<dependency>
<groupId>com.github.davidmarquis.redis2-guava</groupId>
<artifactId>redis2-guava</artifactId>
<version>2.6.0</version>
</dependency>
compile 'com.github.davidmarquis.redis2-guava:redis2-guava:2.6.0'
RedisURI redisUri = RedisURI.Builder
.redis("your-redis-host", your-redis-port)
.withPassword("your-redis-password")
.build();
RedisClient redisClient = RedisClient.create(redisUri);
RedisConnection<String, String> connection = redisClient.connect();
String key = "myKey";
String value = "Hello, Redis!";
connection.set(key, value).subscribe();
connection.get(key)
.subscribe(result -> {
System.out.println("Retrieved value: " + result);
});
String hashKey = "myHashKey";
String field1 = "field1";
String value1 = "value1";
String field2 = "field2";
String value2 = "value2";
connection.hset(hashKey, field1, value1).subscribe();
connection.hset(hashKey, field2, value2).subscribe();
connection.hget(hashKey, field1)
.subscribe(result -> {
System.out.println("Retrieved value from hash: " + result);
});
String counterKey = "myCounter";
connection.incr(counterKey).subscribe();
connection.get(counterKey)
.subscribe(result -> {
System.out.println("Counter value: " + result);
});
String channel = "myChannel";
String message = "Hello, subscribers!";
RedisPubSubConnection<String, String> pubsubConnection = redisClient.connectPubSub();
pubsubConnection.subscribe(channel)
.subscribe(subscription -> {
System.out.println("Subscribed to channel: " + subscription.getChannel());
});
RedisPubSubConnection<String, String> pubsubConnection2 = redisClient.connectPubSub();
pubsubConnection2.getMessages()
.filter(msg -> msg.getChannel().equals(channel))
.subscribe(msg -> {
System.out.println("Received message: " + msg.getMessage());
});
pubsubConnection.publish(channel, message).subscribe();
