Window10 系统 RabbitMQ的安装和简单使用

港控/mmm° 2024-03-17 18:06 48阅读 0赞

#### 1、下载 & 安装 Erlang ####

因为RabbitMQ的服务端是基于 Erlang编写的，所以，首先需要安装Erlang。

##### 1）下载 #####

下载地址如下：

https://www.erlang.org/downloads

![在这里插入图片描述][b4f2223f27a5438e910f57df81856e96.png]

> 此处下载比较慢，可以参考如下百度网盘：  
> 链接：https://pan.baidu.com/s/1oXq5QX3IlzRq5L-mk1gC4Q  
> 提取码：luna

##### 2）安装 #####

选择相应的安装目录，一路next即可。

##### 3）配置环境变量 #####

在系统变量中新建变量  
变量名(N)：**ERLANG\_HOME**  
变量值(V)：**H:\\SW\_install\\erl-24.1**

> 注意：变量值需要根据自己的实际情况进行修改

![在这里插入图片描述][4d6d718bcc89478fb35f8d1923958458.png]  
将 **;%ERLANG\_HOME%\\bin** 添加到 **Path** 变量值的最后。

##### 4）验证环境变量配置的正确性 #####

echo %ERLANG_HOME%

![在这里插入图片描述][93d3f3f9c8b74d628c9f0b2a3197b416.png]

#### 2、下载 & 安装 RabbitMQ ####

##### 1）下载 #####

下载地址如下：

https://www.rabbitmq.com/install-windows.html#installer

![在这里插入图片描述][145eb40e1f0e465ea77e3ce382750ac6.png]

##### 2）安装 #####

选择相应的安装目录，一路next即可。

##### 3）配置环境变量 #####

在系统变量中新建变量  
变量名(N)：**RABBITMQ\_SERVER**  
变量值(V)：**H:\\SW\_install\\RabbitMQ Server\\rabbitmq\_server-3.9.7**

> 注意：变量值需要根据自己的实际情况进行修改

![在这里插入图片描述][693ad1e3429b44a7bafb3f12524e9a4f.png]  
将 **;%RABBITMQ\_SERVER%\\sbin** 添加到 **Path** 变量值的最后。![在这里插入图片描述][52c902aba51e4c0892fcc772ddadf2ea.png]

##### 4）验证环境变量配置的正确性 #####

echo %RABBITMQ_SERVER%

![在这里插入图片描述][586e9c146d4146b0afa0f11fa5842239.png]

##### 5）安装 rabbitmq-plugins #####

cmd命令打开命令行窗口，进入到rabbitmq的安装bin目录（我的是：H:\\SW\_install\\RabbitMQ Server\\rabbitmq\_server-3.9.7\\sbin）

执行如下命令，进行插件安装：

rabbitmq-plugins.bat enable rabbitmq_management

> 如果此处报如下错误：  
> **ERLANG\_HOME not set correctly**  
> 在确认配置的环境变量没问题的情况下，从C:目录逐层到RabbitMQ的安装bin目录，再次执行插件安装，即可解决。

##### 6）启动 RabbitMQ 服务 #####

net start RabbitMQ

或者  
在rabbitmq的sbin目录下，双击执行 **rabbitmq-server.bat** 文件。

##### 7）停止 RabbitMQ 服务 #####

net stop RabbitMQ

##### 8）查看服务状态 #####

rabbitmqctl status

##### 9）页面访问 RabbitMQ #####

**http://localhost:15672**  
账号/密码：**guest**/**guest**

![在这里插入图片描述][3a9b184233c741cc896e63b7e6187e84.png]  
登录后，页面如下：  
![在这里插入图片描述][553f9937c8ea4496a5702e01341c7f77.png]  
![在这里插入图片描述][e11406c42e564b26b045de0bde8bd334.png]

#### 3、RabbitMQ 的简单使用 ####

##### 1）RabbitMQ 的 pom 引用 #####

<dependency>
        <groupId>com.rabbitmq</groupId>
        <artifactId>amqp-client</artifactId>
        <version>5.13.1</version>
    </dependency>

##### 2）消息发送方 #####

package com.miracle.luna.rabbitmq;
    
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.ConnectionFactory;
    
    import java.nio.charset.StandardCharsets;
    
    /**
     * @author Miracle Luna
     * @date 2021/10/19
     */
    public class SendMQ {
        
        private final static String QUEUE_NAME = "hello";
    
        public static void main(String[] args) throws Exception{
        
            ConnectionFactory factory = new ConnectionFactory();
            factory.setHost("localhost");
            factory.setPort(5672);
            factory.setUsername("guest");
            factory.setPassword("guest");
    
            final Connection connection = factory.newConnection();
            final Channel channel = connection.createChannel();
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
    
            String message = "Hello, RabbitMQ!";
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes(StandardCharsets.UTF_8));
            System.out.println("Send '" + message + "'");
    
            channel.close();
            connection.close();
        }
    }

