搜索下載
搜索rabbitmq官網進入下載頁：http://www.rabbitmq.com/download.html，如圖：
安裝
下載完成后直接點擊安裝，此時會檢測系統是否已經安裝其必要的插件，如果彈框說明沒有安裝（安裝了不會彈框），直接點擊“是”，進入下載頁面 http://www.erlang.org/downloads，如圖：
下載完成后直接點擊安裝、選擇路徑（一路next，保持默認）。
安裝完成后檢查環境變量是否自動添加（變量名為ERLANG_HOME），如果沒有，則添加：
此電腦-->鼠標右鍵“屬性”-->高級系統設置-->環境變量-->“新建”系統環境變量，如下圖：
然后雙擊系統變量path，點擊“新建”，將%ERLANG_HOME%\bin加入到path中
校驗是否安裝配置成功：
windows鍵+R鍵，輸入cmd，再輸入erl，看到版本號就說明erlang安裝成功了，如圖：
此時繼續安裝下載的rabbitmq-server-3.7.9.exe，選擇安裝路徑，一路next即可。
配置
1、激活 RabbitMQ's Management Plugin（必須）
進入rabbitmq_server下的sbin目錄，運行控制台，如：
運行命令：rabbitmq-plugins.bat enable rabbitmq_management
注意：輸入rabbitmq-plugins enable rabbitmq_management，導致無法安裝
2、修改端口號和心跳時間（選擇）
到安裝路徑下的etc文件夾下，將rabbitmq.config.example備份一份，並修改為config類型的文件，即為rabbitmq.config。
打開rabbitmq.config，找到tcp_listeners,去掉其前面的注釋%%，然后將后面的整數值5672改為你想要的端口號，如：
{tcp_listeners, [15672]}，
找到heartbeat,去掉注釋%%和大括號后面的逗號，將心跳時間改為你想要的值，如： {heartbeat, 80}
在系統環境變量中新增變量名"RABBITMQ_CONFIG_FILE",值為剛配置的rabbitmq.config文件的路徑地址（去掉后綴），如圖：
特別說明：
rabbitmq.config文件中如果后面有要打開的其他配置，則該項后面的逗號不要去掉，否則就要去掉（不然會有語法錯誤），如：
只開啟配置端口 ：
{tcp_listeners, [15672]} （因為后面沒有要配置的，已經是最后一項，所以去掉逗號）
既開啟端口配置，也開啟心跳配置：
{tcp_listeners, [15672]}，（因為后面有要配置的其他項，所以逗號保留）
{heartbeat, 80}
3、服務停止、更新、啟動
修改配置文件后，不能只重啟服務，而需要重新安裝、更新、重啟服務，如：
注意：運行要用管理員權限，否則無法啟動，如圖所示：
以管理員身份打開cmd控制台，並進入sbin目錄，執行以下三步操作
也可以直接在開始菜單里點擊啟動，如圖：
其他啟動方式或錯誤說明
進入sbin目錄，雙擊rabbitmq-server.bat 或者 直接打開控制台運行 net stop RabbitMQ（關閉） net start RabbitMQ（啟動）運行
啟動出錯
說明端口被占用，修改默認端口
5代表：不是系統管理員權限
訪問測試
http://localhost:15672
默認賬號密碼：guest/guest
4.添加用戶
4.1.添加admin用戶
4.2.用戶角色
1、超級管理員(administrator)
可登陸管理控制台，可查看所有的信息，並且可以對用戶，策略(policy)進行操作。
2、監控者(monitoring)
可登陸管理控制台，同時可以查看rabbitmq節點的相關信息(進程數，內存使用情況，磁盤使用情況等)
3、策略制定者(policymaker)
可登陸管理控制台, 同時可以對policy進行管理。但無法查看節點的相關信息(上圖紅框標識的部分)。
4、普通管理者(management)
僅可登陸管理控制台，無法看到節點信息，也無法對策略進行管理。
5、其他
無法登陸管理控制台，通常就是普通的生產者和消費者。
4.3.創建Virtual Hosts
選中Admin用戶，設置權限：
看到權限已加：
4.4.管理界面中的功能
5.學習五種隊列
5.2.簡單隊列
5.2.1.圖示
P：消息的生產者
C：消息的消費者
紅色：隊列
生產者將消息發送到隊列，消費者從隊列中獲取消息。
5.2.2.導入RabbitMQ的客戶端依賴
<dependency>
<groupId>com.rabbitmq</groupId>
<artifactId>amqp-client</artifactId>
<version>3.4.1</version>
</dependency>package com.zpc.rabbitmq.util;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
public class ConnectionUtil {
public static Connection getConnection() throws Exception {
//定義連接工廠
ConnectionFactory factory = new ConnectionFactory();
//設置服務地址
factory.setHost("localhost");
//端口
factory.setPort(5672);
//設置賬號信息，用戶名、密碼、vhost
factory.setVirtualHost("testhost");
factory.setUsername("admin");
factory.setPassword("admin");
// 通過工程獲取連接
Connection connection = factory.newConnection();
return connection;
}
}
5.2.4.生產者發送消息到隊列
package com.zpc.rabbitmq.simple;
import com.zpc.rabbitmq.util.ConnectionUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
public class Send {
private final static String QUEUE_NAME = "q_test_01";
public static void main(String[] argv) throws Exception {
// 獲取到連接以及mq通道
Connection connection = ConnectionUtil.getConnection();
// 從連接中創建通道
Channel channel = connection.createChannel();
// 聲明（創建）隊列
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();
}
}
5.2.5.管理工具中查看消息
點擊上面的隊列名稱，查詢具體的隊列中的信息：
5.2.6.消費者從隊列中獲取消息
package com.zpc.rabbitmq.simple;
import com.zpc.rabbitmq.util.ConnectionUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.QueueingConsumer;
public class Recv {
private final static String QUEUE_NAME = "q_test_01";
public static void main(String[] argv) throws Exception {
// 獲取到連接以及mq通道
Connection connection = ConnectionUtil.getConnection();
// 從連接中創建通道
Channel channel = connection.createChannel();
// 聲明隊列
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
// 定義隊列的消費者
QueueingConsumer consumer = new QueueingConsumer(channel);
// 監聽隊列
channel.basicConsume(QUEUE_NAME, true, consumer);
// 獲取消息
while (true) {
QueueingConsumer.Delivery delivery = consumer.nextDelivery();
String message = new String(delivery.getBody());
System.out.println(" [x] Received '" + message + "'");
}
}
}
---------------------
參考：https://blog.csdn.net/hellozpc/article/details/81436980