<dependency>
<groupId>com.twitter</groupId>
<artifactId>finagle-redis_2.12</artifactId>
<version>6.53.0</version>
</dependency>
properties
redis.client.pool.size=10
redis.client.pool.timeout=10s
redis.client.readTimeout=10s
redis.server.host=localhost
redis.server.port=6379
import com.twitter finagle.redis.RedisClient;
import java.net.SocketAddress;
public class RedisClientExample {
public static void main(String[] args) {
RedisClient client = RedisClient();
client.connect(new SocketAddress("localhost", 6379));
client.close();
}
}
import com.twitter finagle.redis.RedisClient;
import com.twitter finagle.redis.response.RedisResult;
public class RedisCommandExample {
public static void main(String[] args) {
RedisClient client = RedisClient();
RedisResult setResult = client.set("key", "value");
RedisResult getResult = client.get("key");
System.out.println("Set result: " + setResult);
System.out.println("Get result: " + getResult);
client.close();
}
}
import com.twitter finagle.redis.pubsub.RedisPubSub;
import com.twitter finagle.redis.pubsub.Message;
public class RedisPubSubExample {
public static void main(String[] args) {
RedisClient client = RedisClient();
RedisPubSub pubSub = client.pubsub();
pubSub.subscribe("channel1", (message) -> System.out.println("Received message: " + message));
pubSub.subscribe("channel2", (message) -> System.out.println("Received message: " + message));
client.publish("channel1", "Hello, world!");
pubSub.unsubscribe("channel1");
client.close();
}
}
