Redis異步客戶端選型及落地實(shí)踐

List<RedisURI> servers = new ArrayList<>();servers.add(RedisURI.create("127.0.0.1", 7000));servers.add(RedisURI.create("127.0.0.1", 7001));servers.add(RedisURI.create("127.0.0.1", 7002));servers.add(RedisURI.create("127.0.0.1", 7003));servers.add(RedisURI.create("127.0.0.1", 7004));servers.add(RedisURI.create("127.0.0.1", 7005));//創(chuàng)建客戶端RedisClusterClient client = RedisClusterClient.create(servers);//創(chuàng)建連接StatefulRedisClusterConnection<String, String> connection = client.connect();//獲取異步命令RedisAdvancedClusterAsyncCommands<String, String> commands = connection.async();//執(zhí)行GET命令RedisFuture<String> future = commands.get("test-lettuce-key");try {    String result = future.get();    log.info("Get命令返回:{}", result);} catch (Exception e) {    log.error("Get命令執(zhí)行異常", e);}

// 設(shè)置基于事件的自適應(yīng)刷新策略ClusterTopologyRefreshOptions topologyRefreshOptions = ClusterTopologyRefreshOptions.builder()        //開(kāi)啟自適應(yīng)拓?fù)渌⑿?/span>        .enableAllAdaptiveRefreshTriggers()        //自適應(yīng)拓?fù)渌⑿率录瑫r(shí)時(shí)間，超時(shí)后進(jìn)行刷新        .adaptiveRefreshTriggersTimeout(Duration.ofSeconds(30))        .build();
redisClusterClient.setOptions(ClusterClientOptions.builder()        .topologyRefreshOptions(topologyRefreshOptions)        // redis命令超時(shí)時(shí)間        .timeoutOptions(TimeoutOptions.enabled(Duration.ofSeconds(30)))        .build());