1.什么是RabbitMQ？RabbitMQ是一个开源的消息中间件，用于在不同应用程序之间传递和存储消息。它实现了AMQP（AdvancedMessageQueuingProtocol）协议，提供了一个可靠的消息传递机制，支持诸如消息持久性、消息发布与订阅、消息路由和消息的顺序性等特性。2.RabbitMQ是如何保证消息的可靠性传递？RabbitMQ通过持久性、确认机制和重试机制来保证消息的可靠性传递。持久性指的是将消息存储在磁盘上，即使RabbitMQ服务器崩溃，也不会丢失消息。确认机制允许发送方在消息成功发送到队列后收到确认。重试机制允许消费者处理消息时发生错误时重试处理。3.Rabbit

本地RabbitMQ服务搭建（windows）前言一、Erlang环境准备1.下载安装包2.安装二、RabbitMQ服务器安装1.下载安装包2.安装RabbitMQserver3.启动RabbitMQ4.启动状态检测5.管理插件启用三、登录管理界面前言前面已经对RabbitMQ介绍了很多内容，今天主要是和大家搭建一个可用的RabbitMQ服务端，方便后续进一步实操与细节分析一、Erlang环境准备1.下载安装包跟我们跑java项目，要装jdk类似。rabbitMQ是基于Erlang开发的，因此安装rabbitMQ服务器之前，需要先安装Erlang环境。【PS:我已经上传了对应资源，window

消息堆积问题当生产者发送消息的速度超过了消费者处理的速度，就会导致队列的消息堆积，知道队列存储消息达到上限。最早接受的消息，可能就会成为死信，会被丢弃，这就是消息堆积问题。解决消费对接问题1.增加更多的消费者，提高消费者速度2.在消费则内开启线程池加快消息处理速度3.使用惰性队列,扩大队列容积，提高堆积上限惰性队列rabbitmq3.6.0版本开始，新增了LazyQueues概念，也就是惰性队列。惰性队列的特征如下：接收的消息后直接存入磁盘而非内存消费者要消费消息时才会从磁盘中读取并加载到内存中支持数百万的消息存储普通的队列会设置一个预警值默认40%当队列到了40%时，mqBroker会阻止生

发布者确认（PublisherConfirms）发布者确认是一个RabbitMQ扩展，用于实现可靠的发布。当在通道上启用发布者确认时，客户端发布的消息将由代理异步确认，这意味着它们已在服务器端得到处理。0、引言先决条件本教程假设RabbitMQ已安装并且正在本地主机的标准端口（5672）上运行。如果您使用了不同的主机、端口或凭证，则要求调整连接设置。获取帮助如果您在阅读本教程时遇到问题，可以通过邮件列表或者RabbitMQ社区Slack与RabbitMQ官方取得联系。在本教程中，我们将使用发布者确认来确保已发布的消息已安全到达代理。我们将介绍几种使用发布者确认的策略，并解释它们的利弊。原文链接

一、卸载rabbitmq相关的        1、卸载前先停掉rabbitmq服务，执行命令                servicerabbitmq-serverstop        2、查看rabbitmq安装的相关列表                yumlist|greprabbitmq        3、卸载rabbitmq已安装的相关内容                yum-yremoverabbitmq-server.noarch二、卸载erlang        1、查看erlang安装的相关列表                yumlist|greperlang   

前言消息队列说明：RocketMQ、kafka、RabbitMQ概述及关键概念文章目录前言消息队列-MessageQueue概述作用几种消息队列中间件对比RocketMQ概述关键概念主题：Topic消息队列：MessageQueue消息：Message生产者：Producer消费者：Consumer消费者分组：ConsumerGroupkafka概述消息队列模式关键概念节点-broker主题-Topic分片-partition生产者-ProducerRabbitMQ概述关键概念服务应用：Server连接：Connection网络信道：Channel消息：Message虚拟地址：Virtualh

RabbiMQ 是用 Erlang 开发的，集群非常方便，因为 Erlang 天生就是一门分布式语言，但其本身并不支持负载均衡。RabbitMQ 的集群节点包括内存节点、磁盘节点。RabbitMQ 支持消息的持久化，也就是数据写在磁盘上，最合适的方案就是既有内存节点，又有磁盘节点。RabbitMQ 模式大概分为以下三种:单一模式；普通模式（默认的集群模式）；镜像模式（把需要的队列做成镜像队列，存在于多个节点，属于 RabbiMQ 的 HA 方案，在对业务可靠性要求较高的场合中比较适用）。要实现镜像模式，需要先搭建一个普通集群模式，在这个模式的基础上再配置镜像模式以实现高可用。1.集群架构 #2

RabbitMQ延时队列和死信队列延时队列和死信队列延时队列是RabbitMQ中的一种特殊队列，它可以在消息到达队列后延迟一段时间再被消费。延时队列的实现原理是通过使用消息的过期时间和死信队列来实现。当消息被发送到延时队列时，可以为消息设置一个过期时间，这个过期时间决定了消息在延时队列中等待的时间。如果消息在过期时间内没有被消费者消费，则会被自动发送到一个预先指定的死信队列中。在RabbitMQ中，延时队列的实现可以通过以下步骤来完成：创建一个普通的队列作为延时队列，设置x-message-ttl参数为消息的过期时间。创建一个死信队列，用于接收延时队列中过期的消息。将延时队列设置为普通队列的死

1、应用场景1.RabbitMQ：适用于易用性和灵活性要求较高的场景异步任务处理：RabbitMQ提供可靠的消息传递机制，适用于处理异步任务，例如将耗时的任务放入消息队列中，然后由消费者异步处理，提高系统的响应速度和可伸缩性。解耦系统组件：通过使用RabbitMQ作为消息中间件，不同的系统组件可以通过消息进行解耦，实现松耦合的架构，提高系统的可维护性和灵活性。事件驱动架构：RabbitMQ的发布-订阅模式可以用于构建事件驱动架构，将系统中的事件作为消息发布到相应的主题，不同的消费者可以订阅感兴趣的主题进行相应的处理。2.RocketMQ：适用于大规模数据处理和高吞吐量的场景分布式事务：Rock

最近遇到了关于RabbitMQ的问题，打比方说：某个微服务模块中，RabbitMQ的大部分消费者需要重试两次，而小部分消费者由于特殊原因并不需要进行重试。这就涉及到自定义重试次数的话题了，但在网上找了一圈没发现相关的，但是功夫不负有心人，最后还是解决了这个问题，接下来给大家分享一下~目录1默认配置重试次数2自定义重试次数2.1消费者① 配置文件②配置队列，绑定交换机③消费者文件2.2生产者① 配置文件②生产者文件③ 测试文件2.3启动测试文件1默认配置重试次数一般来说，关于RabbitMQ的重试次数是直接在配置文件中进行定义（比如application.yml），那么所有的消费者都将遵循这个配