<dependency>
<groupId>com.twitter</groupId>
<artifactId>finagle-redis_2.11</artifactId>
<version>21.1.0</version>
</dependency>
import com.twitter.finagle.redis.Client;
import com.twitter.finagle.redis.Redis;
import com.twitter.util.Future;
import java.net.InetSocketAddress;
public class RedisClientExample {
public static void main(String[] args) {
InetSocketAddress address = new InetSocketAddress("localhost", 6379);
Client client = Redis.client().newRichClient(address);
Future<String> future = client.get("key");
future.onSuccess(response -> {
System.out.println("Get result: " + response);
client.release();
}).onFailure(e -> {
System.err.println("Get failed: " + e.getMessage());
client.release();
});
}
}
import com.twitter.finagle.redis.protocol.RedisProtocol;
import com.twitter.util.Duration;
import com.twitter.util.Future;
import com.twitter.finagle.redis.{Client, Redis}
import java.net.InetSocketAddress;
public class RedisConnectionPoolExample {
public static void main(String[] args) {
InetSocketAddress address = new InetSocketAddress("localhost", 6379);
Client client = Redis.client()
.withSessionQualifier.noFailFast()
.withSessionQualifier.noFailureAccrual()
.withSessionQualifier.noBrokersSlaving()
.withSessionQualifier.noAdmissionControl()
.withMaxConnections(100)
.withMaxIdleTime(Duration.fromSeconds(60))
.newRichClient(address);
Future<String> future = client.set("key", "value");
future.onSuccess(response -> {
System.out.println("Set result: " + response);
client.release();
}).onFailure(e -> {
System.err.println("Set failed: " + e.getMessage());
client.release();
});
}
}
