RedisClient client = RedisClient.create("redis://localhost"); StatefulRedisConnection<String, String> connection = client.connect(); RedisAsyncCommands<String, String> asyncCommands = connection.async(); RedisFuture<String> future = asyncCommands.get("key"); future.thenAccept(value -> System.out.println(value)); connection.close(); client.shutdown(); RedisURI redisURI = RedisURI.Builder.redis("localhost") .withPort(6379) .withPassword("password") .build(); RedisClient client = RedisClient.create(redisURI); GenericObjectPoolConfig<RedisConnection> poolConfig = new GenericObjectPoolConfig<>(); LettucePoolingClientConfiguration configuration = LettucePoolingClientConfiguration.builder() .poolConfig(poolConfig) .build(); StatefulRedisConnection<String, String> connection = client .connect(configuration);


上一篇:
下一篇:
切换中文