RabbitMQ学习笔记（一）RabbitMQ简介及 Windows安装RabbitMQ

矫情吗；* 2022-03-20 14:40 458阅读 0赞

### 文章目录 ###

*  RabbitMQ介绍
 *  RabbitMQ特点
 *  RabbitMQ 基本概念及架构
 *  安装Erlang
 *  安装RabbitMQ
 *  用户管理
 *   *  创建新用户
 *  java客户端测试RabbitMQ

# RabbitMQ介绍 #

rabbitMQ是一个在AMQP协议标准基础上完整的，可服用的企业消息系统。它遵循Mozilla Public License开源协议，采用 Erlang 实现的工业级的消息队列(MQ)服务器，Rabbit MQ 是建立在Erlang OTP平台上。

# RabbitMQ特点 #

RabbitMQ 是一个由 Erlang 语言开发的 AMQP 的开源实现。

AMQP ：Advanced Message Queue，高级消息队列协议。它是应用层协议的一个开放标准，为面向消息的中间件设计，基于此协议的客户端与消息中间件可传递消息，并不受产品、开发语言等条件的限制。

RabbitMQ 最初起源于金融系统，用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。具体特点包括：

（1）可靠性（Reliability）  
RabbitMQ 使用一些机制来保证可靠性，如持久化、传输确认、发布确认。

（2）灵活的路由（Flexible Routing）  
在消息进入队列之前，通过 Exchange 来路由消息的。对于典型的路由功能，RabbitMQ 已经提供了一些内置的 Exchange 来实现。针对更复杂的路由功能，可以将多个 Exchange 绑定在一起，也通过插件机制实现自己的 Exchange 。

（3）消息集群（Clustering）  
多个 RabbitMQ 服务器可以组成一个集群，形成一个逻辑 Broker 。

（4）高可用（Highly Available Queues）  
队列可以在集群中的机器上进行镜像，使得在部分节点出问题的情况下队列仍然可用。

（5）多种协议（Multi-protocol）  
RabbitMQ 支持多种消息队列协议，比如 STOMP、MQTT 等等。

（6）多语言客户端（Many Clients）  
RabbitMQ 几乎支持所有常用语言，比如 Java、.NET、Ruby 等等。

（7）管理界面（Management UI）  
RabbitMQ 提供了一个易用的用户界面，使得用户可以监控和管理消息 Broker 的许多方面。

（8）跟踪机制（Tracing）  
如果消息异常，RabbitMQ 提供了消息跟踪机制，使用者可以找出发生了什么。

（9）插件机制（Plugin System）  
RabbitMQ 提供了许多插件，来从多方面进行扩展，也可以编写自己的插件。

# RabbitMQ 基本概念及架构 #

![在这里插入图片描述][20190213142318564.png]  
（1）Message  
消息，消息是不具名的，它由消息头和消息体组成。消息体是不透明的，而消息头则由一系列的可选属性组成，这些属性包括routing-key（路由键）、priority（相对于其他消息的优先权）、delivery-mode（指出该消息可能需要持久性存储）等。  
（2）Publisher  
消息的生产者，也是一个向交换器发布消息的客户端应用程序。  
（3）Exchange  
交换器，用来接收生产者发送的消息并将这些消息路由给服务器中的队列。  
（4）Binding  
绑定，用于消息队列和交换器之间的关联。一个绑定就是基于路由键将交换器和消息队列连接起来的路由规则，所以可以将交换器理解成一个由绑定构成的路由表。  
（5）Queue  
消息队列，用来保存消息直到发送给消费者。它是消息的容器，也是消息的终点。一个消息可投入一个或多个队列。消息一直在队列里面，等待消费者连接到这个队列将其取走。  
（6）Connection  
网络连接，比如一个TCP连接。  
（7）Channel  
信道，多路复用连接中的一条独立的双向数据流通道。信道是建立在真实的TCP连接内地虚拟连接，AMQP 命令都是通过信道发出去的，不管是发布消息、订阅队列还是接收消息，这些动作都是通过信道完成。因为对于操作系统来说建立和销毁 TCP 都是非常昂贵的开销，所以引入了信道的概念，以复用一条 TCP 连接。  
（8）Consumer  
消息的消费者，表示一个从消息队列中取得消息的客户端应用程序。  
（9）Virtual Host  
虚拟主机，表示一批交换器、消息队列和相关对象。虚拟主机是共享相同的身份认证和加密环境的独立服务器域。每个 vhost 本质上就是一个 mini 版的 RabbitMQ 服务器，拥有自己的队列、交换器、绑定和权限机制。vhost 是 AMQP 概念的基础，必须在连接时指定，RabbitMQ 默认的 vhost 是 / 。  
（10）Broker  
表示消息队列服务器实体。

