Redis 如何使用 golang 监听 1000 到 10,000 个列表的变化?
Redis how to listen changes in 1000 to 10,000 lists using golang?
我有1000到10000个键存储在Redis中,它们的值类型是列表。
当一个新项目添加到任何一个现有列表时,我需要通知我的 golang 程序。
收到通知后,我需要生成一个新的 goroutine 并执行一个小操作。
我正在为 redis 连接池使用 redigo。
在不重载 Redis 实例的情况下解决此问题的最佳方法是什么?
我没试过这个,但作为推测,我会使用 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 脚本会像往常一样更新列表,但随后还会将更新的键名发布到通知 pub/sub,这将允许监视脚本 (golang)做某事。您也可以只推送到另一个队列,然后对其进行长时间轮询。
这个link有更多关于Lua与Redis的信息:https://www.redisgreen.net/blog/intro-to-lua-for-redis-programmers/
您可以启用 Redis 的键空间通知并订阅您感兴趣的 keys/patterns 上的相关事件。
可以在文档中找到更多详细信息:http://redis.io/topics/notifications
我有1000到10000个键存储在Redis中,它们的值类型是列表。 当一个新项目添加到任何一个现有列表时,我需要通知我的 golang 程序。 收到通知后,我需要生成一个新的 goroutine 并执行一个小操作。
我正在为 redis 连接池使用 redigo。
在不重载 Redis 实例的情况下解决此问题的最佳方法是什么?
我没试过这个,但作为推测,我会使用 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 脚本会像往常一样更新列表,但随后还会将更新的键名发布到通知 pub/sub,这将允许监视脚本 (golang)做某事。您也可以只推送到另一个队列,然后对其进行长时间轮询。
这个link有更多关于Lua与Redis的信息:https://www.redisgreen.net/blog/intro-to-lua-for-redis-programmers/
您可以启用 Redis 的键空间通知并订阅您感兴趣的 keys/patterns 上的相关事件。
可以在文档中找到更多详细信息:http://redis.io/topics/notifications