1.RabbitMQ的自我认识    RabbitMQ是一个在AMQP基础上完成的，可复用的消息中间件。        由于RabbitMQ是由Erlang语言开发，所以安装RabbitMQ之前需要先安装Erlang。        RabbitMQ是一个消息中间件：接收消息并转发，减少非必要逻辑占用系统用时。2.Erlang语言在CentOS7上的安装由于我使用的是CentOS7版本的系统，而目前市面上能找到的匹配el7版本的RabbitMQ安装包版本为3.10.0以下的版本，所以选择下载3.9.16-1.el7.noarch.rpm版本，再根据Erlang和RabbitMQ对应的版本确定，

确保RabbitMQ的延时消息插件已经安装和启用。你可以通过执行以下命令来安装该插件：rabbitmq-pluginsenablerabbitmq_delayed_message_exchange如果提示未安装，以下是安装流程：查看mq版本：查看自己使用的MQ（消息队列）的版本，可以使用以下方法之一：查看MQ的安装目录或文档：在MQ的安装目录中，通常会包含一个关于版本信息的文件或文件夹，例如version.txt、README.md、docs等。你可以查找这些文件，其中应该包含有关MQ版本的信息。查看管理界面：某些MQ提供了管理界面，你可以通过浏览器登录管理界面，在界面上查看版本信息。通常，你

问题概览目前主流的消息队列技术（MQ技术）分为RabbitMQ和Kafka，其中深蓝色为只要是MQ，一般都会问到的问题。浅蓝色是针对RabbitMQ的特性的问题。蓝紫色为针对Kafka的特性的问题。MQ的应用场景MQ主要提供的功能为：异步解耦削峰。展开来讲就是异步发送（验证码、短信、邮件…）MYSQL和Redis/ES之间的数据同步分布式事务削峰填谷RabbitMQ如何保证消息不丢失RabbitMQ的工作流程应该如下，其中每个环节都可能导致消息丢失。publisher叫做发布者，也可叫做生产者。consumer叫做消费者。生产者确认机制（解决消息未到达交换机或队列的问题）生产者确认机制是用来确

延迟队列是指当消息被发送以后，并不是立即执行，而是等待特定的时间后，消费者才会执行该消息。延迟队列的使用场景有以下几种：未按时支付的订单，30分钟过期之后取消订单。给活跃度比较低的用户间隔N天之后推送消息，提高活跃度。新注册会员的用户，等待几分钟之后发送欢迎邮件等。一、如何实现延迟队列？延迟队列有以下两种实现方式：通过消息过期后进入死信交换器，再由交换器转发到延迟消费队列，实现延迟功能；使用官方提供的延迟插件实现延迟功能。早期，大部分公司都会采用第一种方式，而随着RabbitMQ3.5.7（2015年底发布）的延迟插件的发布，因为其使用更简单、更方便，所以它现在才是大家普通会采用的，实现延迟队

目录一、介绍1.概述2.作用及优势3.工作原理二、交换机Exchange1. Direct2.Topic3. Fanout三、代码案例消费者代码  1.直连direct 生产者代码测试2. 主题topic 生产者代码测试3. 扇形fanout 生产者代码测试每篇一获一、介绍1.概述RabbitMQ中的交换机（exchange）是消息的分发中心，它接收来自生产者的消息，并将这些消息路由到一个或多个队列中。交换机根据消息的路由键（routingkey）将消息发送到相应的队列中。四型交换机直连交换机（directexchange）：直连交换机根据消息的路由键将消息发送到与之匹配的队列中。如果消息的路

一、引言1、、消息队列Ⅰ、什么是消息队列？        消息队列是一种进程间通信或同一进程的不同线程间的通信方式，软件的贮列用来处理一系列的输入，通常是来自用户。消息队列提供了异步的通信协议，每一个贮列中的纪录包含详细说明的数据，包含发生的时间，输入设备的种类，以及特定的输入参数。也就是说：消息的发送者和接收者不需要同时与消息队列交互。消息会保存在队列中，直到接收者取回它。Ⅱ、Messagequeue释义        服务之间最常见的通信方式是直接调用彼此来通信,消息从一端发出后立即就可以达到另一端,称为即时消息通讯(同步通信)消息从某一端发出后,首先进入一个容器进行临时存储,当达到某种条

目录一、介绍1.概述2.作用3.工作原理二、RabbitMQ安装部署1.安装2.部署3.增加用户三、实现案例1.项目创建2.项目配置3.生产者代码4.消费者代码四、测试每篇一获一、介绍1.概述RabbitMQ 是一种开源的消息代理和队列服务器，用于通过简单和可扩展的方式在分布式系统中传递消息。它实现了高级消息队列协议（AMQP）。服务之间最常见的通信方式是直接调用彼此来通信,消息从一端发出后立即就可以达到另一端,称为即时消息通讯(同步通信)消息从某一端发出后,首先进入一个容器进行临时存储,当达到某种条件后,再由这个容器发送 给另一端,称为延迟消息通讯(异步通信)一个提供统一消息服务的应用层标准

🎉🎉欢迎来到我的CSDN主页！🎉🎉🏅我是Java方文山，一个在CSDN分享笔记的博主。📚📚🌟推荐给大家我的专栏《RabbitMQ实战》。🎯🎯👉点击这里，就可以查看我的主页啦！👇👇Java方文山的个人主页🎁如果感觉还不错的话请给我点赞吧！🎁🎁💖期待你的加入，一起学习，一起进步！💖💖目录✨前言什么是交换机使用交换机的好处一、交换机(Exchange)的类型1.直连交换机：DirectExchange2.主题交换机：TopicExchange3.扇形交换机：FanoutExchange4.首部交换机：Headersexchange5.默认交换机：DefaultExchange6.死信交换机：Dead

目录前言一.关于交换机1.交换机工作原理2.交换机类型及路由规则二.交换机实战讲解1.直连交换机2.主题交换机3.扇形交换机总结前言RabbitMQ中的交换机（Exchange）是消息的分发中心，负责将消息发送到一个或多个队列。它接收生产者发送的消息并将这些消息路由到消息队列中一.关于交换机1.交换机工作原理在RabbitMQ中生产者发送消息不会直接将消息投递到队列中，而是先将消息投递到交换机中，在由交换机转发到具体的队列，队列再将消息以推送或者拉取的方式给消费者在交换机接收到生产者发送的消息时，交换机会根据消息的路由键和交换机类型，决定将消息路由到哪个队列，而不同类型的交换机也有不同的路由规

RabbitMq批量删除队列​ 由于部分公司同事使用RabbitMq时，没有将Client设置为autodelete，导致大量冗余队列。其中这些队列又是无routekey队列，收到了批量的订阅消息，占用服务器内存。​ 如何将这些无用的队列删除成为一个问题？经过多次摸索，在rabbitmqmanagementapi里面找到了方案：usingSystem.Net.Http.Headers;usingSystem.Text;usingNewtonsoft.Json;classProgram{staticasyncTaskMain(){stringrabbitMQBaseUrl="https://yo