我已经对键值对或使用 Redisson 库构建的数据结构进行了分组。设计是任何一组值的值变化都应作为事件发送到订阅 Lua 脚本。然后这些脚本进行计算并更新另一组的键值对。这个过程是作为一个链来实现的,一旦 Lua 脚本更新了一个键值,它就会生成一个事件,另一个 Lua 脚本会根据某些参数执行类似于第一个 Lua 脚本的工作。
问题一:Lua脚本与事件如何关联?
问题 2:事件是流水线式的,但我的 Lua 脚本可能必须等待网络 IO。在那种情况下,我假设处理了下一个事件并执行了订阅脚本。这对我来说是个问题,因为第一个脚本尚未完成更新所需的键值对,第二个脚本正在继续其工作。这会给我带来错误。有办法克服这个问题吗?
问题 3:如何从 Redisson 数据结构发出事件,我需要 Lua 脚本来理解该数据结构的结构。怎么办?
最佳答案
在撰写本文时,Redis (3.2.9) 不允许在 Lua 脚本中阻塞命令,包括订阅命令。所以不可能通过 Lua 脚本实现你所描述的。
但是您可以使用 Redisson 主题和/或 Redisson 分布式服务来做到这一点:
- 修改值,向 channel 发送消息。另一个进程接收消息,进行计算和更新。
或者……
- 如果只有一个特定的进程进行计算和更新,您可以使用 Redisson 远程服务来告诉该进程完成工作,它的工作方式类似于 RPC。也许它也可以修改第一个值。
或者……
- 将整个批处理创建为一个可运行的作业,并将其发送给 Redisson 远程执行程序进行处理。如果不是立即需要,您也可以选择安排作业。
关于events - 连接 Redis 事件到 Lua 脚本执行和并发问题,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/41536034/