30分鐘學玩轉RabbitMQ

最近在學習RabbitMQ，在網上找了很多資料發現都特高端。動輒集羣部署，分佈式架構什麼的，對於一個初學者實在不夠友好。心想求人不如求本身，爲何不本身整理一套資料呢？因而《30分鐘學玩轉RabbitMQ》誕生。

1、準備工做

聽說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

從新經過在本地瀏覽器訪問管理頁面，輸入用戶名和密碼。

2、簡單開發指南

深刻的開發案例網上不少，我就不在這裏重複的發明輪子了。做爲一個指南，這裏主要介紹兩種開發方式，更加具體的用例我可能會在之後的文章中專門介紹。

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整合成功。