关键词：
消息包含两部分：1、有效载荷(payload) - 你想要传输的数据。2、标签(lable) - 描述有效载荷的相关信息，包含具体的交换器、消息的接受兴趣方等。
rabbitmq的基础流程如下：
RabbitMQ的客户端和服务端通过channel与RabbitMQ服务器进行通信。
Channel(信道)：程序和RabbitMQ之间的连接是通过channel，channel是基于TCP协议之上的，
一个TCP连接可以有多个channel，可以比喻成如下：一根大电缆里面有很多根小的电线，大电缆就是一个TCP连接，
而小电线就是channel了，而为什么要这么设计呢？因为系统创建和销毁TCP连接是很重量级的操作，
基于一个TCP上进行多个不冲突的通信操作可以大大增加效率。
AMQP的消息路由必须包含3个部分：交换器(Exchange)、队列（Queue）、绑定(Bind)。
1、Queue(队列)：用来存放消息的地方，等待消费者来获取。消费者可以通过以下2种方式从queue里接收消息。
⑴、通过AMQP的basic.consume命令订阅。这样会将channel置为接收模式，直到取消对该queue的订阅为止。订阅了消息后，消费者在消费(或者拒绝)最近接收的那条消息后，就能从队列中（有可用的）自动接收下一条信息。此订阅模式生产者把消息发布到queue后就会被消费消费者自动接收到。
⑵、通过AMQP的basic.get命令获取下一条消息。该模式一次只获取一条信息，然后就取消了订阅，如果需要继续获取下一条需要再次发送此命令。注意：不应该在for循环里使用basic.get来替代basic.consume，这样会影响Rabbit的性能。
当多个消费者订阅同一个队列时，rabbit会采取循环的方式发送给消费者，每条消息只发给一个订阅的消费者，消费者收到信息后需要发送basic.ack来确认收到，或者将auto_ack设置为true来自动确认。如果消费者未回复确认信息，rabbit将不会再对此消费者发送消息了。当然你可以使用basic.reject命令来拒绝rabbit发来的消息，拒绝的同时将该消息从队列里删除。
流程如下：
说了这么多，队列该如何创建呢？使用queue.declare命令来创建队列，需要注意的是在同一条Channel(信道)上只能订阅一个队列，如果在Channel上已经订阅了一个队列的情况需要订阅另外一个队列，唯一的处理方法就是取消订阅之前的队列并将Channel置为【传输模式】然后再订阅新的。
该命令主要用到的参数有：
/** * Declare a queue * @param queue 队列的名称,如果为空将生成随机的名称 * @param durable 是否持久化的队列 (服务重启后队列和消息都还在) * @param exclusive 是否是私有(独占)的队列 (限制在此连接) * @param autoDelete 是否当没人使用队列时自动删除 * @param arguments other properties (construction arguments) for the queue * @return a declaration-confirm method to indicate the queue was successfully declared * @throws java.io.IOException if an error is encountered */ Queue.DeclareOk queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete, Map<String, Object> arguments) throws IOException;
Exchange(交换器)与绑定：服务器根据路由键(规则)将消息路由到指定的队列。Exchange与queue通过绑定操作来进行关联。
交换器共有4种类型：direct、fanout、topic和headers。
direct exchange：如果路由键匹配的话，消息会被投递到对应队列。服务器必须实现direct类型的交换器，包含一个空白字符串名称的默认交换器。
如下的代码将使用到默认对应exchange类型的exchange
channel.basicPublish("",ROUTING_KEY, null, msg.getBytes());
代码中使用了默认的direct交换器，路由键为队列的名称。
当默认的direct交换器无法满足需求时可以使用exchange.declare命令设置合适的参数来创建一个direct交换器。
别人对此交换器的解释：
Direct Exchange – 处理路由键。需要将一个队列绑定到交换机上，要求该消息与一个特定的路由键完全匹配。这是一个完整的匹配。
如果一个队列绑定到该交换机上要求路由键 “dog”，则只有被标记为“dog”的消息才被转发，不会转发dog.puppy，也不会转发dog.guard，只会转发dog。
fanout exchange：不处理路由键。你只需要简单的将队列绑定到交换机上。一个发送到交换机的消息都会被转发到与该交换机绑定的所有队列上。很像子网广播，每台子网内的主机都获得了一份复制的消息。Fanout交换机转发消息是最快的。
topic exchange：通过模式匹配分析消息的routing-key(路由键)属性。它将routing-key和binding-key的字符串切分成单词。这些单词之间用点隔开。它同样也会识别两个通配符：#匹配0个或者多个单词，*匹配一个单词。例如，binding key：*.stock.#匹配routing key：usd.stcok和eur.stock.db，但是不匹配stock.nana
注意：如果将消息发送给未绑定/不符合路由规则的Queue，则消息会进入“黑洞”(Rabbit的一个特殊的队列，老版本的就是直接丢失了)里。
RabbitMQ系统自带的几个Exchange：
rabbitmq实战：理解消息通信(代码片段)
本系列是「RabbitMQ实战：高效部署分布式消息队列」书籍的总结笔记。前段时间总结完了「深入浅出MyBatis」系列，对MyBatis有了更全面和深入的了解，在掘金社区也收到了一些博友的喜欢，很高兴。另外，短暂的陪产假就要结束... 查看详情
消息中间件学习笔记——rabbitmq
...性降低系统复杂度提高一致性问题三、常见的MQ产品四、RabbitMQ中的概念五、如何实现RabbitMQ的延迟对列一、消息中间件概述 通过下图我们就可以很好理解消息中间件的概念。二、消息中间件（MQ）的优劣(1).MQ的优势应用... 查看详情
rabbitmq实战：消息通信模式和最佳实践
本系列是「RabbitMQ实战：高效部署分布式消息队列」书籍的总结笔记。通过前2篇的介绍，了解了消息通信的主要元素和交互过程，以及如何运行和管理RabbitMQ，这篇将站在开发模式的角度理解「面向消息通信」带来的好处，以及... 查看详情
学习笔记《rabbitmq实战指南》笔记(代码片段)
本文摘录总结自《RabbitMQ实战指南》。一、消息中间件消息队列中间件（MessageQueueMiddleware，简称为MQ）是指利用高效可靠的消息传递机制进行与平台无关的数据交流，并基于数据通信来进行分布式系统的集成。它... 查看详情
学习笔记《rabbitmq实战指南》笔记(代码片段)
本文摘录总结自《RabbitMQ实战指南》。一、消息中间件消息队列中间件（MessageQueueMiddleware，简称为MQ）是指利用高效可靠的消息传递机制进行与平台无关的数据交流，并基于数据通信来进行分布式系统的集成。它... 查看详情
rabbitmq学习笔记3：rabbitmq快速入门消息模式
一、RabbitMQ快速入门1、什么是RabbitMQ？（是基于AMQP协议的实现者，用Erlang语言写的。支持多种语言，用于在分布式系统中存储消息、转发消息，具有高可用、高可扩、易用性等特性。）2、RabbitMQ的安装、Web... 查看详情
rabbitmq学习笔记(代码片段)
RabbitMq学习笔记1.消息队列1.1MQ相关概念1.1.1什么是MQ？1.1.2为什么要用MQ？1.2.3MQ的分类1.2.4MQ的选择1.2.5为什么选择RabbitMQ？1.2.5MQ对比分析图在这里插入图片描述1.2RabbitMQ1.2.1.RabbitMQ的概念1.2.2.四大核心概念1.2.3RabbitMQ6大模... 查看详情
rabbitmq超详细学习笔记（章节清晰+通俗易懂）(代码片段)
...学习，最近花了一段时间系统学习了当下最为主流的RabbitMQ消息队列，学习过程中也随时记录，刚开始学习的时候懵懵懂懂，做的笔记都比较杂乱，系统学习完后我将笔记内容不断反复修改，对章节进行设... 查看详情
rabbitmq学习笔记5：rabbitmq高级
...都可以被消费者接收获取;过了之后消息将自动被删除。2.RabbitMQ可以对消息和队列设置TTL,目前有两种方法可以设置：第一种方法是通过队列属性设置,队列中所有消息都有相同的过期时间。第二种方法是对消息进行单独设置,... 查看详情
rabbitmq学习笔记五：rabbitmq之优先级消息队列
RabbitMQ优先级队列注意点：1、只有当消费者不足，不能及时进行消费的情况下，优先级队列才会生效2、RabbitMQ3.5以后才支持优先级队列代码在博客：RabbitMQ学习笔记三：Java实现RabbitMQ之与Spring集成 最后面有下载地址，只是做... 查看详情
rabbitmq学习笔记（自用）(代码片段)
...概念1.1什么是MQ1.2为什么要用MQ1.3MQ的分类1.4MQ的选择二、RabbitMQ2.1RabbitMQ的概念2.2四大核心概念三、简单案例3.1WorkQueues3.2轮训分发消息3.3消息应答3.4RabbitMQ持久化3.5不公平分发3.6预取值分发四、RabbitMQ-发布确认4.1发布确认逻辑4.2发... 查看详情
celery学习笔记2
...任务主要由中间数据存储系统完成，比如消息队列服务器RabbitMQ、redis、AmazonSQS 查看详情
rabbitmq学习笔记(代码片段)
文章目录1.RabbitMq(消息中间件)1.概念：是基于队列模式实现的异步/同步的传输数据。2.传统的Http请求存在哪些缺点？3.mq的使用场景？4.mq服务器如何保证消息不丢失？5.VirtualHost?Exchange分派我们的消息存放在哪个队... 查看详情
rabbitmq学习笔记(代码片段)
文章目录RabbitMq(消息中间件)1.概念：是基于队列模式实现的异步/同步的传输数据。2.传统的Http请求存在哪些缺点？3.mq的使用场景？4.mq服务器如何保证消息不丢失？5.VirtualHost?Exchange分派我们的消息存放在哪个队列... 查看详情
rabbitmq:理解消息通信rabbitmq(代码片段)
原文:RabbitMQ(二):理解消息通信RabbitMQ一、消费者、生产者和信道 生产者(producer)：生产者创建消息，然后发布(发送)到代理服务器(RabbitMQ)，可以说发送消息的程序就是生产者。什么是消息？消息包含两部分：有效载荷和标签。... 查看详情
rabbitmq-理解消息通信-虚拟主机和隔离
每个RabbitMQ服务器都能创建虚拟的消息服务器，我们称之为虚拟主机(vhost)每一个vhost本质上是一个mini版的RabbitMQ服务器，拥有自己的队列、交换器和绑定等等更重要的是，他拥有自己的权限机制，这使得你能够安全地使用一个Rabb... 查看详情
rabbitmq系列-基本概念理解
1.简介RabbitMQ是一个由erlang开发的AMQP（AdvancedMessageQueueprotocol）的开源实现。AMQP高级消息队列，说白了就是一个开源的消息中间件。它能解决不同组件、模块、系统间消息通信。2.系统架构RabbitMQServer：也叫brokerserver，存储消息的... 查看详情
rabbitmq学习笔记(代码片段)
视频教程【编程不良人】MQ消息中间件之RabbitMQ以及整合SpringBoot2.x实战教程1.MQ引言1.1什么是MQMQ(MessageQuene)：消息队列，也叫消息中间件。通过典型的生产者和消费者模型，生产者不断向消息队列中生产消息，消费... 查看详情