vivo 在 2016 年引入 RabbitMQ，基于开源 RabbitMQ 进行扩展，向业务提供消息中间件服务。2019年，RabbitMQ 进入高可用建设阶段，完成了高可用组件 MQ 名字服务以及 RabbitMQ 集群的同城双活建设。在 2019 年

Gradle的build.gradle中增加引入。增加配置类，配置我们的两个rabbitMQ:

为什么要使用MQ？因此，系统可用性降低。因此，需要考虑的东西更多，系统复杂性增大。①自动确认模式，消费者挂掉，待ack的消息回归到队列中。针对这个问题，通过某种算法，将需要保持先后顺序的消息放到同一个消息队列中。同一个queue里的消息一定是顺序消息的。例

在电商系统中，一个用户下单之后通常有30分钟的时间进行支付，如果30分钟之内没有支付成功，则这个订单会进行后续一些处理。针对这些场景，常见的方案是：启动一个cron定时任务，定时运行并查询符合时间条件的数据并进行处理。该方案存在以下几点不足：。显然这并不是

生产者将消息发送到队列，消费者从队列中获取消息。

既然要做分布式系统，就不得不说分布式消息通信系统。分布式系统的基础是各个分布式单元能够以各种方式互相通信，分布式消息中间件比较有名的开源实现有rabbitMQ，zeroMQ（库），ActiveMQ等，本篇先考察一下著名的消息中间件rabbitmq. rab

①. 跨系统的异步通信，所有需要异步交互的地方都可以使用消息队列。基于消息队列的耦合，不需要发送方和接收方同时在线。③. 应用内的同步变异步，比如订单处理，就可以由前端应用将订单信息放到队列，后端应用从队列里依次获得消息处理，高峰时的大量订单可以积压在队列

消息队列 主要解决应用解耦、异步消息、流量削峰等问题，实现高性能、高可用、可伸缩和最终一致性架构。Kafka设计原理，为什么Kafka性能高？RabbitMQ 消息中间件RabbitMQ 是由 LShift 提供的一个 Advanced Message Q

由于使用 WebSocket 连接 RabbitMQ 时需要身份认证，而默认认证方式的账号密码都是固定的，使用这种方式时，任何人都能通过前端 JS 代码中的用户密码连接到 RabbitMQ 服务器，不管用什么样的权限进行限制，都不够安全。本文假设用户已经登

制定一项任务，在某个时间之后去执行，这种场景比较适合使用延迟加载的模式。延迟队列存储的对象肯定是对应的延时消息，所谓”延时消息”是指当消息被发送以后，并不想让消费者立即拿到消息，而是等待指定时间后，消费者才拿到这个消息进行消费。RabbitMQ针对队列中的

以前在单项目中用过RabbitMQ，没有问题,不过这次在分布式项目中使用RabbitMQ中有点搞糊涂了，但是实际上是没有问题的，思路清晰就行。6 rabbitmq.vhost=danger然后要配置applicationContext-rabbitmq.x