RabbitMQ入门与消息队列模式详解

系统管理员 2020-11-01 09:43 880阅读 0赞

# 1.RabbitMQ概述 #

**简介**

*   MQ全称为Message Queue，消息队列是应用程序和应用程序之间的通信方法；
 *   RabbitMQ是开源的，实现了AMQP协议的，采用Erlang(面向并发编程语言)编写的，可复用的企业级消息系统；
 *   AMQP（高级消息队列协议）是一个异步消息传递所使用应用层协议规范，为面向消息中间件设计，基于此协议的客户端与消息中间件可以无视消息来源传递消息，不受客户端、消息中间件、不同的开发语言环境等条件的限制；
 *  支持主流操作系统：Linux、Windows，MacOX等；
 *  支持多种客户端开发语言：Java、Python、Ruby、.NET，PHP、C/C++、Node.js等

**术语**

*    Server(Broker):接收客户端连接，实现AMQP协议的消息队列和路由功能的进程；
 *    Virtual Host：虚拟主机的概念，类似权限控制组，一个Virtual Host里可以有多个Exchange和Queue,权限控制的最小丽都是Virtual Host；
 *    Exchange:交换机，接收生产者发送的消息，并根据Routing Key将消息路由到服务器中的队列Queue。
 *   ExchangeType:交换机类型决定了路由消息行为，RabbitMQ中有三种类型Exchange，分别是fanout、direct、topic；
 *   Message Queue：消息队列，用于存储还未被消费者消费的消息；
 *   Message：由Header和body组成，Header是由生产者添加的各种属性的集合，包括Message是否被持久化、优先级是多少、由哪个Message Queue接收等；body是真正需要发送的数据内容；
 *  BindingKey：绑定关键字，将一个特定的Exchange和一个特定的Queue绑定起来。

# 2.RabbitMQ安装启动与管理 #

## 2.1 Windows64环境下安装RabbitMQ ##

到RabbitMQ官网下载win64位最新版erlang和rabbitmq-server的安装包，分别是 erlangotp\_win64\_19.3和rabbitmq-server-3.6.9。注意安装时计算机全名最好是英文，先安装erlang，再安装rabbitmq-server，根据安装向导，采用默认安装配置即可。安装完成后，可以从开始-所有程序中找到RabbitMQ Server如下图所示：

![Center][]

点RabbitMQ Command Prompt启动命令行，输入rabbitmq-plugins enablerabbitmq\_management

![Center 1][]

