RabbitMQ初步认知

ゝ一世哀愁。 2022-02-01 14:53 362阅读 0赞

**目录**

是什么？

互联网大厂为什么选择RabbitMQ?

RabbitMQ的高性能之道是如何做到的？

什么是AMQP高级协议？

AMQP核心概念是什么？

RabbitMQ整体架构模型是什么样子的？

RabbitMQ消息是如何流转的？

RabbitMQ安装与使用

命令行与管控台

RabbitMQ消息生产与消费

RabbitMQ交换机详解

Direct Exchange

Topic Exchange:

Fanout Exchange

使用交换器和队列

RabbitMQ队列、绑定、虚拟主机、消息

--------------------

# 是什么？ #

RabbitMQ是使用Erlang语言开发的开源消息队列系统，基于AMQP协议来实现。AMQP的主要特征是面向消息、队列、路由（包括点对点和发布/订阅）、可靠性、安全。AMQP协议更多应用在企业系统内，对数据一致性、稳定性和可靠性要求很高的场景，对性能和吞吐量的要求还在其次。

# 互联网大厂为什么选择RabbitMQ? #

滴滴 美团 头条 去哪儿 艺龙

开源、性能优秀，稳定性保障

提供可靠性消息投递模式（confirm）、返回模式（return ）

与SpringAMQP完美的整合、API丰富

集群模式丰富，表达式配置，HA模式，镜像队列模型

保证数据不丢失的前提做到高可靠性、可用性

# RabbitMQ的高性能之道是如何做到的？ #

Erlang语言最初在于交换机领域的架构模式，这样使得RabbitMQ在Broker之间进行数据交互的性能是非常优秀的

Erlang的优点：Erlang有着和原生Socket一样的延迟 RPC框架-Dubbo-Netty（网络编程中高性能之王，也是Socket）

# 什么是AMQP高级协议？ #

AMQP全称：Advanced Message Queuing Protocol 高级消息队列协议

AMQP定义：是具有现代特征的二进制协议。是一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。（规范）

# AMQP核心概念是什么？ #

*  Server:又称Broker，接受客户端的连接，实现AMQP实体服务
 *  Connection：连接，应用程序与Broker的网络连接
 *  Channel:网络信道，几乎所有的操作都在Channel中进行，Channel是进行消息读写的通道。客户端可建立多个Channel，每个Channel代表一个会话任务。
 *  Message:消息，服务器和应用程序之间传送的数据，由Properties和Body组成。Properties可以对消息进行修饰，比如消息的优先级、延迟等高级特性；Body则就是消息体内容。
 *  Virtual host:虚拟地址，用于进行逻辑隔离，最上层的消息路由。一个Virtual Host里面可以有若干个Exchange和 Queue,同一个Virtual Host里面不能有相同名称的Exchange或Queue
 *  Exchange:交换机，接收消息，根据路由键转发消息到绑定的队列
 *  Binding:Exchange和 Queue之间的虚拟连接，binding中可以包含routing key
 *  Routing key：一个路由规则，虚拟机可用它来确定如何路由一个特定消息
 *  Queue:也称为Message Queue，消息队列，保存消息并将它们转发给消费者

# RabbitMQ整体架构模型是什么样子的？ #

![1556674378323-d084c0a1-dc0b-46e5-8440-c7f67002e68d.png][]

# RabbitMQ消息是如何流转的？ #

![image.png][]

# RabbitMQ安装与使用 #

