<dependencies>
<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-redis-client</artifactId>
<version>x.x.x</version>
</dependency>
</dependencies>
import io.vertx.core.Vertx;
import io.vertx.redis.client.Redis;
import io.vertx.redis.client.RedisOptions;
public class Main {
public static void main(String[] args) {
Vertx vertx = Vertx.vertx();
RedisOptions config = new RedisOptions()
.setHost("localhost")
.setPort(6379);
Redis client = Redis.createClient(vertx, config);
client.close();
vertx.close();
}
}
client.get("key", res -> {
if (res.succeeded()) {
String result = res.result();
System.out.println("GET result: " + result);
} else {
System.out.println("GET failed: " + res.cause().getMessage());
}
});
client.set("key", "value", res -> {
if (res.succeeded()) {
System.out.println("SET succeeded");
} else {
System.out.println("SET failed: " + res.cause().getMessage());
}
});
client.incr("counter", res -> {
if (res.succeeded()) {
Long result = res.result();
System.out.println("INCR result: " + result);
} else {
System.out.println("INCR failed: " + res.cause().getMessage());
}
});
client.del("key", res -> {
if (res.succeeded()) {
Long result = res.result();
System.out.println("DEL result: " + result);
} else {
System.out.println("DEL failed: " + res.cause().getMessage());
}
});
Map<String, String> map = new HashMap<>();
map.put("field1", "value1");
map.put("field2", "value2");
client.hmset("hash", map, res -> {
if (res.succeeded()) {
System.out.println("HMSET succeeded");
} else {
System.out.println("HMSET failed: " + res.cause().getMessage());
}
});
client.close();