作为rabbitMQ的生产者，发送消息到MQ的过程中，是通过routingkey发送给交换机，由交换机进行路由，把信息发送的最终的队列中。而rabbitMQ消费的时候，是要明确指明消费的队列的。消费模式rabbitMQ的消费模式分为两种，推模式和拉模式。推模式使用的是Basic.Consume进行消费，而拉模式通过调用Basic.Get进行消费。推模式用于持续的获取消息，在推模式中，RabbitMQ会不断的推送消息给消费者，不过推送的数量可以通过Basic.Qos进行限制。拉模式可以单条的获取信息。消费端的确认和拒绝为了保证消息可以从队列可靠的到达消费者，RabbitMQ提供了消息确认机制。消

Centos7安装RabbitMQ第一步、安装任何软件包之前，建议使用以下命令更新软件包和存储库yum-yupdate第二步、Erlang在默认的YUM存储库中不可用，因此您将需要安装EPEL存储库yum-yinstallepel-releaseyum-yupdate也可以去Erlang官网下载Erlang存储库https://packagecloud.io/rabbitmq/erlang?page=1，将下载好的rpm包防至Centos上第三步、RabbitMQ是基于Erlang（面向高并发的语言）语言开发，所以在安装RabbitMQ之前，需要先安装Erlang语言yum-yinstalle

业务需求：1、商品上架时：search-service新增商品到elasticsearch2、商品下架时：search-service删除elasticsearch中的商品需求分析：数据同步是希望，当我们商品修改了数据库中的商品信息，索引库中的信息也会跟着改。在微服务中数据库和索引库是在两个不同的服务中。如果，商品的服务，向es的服务中发个消息，通知ES服务就可以实现数据的同步。此时我们利用MQ接收商品服务的消息，实现ES服务对消息的监听就可以了。业务模型： ​​​​​​​ 业务实现：商品微服务：消息发送pom.xml1.引入amqp依赖org.springframework.bootspri

一、Direct模式类型：direct特点：Direct模式是fanout模式上的一种叠加，增加了路由RoutingKey的模式。二、codingⅠ生产者 1、引入相应的pom文件pom.xml4.0.0org.springframework.bootspring-boot-starter-parent2.1.5.RELEASEcom.xpfrabbitmq-springboot0.0.1-SNAPSHOTrabbitmq-springbootDemoprojectforSpringBoot8org.springframework.bootspring-boot-starter-amqporg

问题描述：        org.springframework.amqp.rabbit.support.ListenerExecutionFailedException:Failedtoconvertmessage        Causedby:org.springframework.amqp.AmqpException:Nomethodfoundforclassjava.lang.String问题分析：1、消息生产者发送的消息类型为String，消息消费者接收的消息类型为Message，导致接收的时候类型转换不对。@ComponentpublicclassMessageProvider{

1、什么是死信交换机首先我们要知道什么是死信？当一个队列中的消息满足下列情况之一时，可以成为死信（deadletter）：消费者使用basic.reject或basic.nack声明消费失败，并且消息的requeue参数设置为false。消息是一个过期消息，超时无人消费。要投递的队列消息堆积满了，最早的消息可能成为死信。一般呢？一旦消息变成死信是会被我们丢弃的，但是有了死信交换机就不一样了。如果这个包含死信的队列配置了dead-letter-exchange属性，指定了一个交换机，那么队列中的死信就会投递到这个交换机中，而这个交换机称为死信交换机（DeadLetterExchange，简称DL

SpringBoot整合RabbitMq自定义消息监听容器来实现消息批量处理前言添加依赖配置文件编写监听器创建SimpleRabbitListenerContainerFactory发送消息前言RabbitMQ是一种常用的消息队列，SpringBoot对其进行了深度的整合，可以快速地实现消息的发送和接收。在RabbitMQ中，消息的发送和接收都是异步的，因此需要使用监听器来监听消息的到来。SpringBoot中提供了默认的监听器容器，但是有时候我们需要自定义监听器容器，来满足一些特殊的需求，比如批量获取数据。在本文中，我们将使用SpringBoot来整合RabbitMQ，并自定义一个监听器容器

RabbitMQ基础复习1、MQ引言1.1什么是MQ1.2MQ有哪些1.3不同MQ特点2、RabbitMQ引言2.1RabbitMQ2.2RabbitMQ安装3、RabbitMQ配置3.1RabbitMQ命令行3.2Web管理界面3.2.1overview概览3.2.2Admin用户和虚拟主机管理4、RabbitMQ常用消息模型测试4.1RabbitMQ支持的消息模型4.2引入依赖4.3第一种模型：直连4.3.1自定义连接工具类4.3.2生产者4.3.3消费者4.4第二种模型：WorkQueue4.4.1生产者：4.4.2消费者4.4.3改进为能者多劳4.5第三种模型：Fanout4.5.1生

目录前言：具体实现步骤：1、ant环境搭建2、AMQP源码下载3、拷贝JMeter_core.jar包到JMeter-Rabbit-AMQP插件根目录下4、修改AMQP插件的配置文件5、打包6、RabbitMQ客户端插件下载7、完成以上，重启JMeter创建线程组就可以看到AMQP取样器了前言：在使用JMeter进行RabbitMQ测试时，你可以使用JMeter的插件来进行扩展和支持。安装RabbitMQ测试插件是实现这一目标的关键步骤之一。整体流程如下：先下载AMQP插件源码，可以通过ant+ivy在本地编译成jar包，再将jar包导入JMeter目录下，重启JMeter生效。ApacheA

场景：消费端日志控制台报如下错误：2022-11-2513:18:29.354ERROR13368---[.15.178.36:5672]o.s.a.r.c.CachingConnectionFactory:1575-Channelshutdown:channelerror;protocolmethod:#method(reply-code=406,reply-text=PRECONDITION_FAILED-deliveryacknowledgementonchannel5timedout.Timeoutvalueused:1800000ms.Thistimeoutvaluecanbecon