V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
The Go Programming Language
http://golang.org/
Go Playground
Go Projects
Revel Web Framework
beego
outmanone
V2EX  ›  Go 编程语言

Golang 实现延迟队列

  •  
  •   outmanone · 14 天前 · 1534 次点击

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

    9 条回复    2021-12-04 11:18:22 +08:00
    BBCCBB
        1
    BBCCBB  
       14 天前
    直接用 redis zset 简单搞, 时间轮就不用了.
    ryalu
        2
    ryalu  
       14 天前
    巧了,最近刚做过相关的功能设计,用了 google 大佬的一个库 https://github.com/hibiken/asynq ,自己也稍加改造了下。主要就是使用 redis 做用户数据库,然用户更新操作放消息队列延迟落地到 mysql ,延迟过程中消息可以再次被覆盖延后(主要为了减轻数据库压力)
    ryalu
        3
    ryalu  
       14 天前
    差不多就这样吧 https://imgur.com/v3YCC5c
    SmiteChow
        4
    SmiteChow  
       14 天前
    延迟队列是伪命题!
    cenbiq
        5
    cenbiq  
       13 天前
    @SmiteChow Why ?为什么我经常碰到需要的场景?
    bsg1992
        6
    bsg1992  
       13 天前
    @SmiteChow 延迟任务为什么是伪命题呢,很多场景下都需要延迟任务来解决问题的呀!
    SmiteChow
        7
    SmiteChow  
       12 天前
    @cenbiq @bsg1992 同步系统处理不了->异步(=延迟)系统削峰填谷
    outmanone
        8
    outmanone  
    OP
       4 天前
    @SmiteChow 可以不用放到同步系统里面,直接启动多个服务,分布在不同机器就可以。
    outmanone
        9
    outmanone  
    OP
       4 天前
    启动多个延迟队列服务,分发到不同机器,消费同一个缓存中不同 db 的队列。
    关于   ·   帮助文档   ·   API   ·   FAQ   ·   我们的愿景   ·   广告投放   ·   感谢   ·   实用小工具   ·   2749 人在线   最高记录 5497   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 21ms · UTC 11:44 · PVG 19:44 · LAX 03:44 · JFK 06:44
    ♥ Do have faith in what you're doing.