基于Redis 实现特殊的消息队列
2021年11月25日 - 网易
因此在存储该类型消息的时候,采用(当前时间戳+timeRange)作为分数,添加消息采用Lua脚本执行,保证操作的原子性,Lua脚本首先采用zscore命令检查消息是否已经存在,如果已经存在则直接返回,如果不存在则执行zadd命令添加。优先级消息发送该消息时需要设置priority,priority必须大于16,表示消息的优先级,数值越大表示优先级越高...
详情
因此在存储该类型消息的时候,采用(当前时间戳+timeRange)作为分数,添加消息采用Lua脚本执行,保证操作的原子性,Lua脚本首先采用zscore命令检查消息是否已经存在,如果已经存在则直接返回,如果不存在则执行zadd命令添加。优先级消息发送该消息时需要设置priority,priority必须大于16,表示消息的优先级,数值越大表示优先级越高...