老铁们,多进程从 redis 队列获取消息会有一致性问题么 - V2EX
V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
请不要在回答技术问题时复制粘贴 AI 生成的内容
dengtongcai
V2EX    程序员

老铁们,多进程从 redis 队列获取消息会有一致性问题么

  •  
  •   dengtongcai 2018-12-18 11:09:47 +08:00 4515 次点击
    这是一个创建于 2496 天前的主题,其中的信息可能已经有所发展或是发生改变。

    redis 中 list 队列存放了一个消息,集群中的多个进程同时执行 brpoplpush 获取消息,会有一致性问题么,就是会重复消费么。
    搜了下没找到,官方的说明的原子操作好像都是针对单进程的。

    11 条回复    2019-08-31 12:22:33 +08:00
    kkjinping
        1
    kkjinping  
       2018-12-18 11:18:35 +08:00
    不会重复消费,redis 是单线程的。
    dengtongcai
        2
    dengtongcai  
    OP
       2018-12-18 11:37:10 +08:00
    @kkjinping 谢谢 脑子老转不过,redis 单线程是针对 redis 服务端来说的。
    adspoing
        3
    adspoing  
       2018-12-18 11:37:53 +08:00
    不会啊,原子的
    leriou
        4
    leriou  
       2018-12-18 11:42:01 +08:00
    不会的, redis 内部单线程取数据
    Linxing
        5
    Linxing  
       2018-12-18 19:18:10 +08:00
    @kkjinping 高并发的时候也不会嘛 面试的时候问道过。。也是一直没找到答案
    Linxing
        6
    Linxing  
       2018-12-18 19:19:27 +08:00
    @kkjinping 用 INCR 增加一个值 判断一个值是否大于 100 大于 100 的时候不再增加 高并发是不是可能会出现 101 的情况
    ztlong
        7
    ztlong  
       2018-12-18 19:57:23 +08:00
    @Linxing 两种情况,如果是由程序先 get 后判断是否大于 100 然后 incr,这个是可能出现 101 甚至其他的脏数据,但如果是用的 redis 的 incr 返回值来判断,那么一定会出现 101,但不可能出现 102
    dengtongcai
        8
    dengtongcai  
    OP
       2018-12-19 16:11:01 +08:00
    @Linxing 你这个属于复合操作,会出现脏数据
    Linxing
        9
    Linxing  
       2018-12-19 19:13:14 +08:00
    @dengtongcai 如何避免呢
    Linxing
        10
    Linxing  
       2018-12-19 19:13:26 +08:00
    @ztlong 谢谢
    wendellyih
        11
    wendellyih  
       2019-08-31 12:22:33 +08:00
    watch 命令或者是 lua 脚本,后者操作代码上更干净些。
    关于     帮助文档     自助推广系统     博客     API     FAQ     Solana     1382 人在线   最高记录 6679       Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 25ms UTC 17:04 PVG 01:04 LAX 10:04 JFK 13:04
    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