RedisClient redisClient = RedisClientBuilder.create()
.withEndpoint(new InetSocketAddress("redis-server", 6379))
.build();
redisClient.set("key", "value");
Future<String> future = redisClient.get("key");
future.onSuccess(value -> {
});
redisClient.connected().onFailure(t -> {
System.err.println("Redis connection failed: " + t.getMessage());
});
import com.twitter.finagle.redis.Client;
import com.twitter.finagle.Redis;
import com.twitter.finagle.Service;
import com.twitter.finagle.builder.ClientBuilder;
Service<String, String> redisService = ClientBuilder()
.hosts("redis-server:6379")
.hostConnectionLimit(10)
.build(Redis.client());
Client redisClient = new Client(redisService);
redisClient.set("key", "value");
redisClient.get("key").onSuccess(value -> {
System.out.println(value);
});
