import io.vertx.core.Vertx;
import io.vertx.redis.client.Redis;
import io.vertx.redis.client.RedisAPI;
import io.vertx.redis.client.RedisOptions;
public class RedisExample {
public static void main(String[] args) {
Vertx vertx = Vertx.vertx();
RedisOptions options = new RedisOptions()
.setHost("localhost")
.setPort(6379);
Redis redis = Redis.createClient(vertx, options);
RedisAPI api = RedisAPI.api(redis);
api.set("key", "value", setRes -> {
if (setRes.succeeded()) {
System.out.println("Value saved successfully");
api.get("key", getRes -> {
if (getRes.succeeded()) {
System.out.println("Retrieved value: " + getRes.result());
vertx.close(closeRes -> {
if (closeRes.succeeded()) {
System.out.println("Vert.x closed successfully");
} else {
closeRes.cause().printStackTrace();
}
});
} else {
getRes.cause().printStackTrace();
}
});
} else {
setRes.cause().printStackTrace();
}
});
}
}
