Golang 实现延迟队列

2021-11-24 11:50:14 +08:00
 outmanone

延迟队列的实现已经有很多种了,本着程序员不造轮子不是好程序员的精神,我用 Golang + 时间轮算法也实现了一个延迟队列,用 Redis 作为持久化,初步已经在生产环境跑了起来。项目地址在这里: https://github.com/0RaymondJiang0/go-delayqueue ,请各位大佬轻拍 :)

3240 次点击
所在节点    Go 编程语言
9 条回复
BBCCBB
2021-11-24 14:53:13 +08:00
直接用 redis zset 简单搞, 时间轮就不用了.
ryalu
2021-11-24 15:20:22 +08:00
巧了,最近刚做过相关的功能设计,用了 google 大佬的一个库 https://github.com/hibiken/asynq ,自己也稍加改造了下。主要就是使用 redis 做用户数据库,然用户更新操作放消息队列延迟落地到 mysql ,延迟过程中消息可以再次被覆盖延后(主要为了减轻数据库压力)
ryalu
2021-11-24 15:31:12 +08:00
差不多就这样吧 https://imgur.com/v3YCC5c
SmiteChow
2021-11-24 16:02:58 +08:00
延迟队列是伪命题!
cenbiq
2021-11-25 14:29:27 +08:00
@SmiteChow Why ?为什么我经常碰到需要的场景?
bsg1992
2021-11-25 15:37:23 +08:00
@SmiteChow 延迟任务为什么是伪命题呢,很多场景下都需要延迟任务来解决问题的呀!
SmiteChow
2021-11-26 11:27:08 +08:00
@cenbiq @bsg1992 同步系统处理不了->异步(=延迟)系统削峰填谷
outmanone
2021-12-04 11:16:44 +08:00
@SmiteChow 可以不用放到同步系统里面,直接启动多个服务,分布在不同机器就可以。
outmanone
2021-12-04 11:18:22 +08:00
启动多个延迟队列服务,分发到不同机器,消费同一个缓存中不同 db 的队列。

这是一个专为移动设备优化的页面(即为了让你能够在 Google 搜索结果里秒开这个页面),如果你希望参与 V2EX 社区的讨论,你可以继续到 V2EX 上打开本讨论主题的完整版本。

https://www.v2ex.com/t/817625

V2EX 是创意工作者们的社区,是一个分享自己正在做的有趣事物、交流想法,可以遇见新朋友甚至新机会的地方。

V2EX is a community of developers, designers and creative people.

© 2021 V2EX