由于RabbitMQ是基于erlang的，所以，在正式安装RabbitMQ之前，需要先安装一下erlang。1、下载mqhttps://www.rabbitmq.com/download.html2、下载erlang（点击下载路径根据下载的MQ版本对应下载erl版本）https://www.erlang.org/downloads3、erlang与MQ版本对应表https://www.rabbitmq.com/which-erlang.html#intro安装步骤省略，分享一下报错的解决方法，一下是启动报错信息Enablingpluginsonnoderabbit@DESKTOP-JQ2K52

例如这个是我的一个消息队列，它默认绑定的交换机是什么类型呢?看到这个图，感觉应该是一个默认的交换机，因为是defaultexchange于是来到交换机来看看其他默认的交换机：这里可以看到默认的交换机是direct（应该没看错吧）但是默认的交换机不应该是有routingKey吗？那么我消息发送为什么没有用到rountKey呢？具体看例子rabbitmq\junior\rabbitmq-simple_receiveMessage-no2待研究

文章目录RabbitMQ的作用为什么使用RabbitMQ数据隔离work模式交换机如何声明队列和交换机消息转换器生产者重连生产者确认MQ持久化消费者的可靠性1.消费者确认机制2.消费失败问题3.业务幂等性如何保证消息不丢失消息重复消费问题RabbitMQ中死信交换机？延迟队列了解哪些？消息堆积问题怎么解决RabbitMQ高可用机制RabbitMQ的作用提供了系统之间的异步调用，比如一个支付功能，用户在支付完成之后，会去数据库中执行后续操作，然后更新支付状态，会生成订单信息，如果后续还需要添加功能，就需要去业务逻辑中修改代码，这样就会出现业务耦合。同时想要执行后续操作，需要等待支付功能完成，在此

1、安装在Mac下安装RabbitMQ是非常简单的，一般默认RabbitMQ服务器依赖的Erlang已经安装，只需要用下面两个命令就可以完成RabbitMQ的安装（前提是homebrew已经被安装）：brewupdatebrewinstallrabbitmq耐心等待，安装完成后需要将/usr/local/sbin添加到$PATH，可以将下面这两行加到~/.bash_profile：#RabbitMQConfigexportPATH=$PATH:/usr/local/sbin编辑完后:wq保存退出，使环境变量立即生效。source~/.bash_profile2、启动RabbitMQ服务上面配置

RabbitMQ各个名词介绍Broker：接收和分发消息的应用，RabbitMQServer就是MessageBrokerVirtualhost：出于多租户和安全因素设计的，把AMQP的基本组件划分到一个虚拟的分组中，类似于网络中的namespace概念。当多个不同的用户使用同一个RabbitMQserver提供的服务时，可以划分出多个vhost，每个用户在自己的vhost创建exchange／queue等Connection：publisher／consumer和broker之间的TCP连接Channel：如果每一次访问RabbitMQ都建立一个Connection，在消息量大的时候建立TC

目录1.docker安装 2.图形化界面介绍2.1Overview  2.2Connections      2.3Channels 2.4Exchanges 2.5Queues 2.6Admin 2.6.1users 2.6.2VirtualHosts 2.6.3FeatureFlags 2.6.4Policies 2.6.5Limits 2.6.2Cluster 2.用户管理3.设置用户身份5.同步和异步 6.RabbitMQ工作模式7.创建队列8.创建交换机9.交换机绑定队列 10.maven连接RabbitMQ小案例10.1创建连接10.2简单模式demo11.在springboot中

工作队列注意事项：一个消息只能被处理一次，不可以处理多次轮询分发信息消息应答消费者在接收到消息并且处理该消息之后，告诉rabbitmq它已经处理了，rabbitmq可以把该消息删除了。倘若mq没有收到应答，mq会将消息转发给其他消费者自动应答：需要在高吞吐和数据传输安全性方面做权衡没有对消息数据进行限制仅适合在消费者可以高效并以某种速率能够处理这些信息的情况下使用。手动应答：应答方式：自动应答在消息接收到以后即做出应答，但若接收以后还需其他操作，对应答无影响。所以当消费者接收到消息，但是在消息处理完之前就已经挂掉了，但是由于自动应答，使得mq会认为已经处理完，并删除该消息。手动应答可以写在消息

canal[kə’næl]，译意为水道/管道/沟渠，主要用途是基于MySQL数据库增量日志解析，提供增量数据订阅和消费目录一、MySQL设置二、启动Canal服务端三、通过Canal客户端消费数据四、通过RabbitMQ消费数据1、启动RabbitMQ2、修改canal配置3、消费RabbitMQ中的数据文档资料github：https://github.com/alibaba/canalwiki：https://github.com/alibaba/canal一、MySQL设置修改my.cnf中配置[mysqld]log-bin=mysql-bin#开启binlogbinlog-format

目录​编辑一、MQ概述1、MQ的简介2、MQ的用途（1）限流削峰（2）异步解耦(3)数据收集二、RabbitMQ概述1、RabbitMQ简介2、四大核心概念3、RabbitMQ的核心部分 ​编辑4、名词解释：三、HelloWorld1、依赖2、消息生产者 3、消息消费者一、MQ概述1、MQ的简介MQ，MessageQueue，是一种提供消息队列服务的中间件，也称为消息中间件，是一套提供了消息生产、存储、消费全过程API的软件系统。消息即数据。一般消息的体量不会很大。 2、MQ的用途MQ的用途有很多，但总结起来其实就是以下三点：（1）限流削峰MQ可以将系统的超量请求暂存其中，以便系统后期可以慢慢

代码：链接：https://pan.baidu.com/s/1nQBIgB_SbzoKu_XMWZ3JoA?pwd=aeoe提取码：aeoe在昨天的练习作业中，我们改造了余额支付功能，在支付成功后利用RabbitMQ通知交易服务，更新业务订单状态为已支付。但是大家思考一下，如果这里MQ通知失败，支付服务中支付流水显示支付成功，而交易服务中的订单状态却显示未支付，数据出现了不一致。此时前端发送请求查询支付状态时，肯定是查询交易服务状态，会发现业务订单未支付，而用户自己知道已经支付成功，这就导致用户体验不一致。因此，这里我们必须尽可能确保MQ消息的可靠性，即：消息应该至少被消费者处理1次那么问题来