延迟队列的实现已经有很多种了,本着程序员不造轮子不是好程序员的精神,我用 Golang + 时间轮算法也实现了一个延迟队列,用 Redis 作为持久化,初步已经在生产环境跑了起来。项目地址在这里: https://github.com/0RaymondJiang0/go-delayqueue ,请各位大佬轻拍 :)
1
BBCCBB 2021-11-24 14:53:13 +08:00
|
2
ryalu 2021-11-24 15:20:22 +08:00
巧了,最近刚做过相关的功能设计,用了 google 大佬的一个库 https://github.com/hibiken/asynq ,自己也稍加改造了下。主要就是使用 redis 做用户数据库,然用户更新操作放消息队列延迟落地到 mysql ,延迟过程中消息可以再次被覆盖延后(主要为了减轻数据库压力)
|
3
ryalu 2021-11-24 15:31:12 +08:00
差不多就这样吧 https://imgur.com/v3YCC5c
|
4
SmiteChow 2021-11-24 16:02:58 +08:00
延迟队列是伪命题!
|
9
outmanone OP 启动多个延迟队列服务,分发到不同机器,消费同一个缓存中不同 db 的队列。
|