30分钟学玩转RabbitMQ

本是古典何须时尚 2022-05-31 00:52 173阅读 0赞

转载自 http://www.cnblogs.com/learnhow/p/8362289.html

最近在学习RabbitMQ，在网上找了不少资料发现都特高端。动辄集群部署，分布式架构什么的，对于一个初学者实在不够友好。心想求人不如求自己，为什么不自己整理一套资料呢？于是《30分钟学玩转RabbitMQ》诞生。

一、准备工作

据说RabbitMQ是可以部署到Windows环境的，不过作为一个专业级的开发人员怎么能够让这样的事情发生呢？自然我们的准备工作从Linux开始。首先在虚拟机中安装CentOS 7，选择英文，最小安装，默认开启网络以及创建一个root用户：

![871676-20180126215415147-616136809.png][]

![871676-20180126215534787-2017835205.png][]

![871676-20180126215704975-818299634.png][]

完成以后进入系统，由于最小安装有一些基本的命令无法使用，因此在进入一下步之前先将ifconfig、vim以及基本的编译环境准备好：

![复制代码][copycode.gif]

yum install net-tools
    
    
    yum install yum
    
    
    yum install gcc glibc-devel make ncurses-devel openssl-devel xmlto

![复制代码][copycode.gif]

接下来我们从官网下载安装包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

![871676-20180126230218240-970655391.png][]

[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环境变量：

![复制代码][copycode.gif]

[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

![复制代码][copycode.gif]

接下来可以正式安装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

![871676-20180126232942662-1490935331.png][]

正常启动以后，我们可以在本地使用浏览器中访问管理页面：http://<虚拟机IP>:15672/

![871676-20180126233425428-517890344.png][]  大功告成...

至此，我们的准备工作已经完成了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

重新通过在本地浏览器访问管理页面，输入用户名和密码。

![871676-20180126234722365-1587136573.png][]

二、简单开发指南

深入的开发案例网上很多，我就不在这里重复的发明轮子了。作为一个指南，这里主要介绍两种开发方式，更加具体的用例我可能会在以后的文章中专门介绍。

1.单独使用——一个简单的消息生产者

通过maven引入依赖

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

创建生产者：

![复制代码][copycode.gif]

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();
        }
    }

![复制代码][copycode.gif]

执行完成以后切换到浏览器的管理页面：

![871676-20180127000407006-967387756.png][]

我们发现刚才在main函数中声明的QUEUE NAME已经出现了。

2.Spring AMQP——与Spring Boot集成

Maven依赖：

![复制代码][copycode.gif]

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

![复制代码][copycode.gif]

Spring Boot启动项，声明测试队列：

![复制代码][copycode.gif]

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);
        }
    }

![复制代码][copycode.gif]

消息生产者：

![复制代码][copycode.gif]

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);
        }
    }

![复制代码][copycode.gif]

消息接收者：

![复制代码][copycode.gif]

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);
        }
    }

![复制代码][copycode.gif]

Restful接口：

![复制代码][copycode.gif]

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;
        }
    
    }

![复制代码][copycode.gif]

配置文件application.yml：

![复制代码][copycode.gif]

server:
      port: 8081
    spring:
      rabbitmq:
        host: 192.168.31.244
        port: 5672
        username: root
        password: root
        virtual-host: /
        publisher-confirms: true

![复制代码][copycode.gif]

启动Spring Boot，访问：http://localhost:8081/rabbitmq/push，再切换到管理页面：

![871676-20180127002750912-221119420.png][]

新的QUEUE NAME证明Spring Boot与RabbitMQ整合成功。

[871676-20180126215415147-616136809.png]: /images/20220531/426e013a4aba4e3b8b33f09fbfa02eaa.png
[871676-20180126215534787-2017835205.png]: /images/20220531/1dc5703f63184faea7f8b4586729189e.png
[871676-20180126215704975-818299634.png]: /images/20220531/d116498a234e4eb393e3949bbded9911.png
[copycode.gif]: /images/20220531/352258d845374687aef91641dbf8a4ef.png
[871676-20180126230218240-970655391.png]: /images/20220531/3e6f80d06d574e06a356b4c1ca30053e.png
[871676-20180126232942662-1490935331.png]: /images/20220531/906e5d6252d14b1c988cb817ff6ec502.png
[871676-20180126233425428-517890344.png]: /images/20220531/285610602e084619964741146afb37f6.png
[871676-20180126234722365-1587136573.png]: /images/20220531/4af18eda20ff40a28bc228f6bcb68a2f.png
[871676-20180127000407006-967387756.png]: /images/20220531/c165137789d04f8fa29fd5ae56237f1e.png
[871676-20180127002750912-221119420.png]: /images/20220531/e22db061b9fd4fed8c047b8eabd46b2c.png