RabbitMQ 简介：RabbitMQ 基于 AMQP 标准，采用 Erlang 语言开发的消息中间件。
你已经是一个长大的IDEA了, 要学会自己新建工程, 然后IDEA自己创建了rabbitmq-consumer和rabbitmq-producer工程
1.安装 RabbitMQ部署指南 1.单机部署 我们在Centos7虚拟机中使用Docker来安装。 1.1.下载镜像 方式一：在线拉取 docker pull rabbitmq:3-management 方式二：从本地加载 在课前资料已经提供了镜像包： image-20210423191210349 上传到虚拟机中后，使用命令加载镜像即可： docker load -i mq.tar 1.2.安装MQ 执行下面的命令来运行MQ容器： docker run \ -e RABBITMQ_DE
RabbitMQ：第二章：Spring整合RabbitMQ（简单模式，广播模式，路由模式，通配符模式，消息可靠性投递，防止消息丢失，TTL，死信队列，延迟队列，消息积压，消息幂等性）
2、cms 页面发布接口执行页面静态化，并将静态化页面(html文件)存储至GridFS中。
而且只关心消息的发送和接收，没有业务逻辑的侵入，这样就实现了生产者和消费者的解耦。
这篇是SpringBoot整合消息队列的第一篇文章，我们详细介绍下消息队列的相关内容。
MQ(Message Quene)：通过典型的生产者和消费者模型，生产者不断向消息队列中产生消息，消费者不断的从队列中获取消息。因为生产者和消费者都是异步的，而且生产者只关心消息的发送，消费者只关心消息的接收，没有业务逻辑的侵入，轻松实现业务解耦。
系统设计开发起步的时候功能通常都是用同步的方式实现的，随着系统的迭代对稳定性和性能的要求会逐步变高，这种时候通常会使用同步转异步的方式来改进和优化。
在微服务的使用中，我们不可避免需要服务之间的相互调用，但传统模式下，我们使用如OpenFeign的调用方式，需要等待被调用方直接业务并返回结果后，才能进行后续任务，此时，调用者会处于阻塞状态。
当然前提是远程主机将RabbitMQ都配置好了。本人用docker容器配置的 具体看之前的文章里面有一段简洁的介绍 RabbitMQ初识以及简单模式初步 端口一定要开放，阿里云的防火墙面板也要开放这个端口。
官网：https://www.rabbitmq.com/tutorials/tutorial-one-java.html
MQ（Message Queue）消息队列，是基础数据结构中“先进先出(FIFO)”的一种数据结构。一般用来解决应用解耦，异步消息，流量削峰等问题，实现高性能，高可用，可伸缩和最终一致性架构。 从字面意思上看，本质是个队列，只不过队列中存放的内容是message而已
我们启动生产者，然后请求send接口，然后打开rabbitmq控制台发现多了一个名为”byte-zb“的交换机和队列，并且队列中出现了一个未消费的消息，然后启动消费者，我们会在控制台上发现打印了一条消息，同时rabbitmq控制台中”byte-zb“的队列中消息没有了。
4.创建Rabbit配置类RabbitConfig，配置类主要用来配置队列、交换器、路由等高级信息
—1— 背景 利用RabbitMQ集群横向扩展能力，均衡流量压力，让消息集群的秒级服务能力达到百万，Google曾做过此类实验；有货在某些推送场景下也做了类似尝试，在此对此前实践经验以及踩得坑做些总结工作。 RabbitMQ概述 RabbitMQ是基于AMQP协议实现的消息中间件的一种，常用于在分布式系统中存储转发消息，表现为易用、可扩展、高可用等特点，最初活跃在金融系统中。消息中间件的主要作用是让服务组件之间能够解耦，消息生产者无需关注消息消费者的存在与行为。 1.Message:由Producer发出
利用RabbitMQ集群横向扩展能力，均衡流量压力，让消息集群的秒级服务能力达到百万，Google曾做过此类实验；有货在某些推送场景下也做了类似尝试，在此对此前实践经验以及踩得坑做些总结工作。
有了消息队列,每一次连接不管是生成消息还是消费消息,都有各自的逻辑与其他逻辑无关--通信解耦
考虑由订单系统与库存系统、支付系统、物流系统直接通过远程调用方式通信，模块耦合度较高的情况。
Java 是第一大编程语言和开发平台。它有助于企业降低成本、缩短开发周期、推动创新以及改善应用服务。如今全球有数百万开发人员运行着超过 51 亿个 Java 虚拟机，Java 仍是企业和开发人员的首选开发平台
RabbitMQ概述：RabbitMQ是使用最广泛的开源消息代理。RabbitMQ轻量级，易于在集群内部和云平台中部署。它支持多种消息传递协议。 它可以满足企业高规模，高可用性的要求。RabbitMQ使用Erlang语言开发的。 MQ概述：全称为Message Queue, 消息队列（MQ）是一种应用程序对应用程序的通信方法。应用程序通过读写队列的消息（针对应用程序的数据）来通信，而无需专用连接来链接它们。 MQ运行机制： P表示生产者，C表示消费者，红色部分为消息队列
面试技巧另外开篇再说，先上面试干货吧。面试的题目并不一定有严格的顺序关系，有的是从前一个问题延伸而来，（探究的是一个知识的深度），有的是考察面试者的知识广度、有的纯粹是我想到哪里写到哪里的啦。。不要太在意哈，最近工作有点忙。
SpringAMQP是基于RabbitMQ封装的一套模板，并且还利用SpringBoot对其实现了自动装配，使用起来非常方便。
本文给大家介绍一下在 Spring Boot 项目中如何集成消息队列 RabbitMQ，包含对 RibbitMQ 的架构介绍、应用场景、坑点解析以及代码实战。
1、跨系统的异步通信 人民银行二代支付系统，使用重量级消息队列 IBM MQ，异步，解耦，削峰都有体现。 2、应用内的同步变成异步 秒杀：自己发送给自己 3、基于Pub/Sub模型实现的事件驱动 放款失败通知、提货通知、购买碎屏保 系统间同步数据 摒弃ELT（比如全量同步商户数据）； 摒弃API（比如定时增量获取用户、获取产品，变成增量广播）。 4、利用RabbitMQ实现事务的最终一致性
两种方式各有优劣，打电话可以立即得到响应，但是你却不能跟多个人同时通话。发送邮件可以同时与多个人收发邮件，但是往往响应会有延迟。
RabbitMQ由Erlang语言开发，Erlang语言用于并发及分布式系统的开发，在电信领域应用广泛，OTP（Open Telecom Platform）作为Erlang语言的一部分，包含了很多基于Erlang开发的中间件及工具库，安装RabbitMQ需 要安装Erlang/OTP，并保持版本匹配，如下图：
先启动consumer1，2；再启动producer，即可看到两个消费者会争抢消费生产者生产的消息。
开源的消息代理和队列服务器，通过普通协议在完全不同的应用间共享数据，使用Erlang语言编写，并且基于AMQP协议。
本文 SpringBoot 与 RabbitMQ 进行整合的时候，包含了三种消息的确认模式，如果查询详细的确认模式设置，请阅读：RabbitMQ的三种消息确认模式 同时消费端也采取了限流的措施，如果对限流细节有兴趣请参照之前的文章阅读：消费端限流
距离上一次发文章已经很久了，其实这段时间一直也没有停笔，只不过在忙着找工作还有学校结课的事情，重新弄了一下博客，后面也会陆陆续续会把文章最近更新出来~
RabbitMQ是一个消息中间件:它接受并转发消息。你可以把它当做一个快递站点，当你要发送一个包裹时，你把你的包裹放到快递站，快递员最终会把你的快递送到收件人那里，按照这种逻辑RabbitMQ是一个快递站，一个快递员帮你传递快件。RabbitMQ与快递站的主要区别在于，它不处理快件而是接收，存储和转发消息数据。
AMQP，即Advanced Message Queuing Protocol（高级消息队列协议），一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计，基于此协议的客户端与消息中间件传递消息，不受客户端/中间件不同产品、不同开发语言等条件的限制。该协议是一种二进制协议，提供客户端应用于消息中间件之间异步、安全、高效的交互。相对于我们常见的REST API，AMQP更容易实现，可以降低开销，同时灵活性高，可以轻松的添加负载平衡和高可用性的功能，并保证消息传递，在性能上AMQP协议也相对更好一些。
Broker：接收和分发消息的应用，RabbitMQ Server 就是 Message Broker
消息队列，用来保存消息，直到发送给消费者，是消息的容器，也是消息的终点。一个消息可投入一个或多个队列。消息一致在队列里面，等待消费者连接到这个队列将其取走。
1）、ActiveMQ是Apache出品，最流行的，能力强劲的开源消息总线，并且它一个完全支持jms（java message service）规范的消息中间件。其丰富的api，多种集群构建模式使得他成为业界老牌消息中间件，在中小企业中应用广泛。 如果不是高并发的系统，对于ActiveMQ，是一个不错的选择的，丰富的api，让你开发的很愉快哟。 注意：MQ衡量指标：服务性能，数据存储，集群架构。
本篇文章主要用于记录个人学习RabbitMQ的过程，记录下来方便日后查看，如有错误的地方，还望指正。
消息队列这种技术主要用在分布式设计当中，其实可以说是一种设计模式。是相对同步系统而言的。同步系统是什么呢？
之前已经简单介绍了基本是从发送方去确认的，我们需要在配置文件当中开启发送方确认模式，共育两种，一种是相对于交换机一个是相对于队列。
消息队列这种技术主要用在分布式设计当中，其实可以说是一种设计模式。是相对同步系统而言的。同步系统是什么呢？ 同步，是当所有的操作都完毕，才会返回结果，比如用户支付，如果是同步的话就是当用户所发起的支付操作，然后只有等支付的这个业务成功然后才给用户返回结果说支付成功，但是分布式的异步就不一样了， 异步的话它并不是等一套操作全部完成才会返回结果。用户发起支付操作，那么这个操作会立马返回给用户您已经支付成功，然后后面具体的支付扣款以及转账数据等等的操作是自己独立完成的。用户发起支付后，我们只要把这个支付的消息告诉后面的操作，说用户支付了，后面的操作逻辑我就不管了，我现在立马给用户返回信息，让用户及时得到反馈。这就是异步。
消息（Message）是指在应用间传送的数据。消息可以非常简单，比如只包含文本字符串，也可以更复杂，可能包含嵌入对象。
之前我们使用原生JAVA操作RabbitMQ较为繁琐，接下来我们使用SpringBoot整合RabbitMQ，简化代码编写。
通过网络发送数据包或者给一个服务发送网络请求都是透明的操作，不会留下任何永久痕迹。尽管，我们可以将其永久地记下来（通过抓包工具或者日志工具），但通常不会这么做。即使消息代理会暂时地将消息写到外存中，但在其被消费后也通常会删除，这一切是因为，我们认为消息是一种暂态数据。
生产者发送6条消息, messageData分别为1, 2, 3, 4, 5, 6
路由的这种模式和发布订阅的模式相比多了一个路由的环节。要求队列在绑定在绑定到交换机的时候指定到对应的路由。路由的作用是什么呢？作为一种分发的规则。可以按照相应的条件指定和分发。
消息队列一般简称为 MQ （Messges Queue），是指利用高效可靠的消息传递机制进行与平台无关的数据交流，并基于数据通信来进行分布式系统的集成，是在消息的传输过程中保存消息的容器。消息队列本质上是一个队列，而队列中存放的是一个个消息。
下载地址：http://www.rabbitmq.com/download.html
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
