转自：https://blog.csdn.net/zz775854904/article/details/81092892MQ全称为MessageQueue, 消息队列(https://www.oschina.net/action/GoToLink?urlhttp%3A%2F%2Fbaike.baidu.com%2Fview%2F262473.h

前文总结了Dubbo与SpringBoot的整合(https://www.cnblogs.com/cott/p/12373043.html(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fwww.cnblogs.com%2Fcott%2Fp%2F12373043.html))，本文基

上一节学习了cluster，使得我们可以在一个cluster中同步各种消息，不过有时候我们需要把一个cluster的消息同步到另一个cluster中，比如线下测试，模仿用户真实数据。federation插件是一个在不需要cluster，而在brokers之间传输消息的高性能插件，federation插件可以在brokers或者cluster之间传输消

135\.RabbitMQ的使用场景有哪些？抢购活动，削峰填谷，防止系统崩塌。延迟信息处理，比如 10分钟之后给下单未付款的用户发送邮件提醒。解耦系统，对于新增的功能可以单独写模块扩展，比如用户确认评价之后，新增了给用户返积分的功能，这个时候不用在业务代码里添加新增积分的功能，只需要把新增积分的接口订阅

前提条件：PHP拓展amqp协议和sockets要开启使用方式：参见队列(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Flearnku.com%2Fdocs%2Flaravel%2F5.6%2Fqueues%2F1395)

        RabbitMQ是工作在amqp协议（advancedmessagequeueprotocal，高级消息队列协议）上的一个消息中间件。它通过一个生产者消费者模型来处理应用中产生的消息。        除了生产者和消费者，此模型中另外一个重要的概念叫“工作队列”，也称为“任务队列”（TaskQueue），任务队列背后的核心想法是避免

背景在实际使用过程，会遇到这么些情况：生产者发送的消息数量与消费者接收的消息数量不一致。例如生产者向rabbitmq投递了100条消息，消费者只从队列中接收到了80条消息，并且当前队列中已经没有任何消息。要定位这个问题，通常是分段来定位，一方面统计生产者到底发送了多少消息，一方面统计有多少消息是正确路由到

1、发送消息发送消息首先要获取与rabbitmqserver的连接，然后从渠道(chann)中指定的queue发送消息，不能定义两个queue名字相同，但属性不同示例：Sender01.javapackagecom.zf.rabbitmq01;importjava.io.IOException;import

官网文档https://www.rabbitmq.com/rabbitmqctl.8.html一般操作命令后台管理页面都有的，部分没有（应用程序管理，和集群管理）。!(https://oscimg.oschina.net/oscnet/ad668a97b8a7c54904a603dabcfc64a04dc.png)直接使用命令，必须配置环境

为什么使用延迟消息？不同于同步消息，有些业务场景下希望可以实现延迟一定时间再消费消息。典型的场景有微信、支付宝等第三方支付回调接口，会在用户支付后3秒、5秒、30秒等等时间后向应用服务器发送回调请求，确保应用服务器可以正确收到消息。那有些朋友就会说了，把需要定时处理的数据存到数据库中用定时任务就可以实现，为什么还弄个异步消息。增加后台维护