结束交易之前,您 无法获得获取 结果。
如果使用Redis> 2.6.X,则可以使用Lua脚本通过逻辑来创建函数。参见Redis
Lua
这正是我为保证项目中的并发性所做的事情。
编辑:包括一个更完整的示例
您应该创建类似PUBLISHNX脚本(未经测试)的内容:
local shouldPublish = redis.call('SISMEMBER', KEYS[1], ARGV[1])if shouldPublish == 0 redis.call('SADD', KEYS[1], ARGV[1]) redis.call('PUBLISH', ARGV[2], ARGV[3])end
然后传递所有必需的参数,即channel,messageId,message,controlKey。
PS。Wei Li是正确的,在并发的情况下,您可以使用WATCH和循环进行重试来实现相同的结果,但是我仍然更喜欢使用Lua脚本。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)