最近在學習RabbitMQ，在網上找了不少資料發現都特高端。動輒集群部署，分布式架構什么的，對於一個初學者實在不夠友好。心想求人不如求自己，為什么不自己整理一套資料呢？於是《30分鍾學玩轉RabbitMQ》誕生。
一、准備工作
據說RabbitMQ是可以部署到Windows環境的，不過作為一個專業級的開發人員怎么能夠讓這樣的事情發生呢？自然我們的准備工作從Linux開始。首先在虛擬機中安裝CentOS 7，選擇英文，最小安裝，默認開啟網絡以及創建一個root用戶：
完成以后進入系統，由於最小安裝有一些基本的命令無法使用，因此在進入一下步之前先將ifconfig、vim以及基本的編譯環境准備好：
<!-- 安裝ifconfig --> yum install net-tools <!-- 安裝vim --> yum install yum <!-- 准備基礎編譯環境 --> yum install gcc glibc-devel make ncurses-devel openssl-devel xmlto
接下來我們從官網下載安裝包rabbitmq-server-3.7.2-1.el7.noarch.rpm和otp_src_19.3.tar.gz（千萬別問我Erlang是什么，我也是第一次知道這門語言）。上傳到虛擬機后執行命令：
<!-- 解壓包 --> [root@MiWiFi-R3-srv ~]# tar -xvf otp_src_19.3.tar.gz [root@MiWiFi-R3-srv ~]# ll
[root@MiWiFi-R3-srv ~]# mkdir /usr/local/erlang
[root@MiWiFi-R3-srv ~]# cd otp_src_19.3
[root@MiWiFi-R3-srv otp_src_19.3]# ./configure --prefix=/usr/local/erlang --without-javac
[root@MiWiFi-R3-srv otp_src_19.3]# make && make install
編譯&安裝完成以后配置Erlang環境變量：
[root@MiWiFi-R3-srv otp_src_19.3]# vim /etc/profile
#追加環境變量到文件末尾
ERL_HOME=/usr/local/erlang
PATH=$ERL_HOME/bin:$PATH
export ERL_HOME PATH
[root@MiWiFi-R3-srv otp_src_19.3]# source /etc/profile
接下來可以正式安裝RabbitMQ：
[root@MiWiFi-R3-srv otp_src_19.3]# cd ..
[root@MiWiFi-R3-srv ~]# rpm -ivh --nodeps rabbitmq-server-3.7.2-1.el7.noarch.rpm
運行RabbitMQ需要首先開放15672和5672端口：
[root@MiWiFi-R3-srv ~]# firewall-cmd --zone=public --add-port=15672/tcp --permanent
[root@MiWiFi-R3-srv ~]# firewall-cmd --zone=public --add-port=5672/tcp --permanent
[root@MiWiFi-R3-srv ~]# firewall-cmd --reload
正常情況下RabbitMQ已經安裝完成，最后測試一下：
[root@MiWiFi-R3-srv ~]# rabbitmq-plugins enable rabbitmq_management
[root@MiWiFi-R3-srv ~]# rabbitmq-server
正常啟動以后，我們可以在本地使用瀏覽器中訪問管理頁面：http://<虛擬機IP>:15672/
大功告成...
至此，我們的准備工作已經完成了80%。接下來我們需要為RabbitMQ創建用戶並賦權。
[root@MiWiFi-R3-srv ~]# rabbitmqctl add_user root root [root@MiWiFi-R3-srv ~]# rabbitmqctl set_user_tags root administrator [root@MiWiFi-R3-srv ~]# rabbitmqctl set_permissions -p / root '.*' '.*' '.*' <!-- 后台啟動 --> [root@MiWiFi-R3-srv ~]# rabbitmq-server -detached
重新通過在本地瀏覽器訪問管理頁面，輸入用戶名和密碼。
二、簡單開發指南
深入的開發案例網上很多，我就不在這里重復的發明輪子了。作為一個指南，這里主要介紹兩種開發方式，更加具體的用例我可能會在以后的文章中專門介紹。
1.單獨使用——一個簡單的消息生產者
通過maven引入依賴
<dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artifactId> <version>5.1.1</version> </dependency>
創建生產者：
package com.learnhow.rabbitmq; import java.io.IOException; import java.util.concurrent.TimeoutException; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; public class App { // 隊列名稱 public final static String QUEUE_NAME = "Hello.rabbitMQ"; public static void main(String[] args) throws IOException, TimeoutException { // 連接工廠 ConnectionFactory factory = new ConnectionFactory(); // 配置連接屬性 factory.setHost("192.168.31.244"); // 虛擬機地址 factory.setPort(5672); // 端口號 factory.setUsername("root"); // 用戶名 factory.setPassword("root"); // 密碼 // 得到連接，創建通道 Connection connection = factory.newConnection(); Channel channel = connection.createChannel(); // 聲明一個叫Hello.rabbitMQ的隊列 channel.queueDeclare(QUEUE_NAME, false, false, false, null); String message = "Hello RabbitMQ"; // 發送消息 channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8")); // 關閉通道和連接 channel.close(); connection.close(); } }
執行完成以后切換到瀏覽器的管理頁面：
我們發現剛才在main函數中聲明的QUEUE NAME已經出現了。
2.Spring AMQP——與Spring Boot集成
Maven依賴：
<parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.9.RELEASE</version> </parent> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> </dependencies>
Spring Boot啟動項，聲明測試隊列：
package org.dispatcher; import org.springframework.amqp.core.Queue; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.context.annotation.Bean; @SpringBootApplication public class DispatcherApplication { @Bean public Queue helloQueue() { return new Queue("helloQueue"); } public static void main(String[] args) throws Exception { SpringApplication.run(DispatcherApplication.class, args); } }
消息生產者：
package org.dispatcher.controller; import java.util.Date; import org.springframework.amqp.core.AmqpTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @Component public class Producer { @Autowired private AmqpTemplate rabbitTemplate; public void send() { String sendMsg = "Hi~ " + new Date(); this.rabbitTemplate.convertAndSend("helloQueue", sendMsg); } }
消息接收者：
package org.dispatcher.controller; import org.springframework.amqp.rabbit.annotation.RabbitHandler; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; @Component @RabbitListener(queues = "helloQueue") public class Receiver { @RabbitHandler public void process(String msg) { System.out.println("Receiver: " + msg); } }
Restful接口：
package org.dispatcher.controller; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; @RestController @RequestMapping("/rabbitmq") public class RabbitMqController { private static final String SUCCESS = "SUCCESS"; private static final String FAILURE = "FAILURE"; @Autowired private Producer producer; @GetMapping("/push") public String push() { producer.send(); return SUCCESS; } }
配置文件application.yml：
server:
port: 8081
spring:
rabbitmq:
host: 192.168.31.244
port: 5672
username: root
password: root
virtual-host: /
publisher-confirms: true
啟動Spring Boot，訪問：http://localhost:8081/rabbitmq/push，再切換到管理頁面：
新的QUEUE NAME證明Spring Boot與RabbitMQ整合成功。