1
lihongjie0209 2018-06-28 14:42:28 +08:00
消息最起码的属性有 ID 和 Timestemp
消息只在一定的时间范围内有意义, 极端一点, 你不可能收到一条一年前的消息还接着处理. 所以根据业务需求给消息 ID 设置一个 TTL, 或者是直接用 Redis 等缓存机制来保证在合理的时间范围内不会重复消费 |
2
streamo OP @lihongjie0209 嗯,跟我想的差不多,就是一个带过期键支持的 LRU cache。
|
3
lihongjie0209 2018-06-28 16:28:44 +08:00
@streamo #2 我觉能能运行的都很优雅, 至于优化, 需要的时候再说
|