V2EX = way to explore
V2EX 是一个关于分享和探索的地方
Sign Up Now
For Existing Member  Sign In
falsemask
V2EX  ›  问与答

关于 RocketMQ 顺序消息的疑问

  •  
  •   falsemask · Mar 27, 2024 · 1147 views
    This topic created in 774 days ago, the information mentioned may be changed or developed.

    1711538972172.png https://rocketmq.apache.org/zh/docs/featureBehavior/03fifomessage/ 这里的单一生产者指的是单个线程吗?生产都是多实例部署的,如果用户先发起一个下单请求,再发起支付请求,这两个请求都需要发送 MQ 消息。这两个请求被不同的机器处理,用户肯定是先下单再支付的,但是如何保证这两条 MQ 消息也是有序的?

    1 replies    2024-03-27 20:39:16 +08:00
    NizumaEiji
        1
    NizumaEiji  
       Mar 27, 2024   ❤️ 1
    看 rocketmq 的代码。
    发送者的有序是发送者实现的,具体就是根据你的提供的一个分区 key 进行 hash ,然后和具体的逻辑队列数取余,来保证相同分区 key 都发送到一个逻辑队列上。
    所以我理解这种顺序是完全取决于你的消息发送的频率,还有一对顺序消息的严格程度的。你的消息发送频率不高,对于顺序消息的严格程度要求也不高,那多个 jvm 实例并行发送也没啥问题。如果你对顺序严格程度要求高,发送消息的频率要大,那甚至需要你的 mq 发送者单例并且加锁来保证。
    About   ·   Help   ·   Advertise   ·   Blog   ·   API   ·   FAQ   ·   Solana   ·   1035 Online   Highest 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 29ms · UTC 18:27 · PVG 02:27 · LAX 11:27 · JFK 14:27
    ♥ Do have faith in what you're doing.