8.7. Eclipse Vert.x Redis 客户端的更改

以下示例演示了如何在 Eclipse Vert.x 3.x 版本中创建 Redis 客户端。

// Create the redis client (3.x)
RedisClient client = RedisClient
  .create(vertx, new RedisOptions().setHost(host));

以下示例演示了如何在 Eclipse Vert.x 4 中创建 Redis 客户端。

// Create the redis client (4.x)
Redis client = Redis
  .createClient(
    vertx,
    "redis://server.address:port");

在 Eclipse Vert.x 4 中，客户端使用以下标准连接字符串语法：

redis[s]://[[user]:password@]server[:port]/[database]

使用"RedisAPI"，您现在可以决定如何管理连接：

或者

您必须创建客户端，然后更新应用程序以处理请求。

以下示例演示了如何在 Eclipse Vert.x 3.x 版本中创建客户端后处理请求。

// Using 3.x
// omitting the error handling for brevity
client.set("key", "value", s -> {
  if (s.succeeded()) {
    System.out.println("key stored");
    client.get("key", g -> {
      if (s.succeeded()) {
        System.out.println("Retrieved value: " + s.result());
      }
    });
  }
});

以下示例演示了如何在 Eclipse Vert.x 4 中创建客户端后处理请求。这个示例使用列表来设置键值对，而不是硬编码选项。有关该命令可用的参数的更多信息，请参阅 Redis SET 命令。

// Using 4.x
// omitting the error handling for brevity

// 1. Wrap the client into a RedisAPI
api = RedisAPI.api(client);

// 2. Use the typed API
api.set(
    Arrays.asList("key", "value"), s -> {
    if (s.succeeded()) {
      System.out.println("key stored");
      client.get("key", g -> {
        if (s.succeeded()) {
          System.out.println("Retrieved value: " + s.result());
        }
      });
    }
});

当您直接迁移到新的 Redis 客户端时：

您必须创建客户端，然后更新应用程序以处理请求。

以下示例演示了如何在 Eclipse Vert.x 3.x 版本中创建客户端后设置和获取请求。

// Using 3.x
// omitting the error handling for brevity
client.set("key", "value", s -> {
  if (s.succeeded()) {
    System.out.println("key stored");
    client.get("key", g -> {
      if (s.succeeded()) {
        System.out.println("Retrieved value: " + s.result());
      }
    });
  }
});

以下示例演示了如何在 Eclipse Vert.x 4 中创建客户端后处理请求。

// Using 4.x
// omitting the error handling for brevity

import static io.vertx.redis.client.Request.cmd;
import static io.vertx.redis.client.Command.*;

client.send(cmd(SET).arg("key").arg("value"), s -> {
    if (s.succeeded()) {
      System.out.println("key stored");
      client.send(cmd(GET).arg("key"), g -> {
        if (s.succeeded()) {
          System.out.println("Retrieved value: " + s.result());
        }
      });
    }
});

在 Eclipse Vert.x 4 中，所有交互都使用 send (Request) 方法。

在 Eclipse Vert.x 3.x 中，用来硬编码所有已知的命令 till Redis 5 的客户端也根据 命令键入响应。

在新客户端中，命令不会硬编码。响应是 Response 类型。新的线路协议具有更多类型范围。

在较旧的客户端中，响应是以下类型：

在新客户端中，响应是以下类型：

Response 对象具有类型转换器。例如，转换器，例如：

如果收到的数据不是请求的类型，则类型转换器将其转换为最接近的数据类型。当无法转换到特定类型时，会引发 UnsupportedOperationException。例如，无法从 String 转换到 List 或 Map。

您还可以处理集合，因为 Response 对象实现了可 Iterable 接口。

以下示例演示了如何执行 MGET 请求。

// Using 4.x
// omitting the error handling for brevity

import static io.vertx.redis.client.Request.cmd;
import static io.vertx.redis.client.Command.*;

client.send(cmd(MGET).arg("key1").arg("key2").arg("key3"), mget -> {
  mget.result()
    .forEach(value -> {
      // Use the single value

在 Redis 角色和节点选项中，已弃用的术语"slave"已被"replica"替代。

// Before (3.x)
Redis.createClient(
      rule.vertx(),
      new RedisOptions()
        .setType(RedisClientType.SENTINEL)
        .addConnectionString("redis://localhost:5000")
        .setMasterName("sentinel7000")
        .setRole(RedisRole.SLAVE));

以下示例显示了在 Eclipse Vert.x 4 中使用 REPLICA 角色。

// After (4.x)
Redis.createClient(
      rule.vertx(),
      new RedisOptions()
        .setType(RedisClientType.SENTINEL)
        .addConnectionString("redis://localhost:5000")
        .setMasterName("sentinel7000")
        .setRole(RedisRole.REPLICA));

// Before (3.9)
options.setUseSlaves(RedisSlaves);

以下示例显示了在 Eclipse Vert.x 4 中使用节点类型 RedisReplicas。

// After (4.x)
options.setUseReplicas(RedisReplicas);