官网地址：[https://www.rabbitmq.com/][https_www.rabbitmq.com]

初学者建议使用rpm方式安装

1.rpm -ivh erlang-18.3-1.el7.centos.x86\_64.rpm

2.rpm -ivh socat-1.7.3.2-1.1.el7.x86\_64.rpm

提示缺少tcp\_wrappers安装即可

3.rpm -ivh rabbitmq-server-3.6.5-1.noarch.rpm

4.启动rabbitmq

[https://blog.csdn.net/liu911025/article/details/84927880][https_blog.csdn.net_liu911025_article_details_84927880]

5.启动控制台

rabbitmq默认安装路径 usr/lib/rabbitmq/lib/rabbitmq\_server-3.6.5/plugins

6.查看监控插件启动

rabbitmq-plugins enable rabbitmq\_management

7.输入ip+:15672即可

# 命令行与管控台 #

用户：

rabbitmqctl add\_user username password：添加用户

rabbitmqctl list\_users： 列出所有用户

rabbitmqctl delete\_user username： 删除用户

rabbitmqctl clear\_permissions -p vhostpath username: 清除用户权限

rabbitmqctl list\_user\_permissions username： 列出用户权限

rabbitmqctl change\_password username newpassword ：修改密码

rabbitmqctl set\_permissions -p vhostpath username ".\* ".\*" ".\*"：设置用户权限

虚拟主机：

rabbitmqctl add\_vhost vhostpath ：创建虚拟主机

rabbitmqctl list\_vhosts：列出所有虚拟主机

rabbitmqctl list\_permissions -p vhostpath： 列出虚拟主机上所有权限

rabbitmqctl delete\_vhost vhostpath：删除虚拟主机

rabbitmqctl list\_queues：查看所有队列信息

rabbitmqctl -p vhostpath purge\_queue blue：清除队列里的消息

节点迁移的时候：导出然后导入这样信息不容易丢失。（目前公司的大厂都是这么做的）

overview最下面

![image.png][image.png 1]

# RabbitMQ消息生产与消费 #

ConnectionFactory: 获取连接工厂

Connection:一个连接

Channel:数据通信信道，可发送和接收消息

Queue：具体的消息存储队列

Producer & Consumer 生产和消费者

producer:

public class Procuder {
    
    	
    	public static void main(String[] args) throws Exception {
    		//1 创建一个ConnectionFactory, 并进行配置
    		ConnectionFactory connectionFactory = new ConnectionFactory();
    		connectionFactory.setHost("192.168.11.76");
    		connectionFactory.setPort(5672);
    		connectionFactory.setVirtualHost("/");
    		
    		//2 通过连接工厂创建连接
    		Connection connection = connectionFactory.newConnection();
    		
    		//3 通过connection创建一个Channel
    		Channel channel = connection.createChannel();
    		
    		//4 通过Channel发送数据
    		for(int i=0; i < 5; i++){
    			String msg = "Hello RabbitMQ!";
    			//1 exchange   2 routingKey
    			channel.basicPublish("", "test001", null, msg.getBytes());
    		}
    
    		//5 记得要关闭相关的连接
    		channel.close();
    		connection.close();
    	}
    }

下面是将body消息设置成具体的值

![image.png][image.png 2]

Consumer:

public class Consumer {
    
    	public static void main(String[] args) throws Exception {
    		
    		//1 创建一个ConnectionFactory, 并进行配置
    		ConnectionFactory connectionFactory = new ConnectionFactory();
    		connectionFactory.setHost("192.168.11.76");
    		connectionFactory.setPort(5672);
    		connectionFactory.setVirtualHost("/");
    		
    		//2 通过连接工厂创建连接
    		Connection connection = connectionFactory.newConnection();
    		
    		//3 通过connection创建一个Channel
    		Channel channel = connection.createChannel();
    		
    		//4 声明（创建）一个队列
    		String queueName = "test001";
    		channel.queueDeclare(queueName, true, false, false, null);
    		
    		//5 创建消费者
    		QueueingConsumer queueingConsumer = new QueueingConsumer(channel);
    		
    		//6 设置Channel
    		channel.basicConsume(queueName, true, queueingConsumer);
    		
    		while(true){
    			//7 获取消息
    			Delivery delivery = queueingConsumer.nextDelivery();
    			String msg = new String(delivery.getBody());
    			System.err.println("消费端: " + msg);
    			//Envelope envelope = delivery.getEnvelope();
    		}
    		
    	}
    }

先启动消费端，再启动生产端？consumer创建队列，先有队列，生产者才能发送到指定的队列上

rabbitmq发送的时候指定exchange（交换机）routing key

如果exchange为空则采用默认的exchange 路由规则是按照路由key和具体的mq上有没有跟路由key相同名字的队列queuename routingkey=queuename

# RabbitMQ交换机详解 #

Exchange：接收消息，并根据路由键转发消息到所绑定的队列

![image.png][image.png 3]

Name: 交换机名称

Type： 交换机类型 direct、topic、fanout、headers

Direct Exchange:

所有发送到Direct Exchange的消息被转发到RouteKey中指定的Queue

routing key 要和queues里面的key一致

## Direct Exchange ##

![image.png][image.png 4]

producer

![image.png][image.png 5]

Consumer:

![image.png][image.png 6]

![image.png][image.png 7]

## Topic Exchange: ##

所有发送到Topic Exchange的消息被转发到所有关心RouteKey中指定Topic的Queue上

Exchange将RouteKey和某个Topc进行模糊匹配，此时队列需要绑定一个Topic

注意，可以使用通配符进行模糊匹配

符号 “\#”匹配一个或多个词

符号“\*”匹配不多不少一个词，只能匹配到有一个词的

例：user.save

user.update

user.delete.abc

此时，只能匹配到user.save 和user.update，匹配不到user.delete.abc，因为此时这是有两个词的。

例如：“log.\#”能够匹配到“log.info.oa”

“log.\*”之会匹配到“log.erro”

这就是为什么数据库在进行模糊匹配的时候用“\#”号了

![image.png][image.png 8]

consumer ：routingkey user.\#

![image.png][image.png 9]

producer :routingkey

发送消息每个消息对应不同的routingKey

![image.png][image.png 10]

## Fanout Exchange ##

不处理路由键，只需要简单的将队列绑定到交换机上

发送到交换机的消息会被转发到与该交换机绑定的所有队列上

Fanout交换机转发消息是最快的

![image.png][image.png 11]

consumer:

![image.png][image.png 12]

producer:

![image.png][image.png 13]

Fanout Exchange性能最快

Durability：是否需要持久化，true为持久化

Auto Delete：当最后一个绑定到Exchange上的队列删除后，自动删除Exchange

Internal：当前Exchange是否用于RabbitMQ内部使用，默认为False

Arguments：扩展参数，用于扩展AMQP协议自制定化使用

### 使用交换器和队列 ###

使用交换器

![image.png][image.png 14]

使用队列

![image.png][image.png 15]

队列和交换器绑定

![image.png][image.png 16]

### RabbitMQ队列、绑定、虚拟主机、消息 ###

虚拟地址，用于进行逻辑隔离，最上层的消息路由

一个Virtual Host里面可以有若干个Exchange和Queue

同一个Virtual Host里面不能有相同名称的Exchange或Queue

消息定时清除

[1556674378323-d084c0a1-dc0b-46e5-8440-c7f67002e68d.png]: /images/20220201/204883b1695848a8af9673a13f8df1ec.png
[image.png]: /images/20220201/0fc139387ede49268f7c7d444233a00f.png
[https_www.rabbitmq.com]: https://www.rabbitmq.com/
[https_blog.csdn.net_liu911025_article_details_84927880]: https://blog.csdn.net/liu911025/article/details/84927880
[image.png 1]: /images/20220201/1ef7d7c0a6a44059954b14467d706f91.png
[image.png 2]: /images/20220201/01bbf666eea2480c89195859cf97791d.png
[image.png 3]: /images/20220201/c9f05df59e184295937df0255fb9aa30.png
[image.png 4]: /images/20220201/9ef7ef4a1f3a42b9a96cd392e9b1199c.png
[image.png 5]: /images/20220201/fec5174643a54a5ca14205a500635666.png
[image.png 6]: /images/20220201/43631a77d8354d9492240fdb56025099.png
[image.png 7]: /images/20220201/001568d389764e87ac408426668066f6.png
[image.png 8]: /images/20220201/429e4d5a95ab49cd875c2443245a9676.png
[image.png 9]: /images/20220201/6702ad20920d48edbc132dbbd25c608f.png
[image.png 10]: /images/20220201/a231d501a58d4aee873d5e70b94add42.png
[image.png 11]: /images/20220201/e1f5f40aad1b47289caba07f1554ef17.png
[image.png 12]: /images/20220201/dcc7a749ae244967b7ff005941b17399.png
[image.png 13]: /images/20220201/dfe454f21f424c7a854e1d1b2aed1397.png
[image.png 14]: /images/20220201/993215b0bbfe4f7d976c4cfb1f0f3d4e.png
[image.png 15]: /images/20220201/d0896c6c9563455f8463005221b434cc.png
[image.png 16]: /images/20220201/07b4e2b6f01b4d09b8ff44971b7dde7f.png