我还没有尝试过这个,但作为推测,我会使用 Redis 的 Lua 来实现 2 个新命令 - MSR_PUSH 和 MSR_POP - 它们将分别执行以下操作:
-- MSR_PUSH
redis.call("PUSH", KEYS[1], ARGV[1])
redis.call("PUBLISH", "notify", KEYS[1])
和:
-- MSR_POP
local v = redis.call("POP", KEYS[1])
if v then
redis.call("PUBLISH", "notify", KEYS[1])
end
return v
因此,这些 Lua 脚本会像往常一样更新列表,但也会将更新的键名发布到通知发布/订阅,然后允许监视脚本 (golang) 执行某些操作。你也可以推到另一个队列,然后长时间轮询。
这个链接有更多关于 Lua with Redis 的信息:https : //www.redisgreen.net/blog/intro-to-lua-for-redis-programmers/