Java鏈接redis的使用示例

Java鏈接redis的使用示例

         Redis是開源的key-value存儲工具，redis一般用來存儲結構化的數據，由於redis的key能夠包含String、hash、listset和sorted list。

         Redisserver目前最穩定的版本是2.8.9，能夠到官網http://redis.io/download下載。根據機器的類型及位數下載對應的版本安裝便可，reids支持linux和windows操做系統。

         Redisclient支持多種語言，包括：c、C++、C#、php、java、python、go等語言，根據本身的開發語言，選擇合適的redis client版本類型便可。我是使用java語言開發的，針對java語言，redis client也提供了多種客戶端支持，按照推薦類型依次是：Jedis、Redisson、JRedis、JDBC-Redis、RJC、redis-protocol、aredis、lettuce。前兩種類型是比較推薦的，咱們採用了Redisson類型版本做爲redisclient的使用。

         Redisson的源碼工程所在位置：https://github.com/mrniko/redisson。這裏有使用示例及一些介紹，這裏再也不詳細的介紹。

1.        新建maven工程

2.        在pom.xml文件的dependencies節點下增長以下內容：

<dependency>

        <groupId>org.redisson</groupId>

        <artifactId>redisson</artifactId>

        <version>1.0.2</version>

    </dependency>

   

    <dependency>

     <groupId>org.slf4j</groupId>

     <artifactId>slf4j-log4j12</artifactId>

     <version>1.7.7</version>

     </dependency>

 

3.        保存pom.xml後，等eclispe工程構建完成後便可進行開發了

4.        開發工程下載地址：http://download.csdn.net/detail/wgw335363240/7251125

開發示例

下面是演示鏈接redis服務器、保存讀取concurrentMap對象、保存讀取set對象和保存讀取Queue對象的示例代碼，代碼比較簡單，這裏就再也不詳細講解了，代碼以下：


package com.my.test.redis;
 
import java.util.Queue;
import java.util.Set;
import java.util.concurrent.ConcurrentMap;
 
import org.redisson.Config;
import org.redisson.Redisson;
 
public class RedisExample {
 
    /**
     * @param args
     */
    public static void main(String[] args) {
        // 1.初始化
        Config config = new Config();
        config.setConnectionPoolSize(10);
        config.addAddress("127.0.0.1:6379");
        Redisson redisson = Redisson.create(config);
        System.out.println("reids鏈接成功...");
 
        // 2.測試concurrentMap,put方法的時候就會同步到redis中
        ConcurrentMap<String, Object> map = redisson.getMap("FirstMap");
        map.put("wuguowei", "男");
        map.put("zhangsan", "nan");
        map.put("lisi", "女");
 
        ConcurrentMap resultMap = redisson.getMap("FirstMap");
        System.out.println("resultMap==" + resultMap.keySet());
 
        // 2.測試Set集合
        Set mySet = redisson.getSet("MySet");
        mySet.add("wuguowei");
        mySet.add("lisi");
 
        Set resultSet = redisson.getSet("MySet");
        System.out.println("resultSet===" + resultSet.size());
         
        //3.測試Queue隊列
        Queue myQueue = redisson.getQueue("FirstQueue");
        myQueue.add("wuguowei");
        myQueue.add("lili");
        myQueue.add("zhangsan");
        myQueue.peek();
        myQueue.poll();
 
        Queue resultQueue=redisson.getQueue("FirstQueue");
        System.out.println("resultQueue==="+resultQueue);
         
        // 關閉鏈接
        redisson.shutdown();
    }
 
}

運行截圖