MQ：MessageQueue，消息队列。 队列，是一种FIFO 先进先出的数据结构。消息由生产者发送到MQ 进行排队，然后按原来的顺序交由消息的消费者进行处理。QQ和微信就是典型的MQ。MQ的作用主要有以下三个方面： 异步 例子：快递员发快递，直接到客户家效率会很低。引入菜鸟驿站后，快递员只需要把快递放到菜鸟 驿站，就可以继续发其他快递去了。客户再按自己的时间安排去菜鸟驿站取快递。 作用：异步能提高系统的响应速度、吞吐量。解耦 例子：《Thinking in JAVA》很经典，但是都是英文，我

LD is tigger forever，CG are not brothers forever， throw the pot and shine forever. Modesty is not false, solid is not naive, treacherous but not deceitful, stay with good people, and stay away from poor people. talk is cheap, show others the c

channel  有了TCP连接后,还需要channel的原因如下: 创建和销毁TCP连接很耗时; 打开太多TCP连接,耗操作系统资源，并发量大到一定程度,系统的吞吐量会降低； 使用一个connection多channel的方式,可以提升连接的利用率。 因此采用多个channel多路复用一个TCP连接的方式才比较合理 exchange（交换机） 生产者发消息发往交换机，交换机会自己投递消息到绑定的queue队列 1.exchange根据什么规则把消息投递到哪些queue中？ excha

前言 前几天在做日志收集，用到了RabbitMQ，它作为一种中间件，需要对其进行下载，安装，和配置。 消息队列 什么是消息队列？，我们这样想一下，用户访问网站，最终是要将数据以HTTP的协议的方式，通过网络传输到主机的某个端口上的。 那么，接收数据的方式是什么呢？自然是端口监听啦。 那消息队列是什么就很好解释了 它就是端口监听，接到数据后，将数据排列起来。 RabbitMQ是一个非常流行的，开源的，使用Erlang语言编写的框架，通常在电信级平台中作为消息中间件使

信息手动应答 在建立的生产者消费者案例中。 消费端 public static void main(String[] args) throws Exception{ Channel Channel = getConn.getchannel(); /** * * meeage表示接收的消息 */ DeliverCallback DeliverCallback=(consumer,m

个人简介 作者是一个来自河源的大三在校生，以下笔记都是作者自学之路的一些浅薄经验，如有错误请指正，将来会不断的完善笔记，帮助更多的Java爱好者入门。 什么是RabbitMQ MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息(针对应用程序的数据)来通信，而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通信，直接调用通常是用于诸如远程过程调用的技术。排队

1.MQ的组件： 生产者：消息提供者 消费者：消息使用者 MQ服务器：管理队列、消息及相关信息 消息：程序间通讯的数据 队列：消息存放的容器，消息是先进先出的 交换机：用于分发消息 2.RabbitMQ工作模式 2.1 简单模式 无交换机参与。实际工作中几乎用不到。生产者通过MQ将消息放入队列，队列发送给消费者。 2.2 工作队列 类似负载均衡。在多个消息的情况下，工作队列模式会将消息分发给不同的消费者，每个消费者会收到不同的消息， 并且根据处理消息的速度来接收消息

docker启动rabbitmq命令 docker run -d -p 15672:15672 -p 5672:5672 -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin –name rabbitmq –hostname=rabbitmqhostone rabbitmq:management 进入rabbitmq命令 docker exec -it rabbitmq bash 安装可视化管理界面 rabbitmq-pl

RabbitMQ 使用场景 服务解耦 常规的微服务调用： RabbitMQ解耦的情况: 流量削峰 高峰情况下,瞬间出现的大量请求数据,先发送到消息队列服务器,排队等待被处理,而我们的应用,可以慢慢的从消息队列接收请求数据进行处理,这样把数据处理时间拉长,以减轻瞬时压力 异步调用 请求放入RabbitMQ中后，不管后续。直接继续跑 RabbitMQ对接下游服务，慢慢消化。实现异步 基本概念 RabbitMQ是一种消息中间件，用于处理来自客户端的异步消息。服务端将要

RabbitMQ目录 死信队列 1、死信的概念 先从概念解释上搞清楚这个定义，死信，顾名思义就是无法被消费的消息，字面意思可以这样理解，一般来说，producer 将消息投递到 broker 或者直接到queue 里了，consumer 从 queue 取出消息进行消费，但某些时候由于特定的原因导致 queue 中的某些消息无法被消费，这样的消息如果没有后续的处理，就变成了死信，有死信自然就有了死信队列。 应用场景：为了保证订单业务的消息数据不丢失，需要使用到 Rabbi

前言 之前专栏中，对Springboot整合Rabbitmq都有一系列的配置和说明，但总缺少一些必要的描述信息。导致很多看博客的小伙伴会私信问为什么需要这么配置的问题。 本篇博客重点进行Confirm 机制和Return 机制的实现和说明。 为什么会有Confirm RabbitMq中，针对数据由消息生产者向消息队列推送时，通常情况如下所示(以 Routing 方式为例)： 每个Virtual Host 虚拟机中，都会含有各自的Exchange和Queue，需要在rabbit

目录 一、MQ的基本概念 1.1MQ概述 1.2MQ的优缺点 1.3MQ的劣势 1.4常见的MQ产品 1.5RabbitMQ简介 1.6JMS 二、RabbitMQ安装和配置 2.1准备安装包 2.2安装依赖环境 2.3安装Erlang 2.4安装RabbitMQ 2.5开启管理界面及配置 2.6RabbitMQ管理控制台使用 三、RabbitMQ快速入门 四、RabbitMQ工作模式 4.1Hello World 4.2Work queues 4.3Pub