在消息中间件你该了解的秘密一文中详细介绍了如何使用RabbitMQ发送消息、消费消息；如何保证生产者发送消息的可靠性；如何保证消费消息的可靠性、如何横向扩展消费者以及如何对消费者进行流向削峰。
@RabbitListener注解指定目标方法作为消费消息的方法，通过注解参数指定所监听的队列或者Binding。
高级消息队列协议（AMQP）是面向消息的中间件的平台中立的线级协议。Spring AMQP项目将核心Spring概念应用于基于AMQP的消息传递解决方案的开发。Spring Boot通过RabbitMQ使用AMQP提供了一些便利，包括spring-boot-starter-amqp “Starter”。
2、我们建立一个BookService.java并为相关方法加上@RabbitListener注解，启动服务器：
1、RabbitMQ的消息持久化处理，消息的可靠性是 RabbitMQ 的一大特色，那么 RabbitMQ 是如何保证消息可靠性的呢——消息持久化。
之前介绍了 rabbitmq 的消息发送姿势，既然有发送，当然就得有消费者，在 SpringBoot 环境下，消费可以说比较简单了，借助@RabbitListener注解，基本上可以满足你 90%以上的业务开发需求
现在使用广播的形式在消费端进行接收消息，因为交换机和队列需要绑定，所以，我们在消费端可以直接使用绑定的注解，将队列和交换机进行绑定。注解就是如下的这种情况
@RabbitListener注解如果没有存在exchange和queue会自动创建
RabbiMQ的认知：首先要抛弃熟悉的客户端和服务器的观念。对于RabbitMQ应该认为是消息投递服务。、
首先我们来看一下消息的传输流程。消息生产者–>MQ–>消息消费者；消息生产者发送消息到MQ服务器，MQ服务器存储消息，消息消费者监听MQ的消息，发现有消息就消费消息。
Spring AMQP作为Spring框架的一部分，是一套用于支持高级消息队列协议（AMQP）的工具。AMQP是一种强大的消息协议，旨在支持可靠的消息传递，特别适用于构建分布式系统。Spring AMQP构建在RabbitMQ之上，提供了在微服务架构中进行异步通信和消息传递的强大机制。
Exchange（交换机）只负责转发消息，不具备存储消息的能力，因此如果没有任何队列与Exchange绑定，或者没有符合路由规则的队列，那么消息会丢失！
RabbitMQ是一个流行的开源消息中间件，被广泛用于分布式系统和企业应用中。它是一个可靠的、高效的、可扩展的、支持多种消息协议的消息队列系统。本文将介绍RabbitMQ的基础知识，包括其功能、Spring MVC的集成和各个功能点的介绍和使用方法。
MQ 经常被应用于流量削峰、异步消息、应用解耦，常见的 MQ 开源组件有 RabbitMQ、Kafka、ActiveMQ、RocketMQ 等。
SpringAMQP是基于RabbitMQ封装的一套模板，并且还利用SpringBoot对其实现了自动装配，使用起来非常方便。
本文在已掌握rabbit基础用法的基础上书写，安装等操作不再赘述，默认文章使用的是单播模式； 创建工程
RabbitMQ是一种我们经常使用的消息中间件，通过RabbitMQ可以帮助我们实现异步、削峰的目的。
@RabbitListener注解指定目标方法来作为消费消息的方法，通过注解参数指定所监听的队列或者Binding。
Spring AMQP的页面：http://spring.io/projects/spring-amqp
在微服务架构中，服务之间的通信非常重要。在某些情况下，我们需要在服务之间发送和接收消息，以实现更高效、可靠的通信。这时，Spring Cloud Bus 是一个非常有用的工具。
1、https://www.kancloud.cn/yunxifd/rabbitmq/96997
2、在生产者端编写测试类SpringAmqpTest，并利用RabbitTemplate实现消息发送：
SpringBoot整合rabbitMq | 半月无霜 (banmoon.top)
添加依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> 添加配置 spring.rabbitmq.host=192.168.2.71 spring.rabbitmq.port=5672 spring.rabbitmq.username=light spring.rabbitmq.password=l
前言：我们现在有一个用微服务架构模式开发的系统，系统里有一个商品服务和订单服务，且它们都是同步通信的。
我们之前将的是，直接使用java代码操作rabbitmq，相当于就是原生的代码操作rabbitmq，但是之后我们在项目里面，不会使用原生的java代码操作rabbitmq的，所以现在我们要将springboot项目是如何整合rabbitmq的。项目里面是如何使用rabbitmq的。
两种方式各有优劣，打电话可以立即得到响应，但是你却不能跟多个人同时通话。发送邮件可以同时与多个人收发邮件，但是往往响应会有延迟。
上文我们了解了 RabbitMQ 六种队列模式中的简单队列，代码也是非常的简单，比较容易理解。
本次结合着B站某MQ视频以及最近在MQ上的实践聊一聊个人在使用rabbitMQ中所得。
github地址： https://github.com/erlieStar/rabbitmq-examples
创建消息 路由键 pull/push
特殊说明： 解决问题的光鲜，藏着磕Bug的痛苦。 万物皆入轮回，谁也躲不掉！ 以上文章，均是我实际操作，写出来的笔记资料，不会出现全文盗用别人文章！烦请各位，请勿直接盗用！
当消息在一个队列中变成一个死信之后，如果配置了死信队列，它将被重新publish到死信交换机，死信交换机将死信投递到一个队列上，这个队列就是死信队列。
一直没机会做spring生态圈的框架，公司选择的是一些小众的微服务，鉴于此考虑，丰富自己的技术栈，花了两天时间从网上各网站上学习了springboot一些基础知识。 本章只介绍springboot微服务集成RabbitMQ，用于通过消息中间件给其他微服务发送消息。
从这一节开始我们进入rabbitMQ的实战环节，项目环境是spring-boot 加maven。首先让我们创建一个spring-boot项目，然后引入web依赖和 rabbitMQ的依赖
1、Topic交换器(主题，规则匹配)，Topic交换器也称为主题交换器，特点是根据规则进行匹配，可以根据模糊进行匹配（即根据路由key进行模糊匹配），决定将那个信息放入到指定的队列里面去。
我们在微服务中一个命令会逐渐调用各个微服务，但如果一一调用不仅需要微服务实时同步交互还会浪费效率
以 Spring Cloud实战-06使用/actuator/bus-refresh端点手动刷新配置 + 使用Spring Cloud Bus自动更新配置中使用的几个微服务工程为基础，我们梳理下整合RabbitMQ及RabbitMQ的基本用法.
1、Fanout交换器(广播)，以广播的模式进行消息的传递。广播模式一定没有路由键的存在，将消息从路由器发送到所有绑定的队列中去（即消息会发送到所有和指定路由器绑定的队列中去）。
消费消息使用队列监听注解@RabbitListener,添加队列名称就能消费发送到队列上的消息了：
SpringBoot 笔记 (六): 消息 1.基本概念 1.应用场景 2.重要概念 消息代理（broker）：消息队列服务器 目的地：消息消费者 1.消息队列的两种目的地： 队列：点对点的通讯，这种
版权声明：本文为博主原创文章，未经博主允许不得转载。 https://blog.csdn.net/pyycsd/article/details/80969583
消息（Message）是指在应用间传送的数据。消息可以非常简单，比如只包含文本字符串，也可以更复杂，可能包含嵌入对象。
在上一篇随笔中我们认识并安装了RabbitMQ，接下来我们来看下怎么在Spring Boot 应用中整合RabbitMQ。
我们并不推荐RPC式的mq调用，这么做完全没有发挥mq异步削峰的作用。如果有使用RPC的需求，请移步SpringCloud或者Dubbo。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
腾讯会议
实时音视频