运行结果如下：

Send 'Hello, RabbitMQ!'

##### 3）消息接收方 #####

package com.miracle.luna.rabbitmq;
    
    import com.rabbitmq.client.*;
    
    import java.io.IOException;
    import java.nio.charset.StandardCharsets;
    
    /**
     * @author Miracle Luna
     * @date 2021/10/19
     */
    public class RecvMQ {
        
        private final static String QUEUE_NAME = "hello";
    
        public static void main(String[] args) throws Exception{
        
            ConnectionFactory factory = new ConnectionFactory();
            factory.setHost("localhost");
            factory.setPort(5672);
            factory.setUsername("guest");
            factory.setPassword("guest");
    
            final Connection connection = factory.newConnection();
            final Channel channel = connection.createChannel();
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
    
            System.out.println("Waiting for messages...");
    
            Consumer consumer = new DefaultConsumer(channel) {
        
                @Override
                public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
        
                    String message = new String(body, StandardCharsets.UTF_8);
                    System.out.println("Received '" + message + "'");
                }
            };
    
            channel.basicConsume(QUEUE_NAME, true, consumer);
        }
    }

运行结果如下：

Waiting for messages...
    Received 'Hello, RabbitMQ!'

可以在Queues页签中，看到所有队列中的消息数量  
![在这里插入图片描述][d76e173b5adb4eb585408cb7953adee1.png]

#### 4、常用命令 ####

1）查看用户列表：rabbitmqctl list\_users  
2）新增一个用户：rabbitmqctl add\_user root password  
3）删除一个用户：rabbitmqctl delete\_user test  
4）修改用户密码：rabbitmqctl change\_password root 123456  
5）授予管理员角色：rabbitmqctl set\_user\_tags root administrator  
6）授予用户权限：rabbitmqctl set\_permissions -p / root “.” “.” “.\*”  
7）查看队列列表：rabbitmqctl list\_queues  
8）删除一个队列：rabbitmqctl delete\_queue test  
9）重置（如果忘记密码，可以进行应用重置，但是数据会丢失，慎用！！！）：  
rabbitmqctl stop\_app  
rabbitmqctl reset  
rabbitmqctl start\_app

[b4f2223f27a5438e910f57df81856e96.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/29862bb7106842f0b1587fd6c9745bcb.png
[4d6d718bcc89478fb35f8d1923958458.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/c55f599a10b94becbfbdeba837cfd79f.png
[93d3f3f9c8b74d628c9f0b2a3197b416.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/8c911a3ca563444e9faed82a6f82d041.png
[145eb40e1f0e465ea77e3ce382750ac6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/afa10290b6ee45d2a67933795b8cfa6b.png
[693ad1e3429b44a7bafb3f12524e9a4f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/a28d88f1a6df41d4b1208f2d1aa5e0c9.png
[52c902aba51e4c0892fcc772ddadf2ea.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/fc3c712acf424d44947c081ab8497f32.png
[586e9c146d4146b0afa0f11fa5842239.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/d514d37d032d477594ccabcdab0517f3.png
[3a9b184233c741cc896e63b7e6187e84.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/e00078a7e89b443da37b68d570aae28d.png
[553f9937c8ea4496a5702e01341c7f77.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/f10ab6241084487fb6bc730a8f3425c8.png
[e11406c42e564b26b045de0bde8bd334.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/6cffef2bedcd46f889c14712d89669aa.png
[d76e173b5adb4eb585408cb7953adee1.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/80cee132583a48d9883936c990219237.png