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

Golang 实现延迟队列

  •  
  •   outmanone · 2021-11-24 11:50:14 +08:00 · 3489 次点击
    这是一个创建于 1123 天前的主题,其中的信息可能已经有所发展或是发生改变。

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

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