NoSQL之Redis（二）（java）

mwjhw216

import org.redisson.Config;　　
import org.redisson.Redisson;
　　

　　
import java.util.Queue;
　　
import java.util.Set;
　　
import java.util.concurrent.ConcurrentMap;
　　

　　
public class RedisExample {
　　
    /**
　　
     *
　　
     */
　　

　　
    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("redis 连接成功!");
　　

　　
        //测试concurrentMap
　　
        ConcurrentMap map = redisson.getMap("FirstMap1");
　　
        map.put("zhangsan","男");
　　
        map.put("lisi","男");
　　
        map.put("wangwu","女");
　　

　　
        ConcurrentMap resultMap = redisson.getMap("FirstMap1");
　　
        System.out.println("resultMap = " + resultMap.keySet());
　　

　　
        //2、测试集合类
　　
        Set mySet = redisson.getSet("FirstSet1");
　　
        mySet.add("baidu");
　　
        mySet.add("xinlang");
　　
        mySet.add("souhu");
　　
        mySet.add("wangyi");
　　

　　
        Set resultSet = redisson.getSet("FirstSet1");
　　
        System.out.println("resultSet = " + resultSet.size());
　　

　　

　　
        //3、测试Queue队列
　　
        Queue myQueue = redisson.getQueue("FirstQueue1");
　　
        myQueue.add("董贞");
　　
        myQueue.add("王菲");
　　
        myQueue.add("陈奕迅");
　　

　　
        myQueue.peek();
　　
        myQueue.poll();
　　

　　
        Queue resultQueue = redisson.getQueue("FirstQueue1");
　　
        System.out.println("resultQueue = " + resultQueue);
　　

　　
        //关闭连接
　　
        redisson.shutdown();
　　
    }
　　
}