<dependency>
<groupId>com.github.jedisque</groupId>
<artifactId>rxredis</artifactId>
<version>3.0.0</version>
</dependency>
import com.github.jedisque.rxredis.RxRedis;
import com.github.jedisque.rxredis.RedisConnection;
import com.github.jedisque.rxredis.pubsub.PublishHandler;
public class RedisExample {
public static void main(String[] args) {
RxRedis rxRedis = new RxRedis();
RedisConnection connection = rxRedis.connect();
connection.set("key", "value")
.subscribe();
connection.get("key")
.subscribe(result -> System.out.println("Value: " + result.toString()));
connection.subscribe("channel")
.subscribe(new PublishHandler() {
@Override
public void handleMessage(String channel, String message) {
System.out.println("Received message: " + message);
}
});
connection.quit().subscribe();
}
}