# 安装Erlang #

官网下载地址：[http://www.erlang.org/downloads][http_www.erlang.org_downloads]

根据自己电脑选择相应版本，我这里选择的64位  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70]  
下载完成后直接安装，一直NEXT就行。

**配置环境变量**

ERLANG_HOME=C:\Program Files\erl10.2

在PATH中添加

%ERLANG_HOME%\bin;

**验证是否安装成功**：在命令行窗口中输入`erl`, 展示版本号则表示安装成功：  
![在这里插入图片描述][20190213142711838.png]

# 安装RabbitMQ #

官网下载地址：[http://www.rabbitmq.com/install-windows.html][http_www.rabbitmq.com_install-windows.html]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 1]  
下载安装即可。

**配置环境变量**  
新建`RABBITMQ_SERVER=C:\Program Files\RabbitMQ Server\rabbitmq_server-3.7.11`;  
在PATH中添加`%RABBITMQ_SERVER%\sbin;`。  
**激活rabbitmq\_management**  
在命令行窗口中进入`C:\Program Files\RabbitMQ Server\rabbitmq_server-3.7.11`目录，执行命令`rabbitmq-plugins.bat enable rabbitmq_management`:  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 2]  
**启动RabbitMQ服务**  
执行命令`net stop RabbitMQ && net start RabbitMQ`进行服务重启。  
![在这里插入图片描述][20190213143256213.png]  
如果出现下面这个错误，则表示您需要**以管理员身份运行**CMD命令行窗口：  
![在这里插入图片描述][2019021314341659.png]  
到此，rabbitmq安装成功。此时服务已经启动，浏览器访问\`http://localhost:15672/ 控制台  
默认的用户名：guest  
默认的密码为：guest

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 3]

# 用户管理 #

默认只有一个guest用户，他的角色是administor，执行命令`rabbitmqctl.bat list_users`查看已有用户及用户的角色  
![在这里插入图片描述][20190213143836469.png]

rabbitmq用户角色可分为五类：**超级管理员, 监控者, 策略制定者, 普通管理者以及其他**

(1) 超级管理员(administrator)  
可登陆管理控制台(启用management plugin的情况下)，可查看所有的信息，并且可以对用户，策略(policy)进行操作。  
(2) 监控者(monitoring)  
可登陆管理控制台(启用management plugin的情况下)，同时可以查看rabbitmq节点的相关信息(进程数，内存使用情况，磁盘使用情况等)  
(3) 策略制定者(policymaker)  
可登陆管理控制台(启用management plugin的情况下), 同时可以对policy进行管理。  
(4) 普通管理者(management)  
仅可登陆管理控制台(启用management plugin的情况下)，无法看到节点信息，也无法对策略进行管理。  
(5) 其他的  
无法登陆管理控制台，通常就是普通的生产者和消费者

## 创建新用户 ##

`rabbitmqctl.bat add_user username password`新建一个用户。  
`rabbitmqctl.bat set_user_tags username administrator`为用户添加一个角色。  
`rabbitmqctl.bat set_user_tags username tag1 tag2 ...`也可以为其增加多个角色。  
`rabbitmqctl.bat change_password username newpassword`修改密码。  
`rabbitmqctl.bat delete_user username`删除用户。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 4]  
现在可以使用新用户来登陆rabbitMQ的控制台了。  
当然我们也可以在控制台中对用户进行管理，这里就不演示了  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 5]

# java客户端测试RabbitMQ #

首先我们要先将上面的新建的用户lbl添加一个`Can access virtual hosts`（上图中可以看到是`No access`）。  
![在这里插入图片描述][20190213154252655.png]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 6]  
我们这里讲lbl的virtual host设置为`/`：  
![在这里插入图片描述][20190213154353324.png]  
**编写消息发送者**

import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.ConnectionFactory;
    
    public class SendMQ { 
        private final static String QUEUE_NAME = "Hello";
    
        public static void main(String[] args) throws Exception { 
            // connection是socket连接的抽象，并且为我们管理协议版本协商（protocol version negotiation），
            // 认证（authentication ）等等事情。这里我们要连接的消息代理在本地，因此我们将host设为“localhost”。
            // 如果我们想连接其他机器上的代理，只需要将这里改为特定的主机名或IP地址。
            ConnectionFactory factory = new ConnectionFactory();
            factory.setHost("localhost");
            factory.setPort(5672); //默认端口号
            factory.setUsername("lbl");//默认用户名
            factory.setPassword("123456");//默认密码
            Connection connection = factory.newConnection();
            Channel channel = connection.createChannel();
            // 接下来，我们创建一个channel，绝大部分API方法需要通过调用它来完成。
            // 发送之前，我们必须声明消息要发往哪个队列，然后我们可以向队列发一条消息：
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
            String message = "Hello world";
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
            System.out.println(" [x] Sent '" + message + "'");
            channel.close();
            connection.close();
        }
    }

**编写消息接受者**

import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.ConnectionFactory;
    import com.rabbitmq.client.DeliverCallback;
    
    public class RecvMQ { 
    
        private final static String QUEUE_NAME = "Hello";
    
        public static void main(String[] argv) throws Exception { 
            ConnectionFactory factory = new ConnectionFactory();
            factory.setHost("localhost");
            Connection connection = factory.newConnection();
            Channel channel = connection.createChannel();
    
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
            System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
    
            DeliverCallback deliverCallback = (consumerTag, delivery) -> { 
                String message = new String(delivery.getBody(), "UTF-8");
                System.out.println(" [x] Received '" + message + "'");
            };
            channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> { 
            });
        }
    }

注：上面实例来源官方实例：[http://www.rabbitmq.com/tutorials/tutorial-one-java.html][http_www.rabbitmq.com_tutorials_tutorial-one-java.html]  
在rabbitMQ的控制台查看`queues=hello`的消息（我这里不小心执行了两次，所以会有两条消息）。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 7]  
执行`RecvMQ`，可以看到控制台输出

[*] Waiting for messages. To exit press CTRL+C
     [x] Received 'Hello world'
     [x] Received 'Hello world'

`RecvMQ`不关闭，在执行一次`SendMQ`，可以看到控制台又消费了一条消息`[x] Received 'Hello world'`。

[20190213142318564.png]: /images/20220320/f31b48b0b4ec4b04b1a96625d9329444.png
[http_www.erlang.org_downloads]: http://www.erlang.org/downloads
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70]: /images/20220320/b2ae82150a3648e896cd70ac7aa9437a.png
[20190213142711838.png]: /images/20220320/e4dcbbc863d0463f9f315906311d33d3.png
[http_www.rabbitmq.com_install-windows.html]: http://www.rabbitmq.com/install-windows.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 1]: /images/20220320/67dc35b472604814966fcd3da1906439.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 2]: /images/20220320/ce737cf081a74cf3b92dce9b79036c42.png
[20190213143256213.png]: /images/20220320/d0f64bbfdc814ca2bc76138c0a577485.png
[2019021314341659.png]: /images/20220320/ebe79d1489834ce09ef22a1b150aa9e6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 3]: /images/20220320/53f2a17b874245f299f312775672b4ab.png
[20190213143836469.png]: /images/20220320/2aea260445c04312aff99b4c8e57e0e5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 4]: /images/20220320/994fcfa1cff04b3dbf14e68c5ea88b90.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 5]: /images/20220320/43d0dfd357bc4ffcb1fbdc7de2eb7e69.png
[20190213154252655.png]: /images/20220320/6d53ad55978540ef89175995ba946860.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 6]: /images/20220320/1d0d88643246492f86eac2ba72a394a3.png
[20190213154353324.png]: /images/20220320/1c51b36f0e6c4ab5af98490280eade37.png
[http_www.rabbitmq.com_tutorials_tutorial-one-java.html]: http://www.rabbitmq.com/tutorials/tutorial-one-java.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 7]: /images/20220320/884ff752018e43c8b346fff8243e80ee.png