### 1、下載 & 安裝 Erlang 因為RabbitMQ的服務端是基于 Erlang編寫的，所以，首先需要安裝Erlang。 **1）下載** 下載地址如下： [https://www.erlang.org/downloads](https://www.erlang.org/downloads) （此處下載比較慢，可以參考如下百度網盤） 鏈接：[https://pan.baidu.com/s/1oXq5QX3IlzRq5L-mk1gC4Q](https://pan.baidu.com/s/1oXq5QX3IlzRq5L-mk1gC4Q) 提取碼：**luna**  **2）安裝** 選擇相應的安裝目錄，一路next即可 **3）配置環境變量** 在系統變量中新建變量 變量名(N)：ERLANG\_HOME 變量值(V)：H:\\SW\_install\\erl-24.1 （注意：變量值需要根據自己的實際情況進行修改）  將;%ERLANG\_HOME%\\bin添加到Path變量值的最后 **4）驗證環境變量配置的正確性** ~~~ echo %ERLANG_HOME% ~~~  ### 2、下載 & 安裝 RabbitMQ **1）下載** 下載地址如下： [https://www.rabbitmq.com/install-windows.html#installer](https://www.rabbitmq.com/install-windows.html#installer)  **2）安裝** 選擇相應的安裝目錄，一路next即可 **3）配置環境變量** 在系統變量中新建變量 變量名(N)：RABBITMQ\_SERVER 變量值(V)：H:\\SW\_install\\RabbitMQ Server\\rabbitmq\_server-3.9.7 （注意：變量值需要根據自己的實際情況進行修改）  將;%RABBITMQ\_SERVER%\\sbin添加到Path變量值的最后  **4）驗證環境變量配置的正確性** ~~~ echo %RABBITMQ_SERVER% ~~~  **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  登錄后，頁面如下：  可以通過頁面，添加新的用戶（Admin--> Users--> Add a user --> Add user）  ### 3、RabbitMQ 的簡單使用 **1）RabbitMQ 的 pom 引用** [](javascript:void(0); "復制代碼") ~~~ <!-- https://mvnrepository.com/artifact/com.rabbitmq/amqp-client --> <dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artifactId> <version>5.13.1</version> </dependency> ~~~ [](javascript:void(0); "復制代碼") **2）消息發送方** [](javascript:void(0); "復制代碼") ~~~ 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(); } } ~~~ [](javascript:void(0); "復制代碼") 運行結果如下： ~~~ Send 'Hello, RabbitMQ!' ~~~ **3）消息接收方** [](javascript:void(0); "復制代碼") ~~~ 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); } } ~~~ [](javascript:void(0); "復制代碼") 運行結果如下： ~~~ Waiting for messages... Received 'Hello, RabbitMQ!' ~~~ 可以在Queues頁簽中，看到所有隊列中的消息數量  ### 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 https://www.cnblogs.com/miracle-luna/p/15426463.html