上一讲我们学习了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中,文档与例子用的是不同的方法,就要问作者了。
具体调用方法请参考上一节。
文章作者:沃航科技