其它特性

操作节点

Redisson NodesGroup 对象提供了对 Redis 节点的一些控制：

  1. NodesGroup nodesGroup = redisson.getNodesGroup();
  2. nodesGroup.addConnectionListener(new ConnectionListener() {
  3.     public void onConnect(InetSocketAddress addr) {
  4.        // Redis server connected
  5.     }
  7.     public void onDisconnect(InetSocketAddress addr) {
  8.        // Redis server disconnected
  9.     }
  10. });

允许给单个或所有 Redis 服务器发送 ping 请求：

  1. NodesGroup nodesGroup = redisson.getNodesGroup();
  2. Collection<Node> allNodes = nodesGroup.getNodes();
  3. for (Node n : allNodes) {
  4.     n.ping();
  5. }
  6. // or
  7. nodesGroup.pingAll();

执行批量命令

通过 RBatch 对象可以将多个命令汇总到一个网络调用中一次性发送并执行。 通过这个对象你可以一组命令的执行时间。 在 Redis 中这种方式称为 Pipeling。

  1. RBatch batch = redisson.createBatch();
  2. batch.getMap("test").fastPutAsync("1", "2");
  3. batch.getMap("test").fastPutAsync("2", "3");
  4. batch.getMap("test").putAsync("2", "5");
  5. batch.getAtomicLongAsync("counter").incrementAndGetAsync();
  6. batch.getAtomicLongAsync("counter").incrementAndGetAsync();
  8. List<?> res = batch.execute();

脚本

  1. redisson.getBucket("foo").set("bar");
  2. String r = redisson.getScript().eval(Mode.READ_ONLY, 
  3.    "return redis.call('get', 'foo')", RScript.ReturnType.VALUE);
  5. // do the same using cache
  6. RScript s = redisson.getScript();
  7. // load script into cache to all redis master instances
  8. String res = s.scriptLoad("return redis.call('get', 'foo')");
  9. // res == 282297a0228f48cd3fc6a55de6316f31422f5d17
  11. // call script by sha digest
  12. Future<Object> r1 = redisson.getScript().evalShaAsync(Mode.READ_ONLY, 
  13.    "282297a0228f48cd3fc6a55de6316f31422f5d17", 
  14.    RScript.ReturnType.VALUE, Collections.emptyList());

Spring Cache 集成

Redisson 完全支持 Spring Cache 抽象. 每个 Cache 实例具有两个重要参数： ttl 和 maxIdleTime， 且在它们没有定义或者等于 0 时会永久存储。 配置示例：

  1. @Configuration
  2. @ComponentScan
  3. @EnableCaching
  4. public static class Application {
  6.     @Bean(destroyMethod="shutdown")
  7.     RedissonClient redisson() throws IOException {
  8.         Config config = new Config();
  9.         config.useClusterServers()
  10.               .addNodeAddress("127.0.0.1:7004", "127.0.0.1:7001");
  11.         return Redisson.create(config);
  12.     }
  14.     @Bean
  15.     CacheManager cacheManager(RedissonClient redissonClient) {
  16.         Map<String, CacheConfig> config = new HashMap<String, CacheConfig>();
  17.         config.put("testMap", new CacheConfig(24*60*1000, 12*60*1000));
  18.         return new RedissonSpringCacheManager(redissonClient, config);
  19.     }
  21. }

Cache 配置也可以从 JSON 或 YAML 配置文件中读取：

  1. @Configuration
  2. @ComponentScan
  3. @EnableCaching
  4. public static class Application {
  6.     @Bean(destroyMethod="shutdown")
  7.     RedissonClient redisson(@Value("classpath:/redisson.json") Resource configFile) throws IOException {
  8.         Config config = Config.fromJSON(configFile.getInputStream());
  9.         return Redisson.create(config);
  10.     }
  12.     @Bean
  13.     CacheManager cacheManager(RedissonClient redissonClient) throws IOException {
  14.         return new RedissonSpringCacheManager(redissonClient, "classpath:/cache-config.json");
  15.     }
  17. }

底层 Redis 客户端

Redisson 使用高性能异步且无锁的 Redis 客户端。 它支持异步和同步模式。 如果 Redisson 尚不支持，你可以通过它自行执行命令。 当然，在使用底层客户端之前，你可能想在 Redis命令映射 查询一下。

  1. RedisClient client = new RedisClient("localhost", 6379);
  2. RedisConnection conn = client.connect();
  3. //or 
  4. Future<RedisConnection> connFuture = client.connectAsync();
  6. conn.sync(StringCodec.INSTANCE, RedisCommands.SET, "test", 0);
  7. conn.async(StringCodec.INSTANCE, RedisCommands.GET, "test");
  9. conn.sync(RedisCommands.PING);
  11. conn.close()
  12. // or
  13. conn.closeAsync()
  15. client.shutdown();
  16. // or
  17. client.shutdownAsync();