10.3. 命令的批量执行

多个连续命令可以通过RBatch对象在一次网络会话请求里合并发送，这样省去了产生多个请求消耗的时间和资源。这在Redis中叫做管道。

用户可以通过以下方式调整通过管道方式发送命令的方式：

  1. BatchOptions options = BatchOptions.defaults()
  2. // 指定执行模式
  3. //
  4. // ExecutionMode.REDIS_READ_ATOMIC - 所有命令缓存在Redis节点中，以原子性事务的方式执行。
  5. //
  6. // ExecutionMode.REDIS_WRITE_ATOMIC - 所有命令缓存在Redis节点中，以原子性事务的方式执行。
  7. //
  8. // ExecutionMode.IN_MEMORY - 所有命令缓存在Redisson本机内存中统一发送，但逐一执行（非事务）。默认模式。
  9. //
  10. // ExecutionMode.IN_MEMORY_ATOMIC - 所有命令缓存在Redisson本机内存中统一发送，并以原子性事务的方式执行。
  11. //
  12. .executionMode(ExecutionMode.IN_MEMORY)
  14. // 告知Redis不用返回结果（可以减少网络用量）
  15. .skipResult()
  17. // 将写入操作同步到从节点
  18. // 同步到2个从节点，等待时间为1秒钟
  19. .syncSlaves(2, 1, TimeUnit.SECONDS)
  21. // 处理结果超时为2秒钟
  22. .responseTimeout(2, TimeUnit.SECONDS)
  24. // 命令重试等待间隔时间为2秒钟
  25. .retryInterval(2, TimeUnit.SECONDS);
  27. // 命令重试次数。仅适用于未发送成功的命令
  28. .retryAttempts(4);

使用方式如下：

  1. RBatch batch = redisson.createBatch();
  2. batch.getMap("test").fastPutAsync("1", "2");
  3. batch.getMap("test").fastPutAsync("2", "3");
  4. batch.getMap("test").putAsync("2", "5");
  5. batch.getAtomicLongAsync("counter").incrementAndGetAsync();
  6. batch.getAtomicLongAsync("counter").incrementAndGetAsync();
  8. BatchResult res = batch.execute();
  9. // 或者
  10. Future<BatchResult> asyncRes = batch.executeAsync();
  11. List<?> response = res.getResponses();
  12. res.getSyncedSlaves();

在集群模式下，所有的命令会按各个槽所在的节点，筛选分配到各个节点并同时发送。每个节点返回的结果将会汇总到最终的结果列表里。