<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();


上一篇:
下一篇:
切换中文