消息的分发策略

消息的分发策略

MQ消息队列有下面几个角色
1.生产者
2.存储消息
3.消费者

生产者生成消息后，MQ进行存储，消费者是如何获取消息的呢？一般获取消息数据的方式是推（push）和拉（pull）两种方式，典型的git就是有推拉机制，我们发送的http请求就是一种典型的拉去数据库数据返回的过程。而消息队列MQ是一种推送的过程。

场景分析

消息分发策略的机制和对比

轮询分发

在轮询分发的场景下，交换机并不知道后面消费者的消费能力，就两个消费者一人一个这样轮询
缺点：不同消费者处理任务的时间是不一样的，这样会造成性能浪费

公平分发

公平分发的本质就是能者多劳
1，使用公平分发，必须关闭自动应答ack，然后改成手动应答方式。
2，每个消费者发送确认消息之前，消息队列不发送下一个消息到消费者，一次只处理一个消息。
限制发送给同一个消费者不得超过1条消息。
3，消费者增加了channel.basicQos(1)控制同一消息消费次数。
在spring boot里面的配置

publisher-confirms: true  #消息发送到交换机确认机制，是否确认回调
    publisher-returns: true   #消息发送到交换机确认机制，是否返回回调
    listener:
      simple:
        acknowledge-mode: auto    #自动应答ack auto   manual 手动跟新,设置auto，则就是公平分发
        concurrency: 1              #定义最小的消费者数量
        max-concurrency: 100       #定义最大的消费者数量
        retry:
          enabled: false          #是否支持重试
          #将自动应答模式关闭,即开启acknowledge机制
        prefetch: 0              #预读设置,prefetch默认是1，如果设置为0就是轮询模式;就是告诉同一时间将几个消息给消费者,

最后

以上就是调皮小土豆为你收集整理的消息的分发策略的全部内容，希望文章能够帮你解决消息的分发策略所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。