启动管理工具，在浏览器中输入[http://127.0.0.1:15672/][http_127.0.0.1_15672]即可打开管理登录界面，默认超级管理员用户名guest,密码guest

![Center 2][]

## 2.2 Linux下安装RabbitMQ ##

**先安装Erlang**

wget [http://packages.erlang-solutions.com/erlang-solutions-1.0-1.noarch.rpm][http_packages.erlang-solutions.com_erlang-solutions-1.0-1.noarch.rpm]

rpm -Uvherlang-solutions-1.0-1.noarch.rpm

rpm --import [http://packages.erlang-solutions.com/rpm/erlang\_solutions.asc][http_packages.erlang-solutions.com_rpm_erlang_solutions.asc]

sudo yuminstall erlang

**再安装RabbitMQ**

rpm --importhttps://www.rabbitmq.com/rabbitmq-release-signing-key.asc

yum installrabbitmq-server-3.6.9-1.noarch.rpm

**操作命令：**

启动 service rabbitmq-server start

停止 service rabbitmq-server stop

重启 service rabbitmq-server restart

设置开机启动 chkconfig rabbitmq-server on

**开启web界面管理工具**

rabbitmq-pluginsenable rabbitmq\_management

service rabbitmq-serverrestart

**防火墙开放15672端口访问**

/sbin/iptables-I INPUT -p tcp --dport 15672 -j ACCEPT

/etc/rc.d/init.d/iptablessave

## 2.3 RabbitMQ添加用户和Virtual Host ##

Admin-Users-Add a user

![Center 3][]

Tags:用户角色说明

超级管理员(administrator)

可登陆管理控制台，可查看所有的信息，并且可以对用户，策略(policy)进行操作。

监控者(monitoring)

可登陆管理控制台，同时可以查看rabbitmq节点的相关信息(进程数，内存使用情况，磁盘使用情况等)

策略制定者(policymaker)

可登陆管理控制台, 同时可以对policy进行管理,但无法查看节点的相关信息。

普通管理者(management)

仅可登陆管理控制台，无法看到节点信息，也无法对策略进行管理。

其他none

无法登陆管理控制台，通常就是普通的生产者和消费者。

Admin-Virtual Host-Add virtual host

![Center 4][]

添加virtual host和用户后，需要为用户指定virtual host，之后用该用户可以登录

![Center 5][]

# 3.RabbitMQ的5种模式与实例 #

## 3.1 简单模式Hello World ##

![Center 6][]

功能：一个生产者P发送消息到队列Q,一个消费者C接收

**生产者实现思路：**

创建连接工厂ConnectionFactory，设置服务地址127.0.0.1，端口号5672，设置用户名、密码、virtual host，从连接工厂中获取连接connection，使用连接创建通道channel，使用通道channel创建队列queue，使用通道channel向队列中发送消息，关闭通道和连接。

![Center 7][]

**消费者实现思路**

创建连接工厂ConnectionFactory，设置服务地址127.0.0.1，端口号5672，设置用户名、密码、virtual host，从连接工厂中获取连接connection，使用连接创建通道channel，使用通道channel创建队列queue, 创建消费者并监听队列，从队列中读取消息。

![Center 8][]

## 3.2 工作队列模式Work Queue ##

![Center 9][]

**功能：**一个生产者，多个消费者，每个消费者获取到的消息唯一，多个消费者只有一个队列

**任务队列：**避免立即做一个资源密集型任务，必须等待它完成，而是把这个任务安排到稍后再做。我们将任务封装为消息并将其发送给队列。后台运行的工作进程将弹出任务并最终执行作业。当有多个worker同时运行时，任务将在它们之间共享。

**生产者实现思路：**

创建连接工厂ConnectionFactory，设置服务地址127.0.0.1，端口号5672，设置用户名、密码、virtual host，从连接工厂中获取连接connection，使用连接创建通道channel，使用通道channel创建队列queue，使用通道channel向队列中发送消息，2条消息之间间隔一定时间，关闭通道和连接。

![Center 10][]

**消费者实现思路：**

创建连接工厂ConnectionFactory，设置服务地址127.0.0.1，端口号5672，设置用户名、密码、virtual host，从连接工厂中获取连接connection，使用连接创建通道channel，使用通道channel创建队列queue，创建消费者C1并监听队列，获取消息并暂停10ms，另外一个消费者C2暂停1000ms，由于消费者C1消费速度快，所以C1可以执行更多的任务。

![Center 11][]

## 3.3 发布/订阅模式Publish/Subscribe ##

![Center 12][]

**功能：**一个生产者发送的消息会被多个消费者获取。一个生产者、一个交换机、多个队列、多个消费者

生产者：可以将消息发送到队列或者是交换机。

消费者：只能从队列中获取消息。

如果消息发送到没有队列绑定的交换机上，那么消息将丢失。

交换机不能存储消息，消息存储在队列中

**生产者实现思路：**

创建连接工厂ConnectionFactory，设置服务地址127.0.0.1，端口号5672，设置用户名、密码、virtual host，从连接工厂中获取连接connection，使用连接创建通道channel，使用通道channel创建队列queue，使用通道channel创建交换机并指定交换机类型为fanout，使用通道向交换机发送消息，关闭通道和连接。

![Center 13][]

**消费者实现思路：**

创建连接工厂ConnectionFactory，设置服务地址127.0.0.1，端口号5672，设置用户名、密码、virtual host，从连接工厂中获取连接connection，使用连接创建通道channel，使用通道channel创建队列queue，绑定队列到交换机，设置Qos=1，创建消费者并监听队列，使用手动方式返回完成。可以有多个队列绑定到交换机，多个消费者进行监听。

![Center 14][]

## 3.4 路由模式Routing ##

![Center 15][]

说明：生产者发送消息到交换机并且要指定路由key，消费者将队列绑定到交换机时需要指定路由key

**生产者实现思路：**

创建连接工厂ConnectionFactory，设置服务地址127.0.0.1，端口号5672，设置用户名、密码、virtual host，从连接工厂中获取连接connection，使用连接创建通道channel，使用通道channel创建队列queue，使用通道channel创建交换机并指定交换机类型为direct，使用通道向交换机发送消息并指定key=b，关闭通道和连接。

![Center 16][]

**消费者实现思路：**

![Center 17][]

## 3.5 通配符模式Topics   ##

![Center 18][]

说明：生产者P发送消息到交换机X，type=topic，交换机根据绑定队列的routing key的值进行通配符匹配；符号\#：匹配一个或者多个词lazy.\# 可以匹配lazy.irs或者lazy.irs.cor

符号\*：只能匹配一个词lazy.\* 可以匹配lazy.irs或者lazy.cor

**生产者实现思路：**

创建连接工厂ConnectionFactory，设置服务地址127.0.0.1，端口号5672，设置用户名、密码、virtual host，从连接工厂中获取连接connection，使用连接创建通道channel，使用通道channel创建队列queue，使用通道channel创建交换机并指定交换机类型为topic，使用通道向交换机发送消息并指定key=key.1，关闭通道和连接。

![Center 19][]

**消费者实现思路：**

![Center 20][]

# 4.spring集成rabbitmq配置 #

Spring提供了AMQP的一个实现，并且spring-rabbit是RabbitMQ的一个实现，下面给出订阅者模式的事例配置如下：

![Center 21][]

# 5.总结 #

RabbitMQ提供了6种模式，分别是HelloWorld，Work Queue，Publish/Subscribe，Routing，Topics，RPC Request/reply，本文详细讲述了前5种，并给出代码实现和思路。其中Publish/Subscribe，Routing，Topics三种模式可以统一归为Exchange模式，只是创建时交换机的类型不一样，分别是fanout、direct、topic。Spring提供了rabbitmq的一个实现，所以集成起来很方便，文章第4章给出了订阅者模式的一种spring配置。

欢迎大家关注博主订阅号“Java技术日志”，提供Java相关技术分享，从Java编程基础到Java高级技术，从JavaWeb技术基础Jsp、Servlet、JDBC到SSH、SSM开发框架，从REST风格接口设计到分布式项目实战。剖析主流开源技术框架，用亲身实践来谱写深度Java技术日志。

[Center]: /images/1604223735279.png
[Center 1]: /images/1604223711574.png
[http_127.0.0.1_15672]: http://127.0.0.1:15672/
[Center 2]: /images/1604223685240.png
[http_packages.erlang-solutions.com_erlang-solutions-1.0-1.noarch.rpm]: http://packages.erlang-solutions.com/erlang-solutions-1.0-1.noarch.rpm
[http_packages.erlang-solutions.com_rpm_erlang_solutions.asc]: http://packages.erlang-solutions.com/rpm/erlang_solutions.asc
[Center 3]: /images/1604223634689.png
[Center 4]: /images/1604223610477.png
[Center 5]: /images/1604223584610.png
[Center 6]: /images/1604223560421.png
[Center 7]: /images/1604223532231.png
[Center 8]: /images/1604223505092.png
[Center 9]: /images/1604223478443.png
[Center 10]: /images/1604223453429.png
[Center 11]: /images/1604223425240.png
[Center 12]: /images/1604223401465.png
[Center 13]: /images/1604223378100.png
[Center 14]: /images/1604223352664.png
[Center 15]: /images/1604223323696.png
[Center 16]: /images/1604223270341.png
[Center 17]: /images/1604223243951.png
[Center 18]: /images/1604223217120.png
[Center 19]: /images/1604223188215.png
[Center 20]: /images/1604223160616.png
[Center 21]: /images/1604222460965.png