mwjhw216 发表于 2018-11-3 11:17:01

NoSQL之Redis(二)(java)

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


页: [1]
查看完整版本: NoSQL之Redis(二)(java)