<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-redis-client</artifactId>
<version>4.1.0</version>
</dependency>
import io.vertx.redis.client.Redis;
import io.vertx.redis.client.RedisAPI;
import io.vertx.redis.client.RedisOptions;
import io.vertx.core.Vertx;
public class RedisClientExample {
public static void main(String[] args) {
Vertx vertx = Vertx.vertx();
RedisOptions options = new RedisOptions()
.setHost("localhost")
.setPort(6379);
Redis client = Redis.createClient(vertx, options);
client.connect()
.onSuccess(connection -> {
// ...
})
.onFailure(error -> {
});
}
}
// ...
client.connect()
.onSuccess(connection -> {
RedisAPI redisAPI = RedisAPI.api(connection);
redisAPI.get("key")
.onSuccess(result -> {
})
.onFailure(error -> {
});
redisAPI.set("key", "value")
.onSuccess(result -> {
})
.onFailure(error -> {
});
})
.onFailure(error -> {
});
// ...
