上一讲我们学习了vert.x如何操作redis,这一讲我们学习另一种vert.x操作redis的方法。两种方式调用相同的库,但是调用的函数不同,同学们注意对比。
新建RedisClient.java文件
package REDIS; import io.vertx.core.Vertx; import io.vertx.core.json.JsonObject; import io.vertx.redis.client.Redis; import io.vertx.redis.client.RedisAPI; import io.vertx.redis.client.RedisOptions; import java.util.Arrays; import java.util.List; public class RedisClient { private static RedisAPI client = null; public static void Init(Vertx vertx) { Redis.createClient(vertx, new RedisOptions(new JsonObject() .put("endpoint", "localhost:6379"))) .connect(onConnect -> { if (onConnect.succeeded()) { Redis redis = onConnect.result(); client = RedisAPI.api(redis); } }); } public static void set (String key, String value) { List<String> args = Arrays.asList(key, value); client.set(args, res -> { if (res.failed()) { System.out.println("redis set fail"); } }); } public static void get(String key, RedisLambda r) { client.get(key, res -> { if (res.failed()) { System.out.println("Connection or Operation Failed " + res.cause()); } r.ReturnData(res.result().toString()); }); } }
可以看见,这次主要用的是一个叫做RedisAPI的类
其中set需要新建一个List<String>对象,本使用方法来源于vert.x的文档介绍,至于为什么vert.x中,文档与例子用的是不同的方法,就要问作者了。
具体调用方法请参考上一节。
文章作者:沃航科技