zoukankan      html  css  js  c++  java
  • RocketMQ 消息消费

    消息消费

    难点:如何保证消息只消费一次?

         顺序消费?

    消费模式:

      1、单一消费模式:一条消息,仅被一个消费者进行消费。

        如何进行负载?负载算法有 a、平均分配。b、平均轮询分配。c、一致性hash(不推荐)。d、根据配置,为消费者指定消息队列。e、根据broker进行分配,消费者固定消费指定的Broker。

      2、广播模式:一条消息被所有的消费者消费。

    消息的消费:

      1、一个消息队列,同时只允许一个消费者进行消息的消费。一个消费者可以消费多个消息队列。 

    顺序消费:

      1、RocketMq 仅保证队列里面的消息顺序的消费,如果需要保证主题(topic)的顺序消费,需要将topic的的队列设置为1(默认为4),这样设置取消了队列的高性能。

     

    与ActiveMq的对比:

      1、高性能方面:存储消息的时候,使用多个队列来存储,可以并发的进行消息的消费。

      2、ActiveMq消息顺序的处理方式为:任何时候,只允许一个消费者消费消息。如果有2个consumer都是这样配置的,broker只会把队列消息发送给其中一个consumer,如果这个consumer挂掉了,broker会把消息推送给另外的consumer,这样就保证了按顺序消费消息。

        

  • 相关阅读:
    hdu5714 拍照[2016百度之星复赛C题]
    hdu5715 XOR 游戏 [2016百度之星复赛D题]
    AFO
    BZOJ 3566 概率充电器
    BZOJ 3427 Bytecomputer
    BZOJ 4513 储能表
    BZOJ 3667 Miller_Rabin
    BZOJ 4557 侦察守卫
    BZOJ 3894 文理分科
    SUOI #69 奔跑的Aqua
  • 原文地址:https://www.cnblogs.com/chen--biao/p/10166585.html
Copyright © 2011-2022 走看看