请教一下各位,在 toB saas 系统开发中,大家是如何用好消息队列的 - V2EX
V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
请不要在回答技术问题时复制粘贴 AI 生成的内容
rainbow9
V2EX    程序员

请教一下各位,在 toB saas 系统开发中,大家是如何用好消息队列的

  •  
  •   rainbow9 2020-08-25 12:08:03 +08:00 1219 次点击
    这是一个创建于 1886 天前的主题,其中的信息可能已经有所发展或是发生改变。

    场景一、 一般而言,toB 系统业务逻辑比较复杂,涉及使用事务的东西也比较多,这种是不是时候用消息队列如 kafka 之类的做流式处理,做业务解耦, 比如具体到一个很小的例子,在一个接口中处理如下业务逻辑 查询 A 业务表数据 -> 查询 B 业务表数据 -> 更新 A 业务表数据 -> 更新 B 业务表数据 -> 还有一些后续的逻辑处理(比如写入统计数据、发送短信等等),这里面加入队列来解耦,有比较好的实践么,为了某些一致性考虑,需不要要把加入队列包在事务里,如果加入队列失败,需不要把数据库操作回滚。

    场景二、系统很多延时消息之类的,比如 xxx 时间点,提醒某某人做 xxx 事,这个时间点还经常变化,这种有么有用 kafka 去自己做延时消息的(后端是 php 技术栈)。

    Littlesqx
        1
    Littlesqx  
       2020-08-25 14:07:45 +08:00
    自荐,已经生产验证过;自定义监控支持,多进程弹性扩容,支持 Swoole 协程 API https://github.com/Littlesqx/aint-queue
    rainbow9
        2
    rainbow9  
    OP
       2020-08-25 17:31:58 +08:00
    @Littlesqx 标记一下,我学习一下。
    关于     帮助文档     自助推广系统     博客     API     FAQ     Solana     1404 人在线   最高记录 6679       Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 92ms UTC 16:51 PVG 00:51 LAX 09:51 JFK 12:51
    Do have faith in what you're doing.
    ubao msn snddm index pchome yahoo rakuten mypaper meadowduck bidyahoo youbao zxmzxm asda bnvcg cvbfg dfscv mmhjk xxddc yybgb zznbn ccubao uaitu acv GXCV ET GDG YH FG BCVB FJFH CBRE CBC GDG ET54 WRWR RWER WREW WRWER RWER SDG EW SF DSFSF fbbs ubao fhd dfg ewr dg df ewwr ewwr et ruyut utut dfg fgd gdfgt etg dfgt dfgd ert4 gd fgg wr 235 wer3 we vsdf sdf gdf ert xcv sdf rwer hfd dfg cvb rwf afb dfh jgh bmn lgh rty gfds cxv xcv xcs vdas fdf fgd cv sdf tert sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf shasha9178 shasha9178 shasha9178 shasha9178 shasha9178 liflif2 liflif2 liflif2 liflif2 liflif2 liblib3 liblib3 liblib3 liblib3 liblib3 zhazha444 zhazha444 zhazha444 zhazha444 zhazha444 dende5 dende denden denden2 denden21 fenfen9 fenf619 fen619 fenfe9 fe619 sdf sdf sdf sdf sdf zhazh90 zhazh0 zhaa50 zha90 zh590 zho zhoz zhozh zhozho zhozho2 lislis lls95 lili95 lils5 liss9 sdf0ty987 sdft876 sdft9876 sdf09876 sd0t9876 sdf0ty98 sdf0976 sdf0ty986 sdf0ty96 sdf0t76 sdf0876 df0ty98 sf0t876 sd0ty76 sdy76 sdf76 sdf0t76 sdf0ty9 sdf0ty98 sdf0ty987 sdf0ty98 sdf6676 sdf876 sd876 sd876 sdf6 sdf6 sdf9876 sdf0t sdf06 sdf0ty9776 sdf0ty9776 sdf0ty76 sdf8876 sdf0t sd6 sdf06 s688876 sd688 sdf86