<dependencies>
<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-redis-client</artifactId>
<version>4.1.5</version>
</dependency>
</dependencies>
dependencies {
implementation 'io.vertx:vertx-redis-client:4.1.5'
}
import io.vertx.core.Vertx;
import io.vertx.redis.client.Redis;
import io.vertx.redis.client.RedisClient;
import io.vertx.redis.client.RedisOptions;
public class RedisClientExample {
public static void main(String[] args) {
Vertx vertx = Vertx.vertx();
RedisOptions options = new RedisOptions()
.setHost("localhost")
.setPort(6379);
RedisClient redisClient = Redis.createClient(vertx, options);
}
}
redisClient.get("key", ar -> {
if (ar.succeeded()) {
String value = ar.result().toString();
System.out.println("Value: " + value);
} else {
System.out.println("Failed to get value");
}
});
redisClient.set("key", "value", ar -> {
if (ar.succeeded()) {
System.out.println("Value set successfully");
} else {
System.out.println("Failed to set value");
}
});
redisClient.hgetall("hash", ar -> {
if (ar.succeeded()) {
JsonObject result = ar.result();
System.out.println("Hash: " + result.encode());
} else {
System.out.println("Failed to get hash");
}
});
import io.vertx.core.Vertx;
import io.vertx.redis.client.Redis;
import io.vertx.redis.client.RedisClient;
import io.vertx.redis.client.RedisOptions;
import io.vertx.redis.client.impl.RedisConnectionUtils;
public class ConcurrentRedisOperations {
public static void main(String[] args) {
Vertx vertx = Vertx.vertx();
RedisOptions options = new RedisOptions()
.setHost("localhost")
.setPort(6379);
RedisClient redisClient = Redis.createClient(vertx, options);
for (int i = 0; i < 1000; i++) {
vertx.executeBlocking(promise -> {
redisClient.set("key" + i, "value" + i, ar -> {
if (ar.succeeded()) {
promise.complete();
} else {
promise.fail(ar.cause());
}
});
}, res -> {
if (res.succeeded()) {
System.out.println("Value set successfully");
} else {
System.out.println("Failed to set value: " + res.cause().getMessage());
}
});
}
}
}
