1、前言RabbitMQ消息首先发送到交换机，然后通过路由键【routingKey】和【bindingKey】比较从而将消息发送到对应的队列【queue】上。在这个过程有两个地方消息可能会丢失：消息发送到交换机的过程。消息从交换机发送到队列的过程。而RabbitMQ提供了类似于回调函数的机制来告诉发送方消息是否发送成功。这里针对上述的两种情况，RabbitMQ也是给出了以下的应对策略：publisher-confirm：消息到达交换机时会触发。publisher-return：到达交换机但是没有路由到队列，会返回ack以及失败原因。2、publisher-confirm在SpringBoot项

1、引入springboot整合amqp的依赖org.springframework.bootspring-boot-starter-amqp2、application.yml配置server:port:8111spring:rabbitmq:port:5672host:localhostusername:guestpassword:guest#这个配置是保证提供者确保消息推送到交换机中，不管成不成功，都会回调publisher-confirm-type:correlated#保证交换机能把消息推送到队列中publisher-returns:truevirtual-host:/#这个配置是保证

RabbitMQ帮助类的封装基本部分publicclassRabbitMQInvoker{#regionIdentyprivatestaticIConnection_CurrentConnection=null;privatereadonlystring_HostName=null;privatereadonlystring_UserName=null;privatereadonlystring_Password=null;#endregionpublicRabbitMQInvoker(stringhostName="localhost",stringuserName="guest",stri

1介绍:RabbitMQ是一个开源的消息中间件，它实现了AMQP（高级消息队列协议）标准，并且支持多种语言和操作系统，包括Java、Python、Ruby、PHP、.NET、MacOS、Windows、Linux等等。RabbitMQ提供了可靠的消息传递机制，能够保证消息的可靠性和可靠传输，同时还支持消息的路由与转发，能够实现灵活的消息处理模式。RabbitMQ的核心概念是消息、生产者、消费者和队列。生产者通过发送消息到队列中，而消费者则从队列中接收消息。RabbitMQ支持多个消费者从同一队列中接收消息，从而实现集群的负载均衡和高可用性。RabbitMQ支持多种交换机类型（Direct、Fa

前言：在介绍RabbitMQ之前，我们先来看下面一个场景：1.1.1.1异步处理场景说明：用户注册后，需要发注册邮件和注册短信，传统的做法有两种1.串行的方式(1)串行方式：将注册信息写入数据库后，发送注册邮件，再发送注册短信，以上三个任务全部完成后才返回给客户端。这有一个问题是，邮件，短信并不是必须的，它只是一个通知，而这种做法让客户端等待没有必要等待的东西。(2)并行方式：将注册信息写入数据库后，发送邮件的同时，发送短信，以上三个任务完成后，返回给客户端，并行的方式能提高处理的时间。假设三个业务节点分别使用50ms，串行方式使用时间150ms，并行使用时间100ms。虽然并性已经提高的处理

RabbitMQ入门（详细）初始消息队列消息队列初识为什么要使用消息队列？消息队列的特性RabbitMQ介绍特点核心概念Linux（CentOs7）下安装：安装前配置：Erlang下载安装RabbitMQ下载安装linux下安装rabbitmq可能会遇到的问题Linux常用命令RabbitMQWeb界面管理新增用户管理界面Java基础应用创建连接工厂设置RabbitMQ地址建立连接获得信道声明队列发布或消费（接收）消息发布消息：消费（接收）消息：关闭连接交换机工作模式fanout广播模式direct直接模式topic主题模式：应用：定义交换机：接收时需要绑定队列：广播模式完整案例：其他知识点消

文章目录1.场景描述1.1场景11.2场景22.原理3.实战开发3.1建表3.2集成mybatis-plus3.3集成RabbitMq3.3.1安装mq3.3.2springBoot集成mq3.4具体实现3.4.1mq配置类3.4.2生产者3.4.3消费者1.场景描述消息中间件是分布式系统常用的组件，无论是异步化、解耦、削峰等都有广泛的应用价值。我们通常会认为，消息中间件是一个可靠的组件——这里所谓的可靠是指，只要我把消息成功投递到了消息中间件，消息就不会丢失，即消息肯定会至少保证消息能被消费者成功消费一次，这是消息中间件最基本的特性之一，也就是我们常说的“ATLEASTONCE”，即消息至少

一、需要保证MQ顺序消费的场景实际项目中，比如订单系统要同步订单表的数据到大数据部门的MySQL库中，通常做法是通过Canal这样的中间件去监听binlog，然后再把这些binlog发送到MQ中，然后消费者从MQ中获取binlog数据落地到大数据部门的MySQL中。在这个过程，可能有订单的增删改操作，需要保证binlog数据一定是有序的，比如binlog执行顺序是增加、修改。但是消费者可能拿到的顺序是修改、增加，这就导致数据发生异常二、发生消息乱序的原因1、多个消费者消费一个队列中的消息1）原因一个queue，但是有多个consumer去消费，因为我们无法保证先读到消息的consumer一定先

一、准备安装文件1、下载Erlang登录网站Downloads-Erlang/OTP，选择“DownloadWindowsinstaller”，如下图所示：弹出框中，选在下载保存地址，保存文件，如下图所示：2、下载RabbitMQ登录网站https://github.com/rabbitmq/rabbitmq-server/releases/tag/v3.12.4，选择“rabbitmq-server-3.12.4.exe”，如下图所示二、安装1、Erlang安装点击“otp_win64_26.0.2”文件，选择默认路径，一路点击“next”，最后点击”close”结束安装配置环境变量（1）打

目录1初识MQ1.1同步和异步通讯1.1.1同步通讯1.1.2异步通讯1.2技术对比2.快速入门2.1安装RabbitMQ2.1.1单机部署2.1.2集群部署2.2RabbitMQ消息模型2.3.导入Demo工程2.4入门案例2.4.1publisher实现2.4.2consumer实现3SpringAMQP3.1BasicQueue简单队列模型3.1.1消息发送3.1.2消息接收3.1.3测试3.2WorkQueue3.2.1.消息发送3.2.2消息接收3.2.3.测试3.2.4.能者多劳3.2.5总结3.3发布/订阅3.4Fanout3.4.1案例----利用SpringAMQP演示Fan