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。這里有使用示例及一些介紹，這里不再詳細的介紹。

Redisson版的redis可發工程搭建

1.        新建maven工程

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

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();
    }

}

運行截圖：