1

我已经对使用 Redisson 库构建的键值对或数据结构进行了分组。设计是任何一组值的值的变化都应该作为事件发送到订阅 Lua 脚本。然后这些脚本进行计算并更新另一个组的键值对。这个过程是作为一个链来实现的，一旦 Lua 脚本更新了一个键值对，它就会生成一个事件，另一个 Lua 脚本会根据某些参数执行类似于第一个 Lua 脚本的工作。

问题一：如何连接Lua脚本和事件？

问题 2：事件是流水线的，但我的 Lua 脚本可能必须等待网络 IO。在这种情况下，我假设处理了下一个事件并执行了订阅脚本。这对我来说是个问题，因为第一个脚本还没有完成更新它需要的键值对，而第二个脚本正在继续它的工作。这会给我带来错误。有没有办法克服这个问题？

问题 3：如何从 Redisson 数据结构中发出事件，我需要 Lua 脚本来理解该数据结构的结构。如何？

4

1 回答 1

1

在撰写本文时，Redis (3.2.9) 不允许在 Lua 脚本中阻塞命令，包括 subscribe 命令。所以不可能通过 Lua 脚本实现你所描述的。

但是，您可以使用 Redisson 主题和/或 Redisson 分布式服务来执行此操作：

  1. 修改一个值，向通道发送消息。另一个进程接收消息，进行计算和更新。

或者 ...

  1. 如果只有一个特定的进程进行计算和更新，您可以使用 Redisson 远程服务告诉该进程完成工作，它的工作方式类似于 RPC。也许它也可以修改第一个值。

或者 ...

  1. 将整个批次创建为一个可运行的作业，并将其发送给 Redisson 远程执行器进行处理。如果不是立即需要，您也可以选择安排作业。
于 2017-06-21T20:59:58.773 回答