SpringBoot RabbitMQ 整合使用

栏目: Java · 发布时间: 8年前

内容简介：SpringBoot RabbitMQ 整合使用

上次写了篇文章，《SpringBoot Kafka 整合使用》，阅读量还挺高的，于是想想还是把其他几种 MQ 也和 SpringBoot 整合使用下。

下面是四种比较流行的 MQ ：

SpringBoot RabbitMQ 整合使用

后面都写写和 SpringBoot 整合的文章。

安装 RabbitMQ

由于换 Mac 了，所以一些环境就直接在 Mac 搞，但是像安装 RabbitMQ 这些又会把自己电脑系统给搞的太乱，所以能在 Docker 里面安装就安装在 Docker，这次 RabbitMQ 我也直接在 Docker 里安装。

启动 Docker for Mac，如果没安装过的请看我上一篇文章： http://www.54tianzhisheng.cn/2018/01/25/Docker-install/

当然你也可以在自己的 Linux 服务器或者虚拟机里启动安装 RabbitMQ 。

Docker 安装的话很简单，因为 RabbitMQ 官方已经提供了自己的 Docker 容器，只需要一行命令：

docker run -d  -p 15672:15672  -p  5672:5672  -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin --name rabbitmq rabbitmq:3-management

该镜像拥有一个基于 web 的控制台和 Http API。

讲解下上面命令行：

15672 ：表示 RabbitMQ 控制台端口号，可以在浏览器中通过控制台来执行 RabbitMQ 的相关操作。
5672 : 表示 RabbitMQ 所监听的 TCP 端口号，应用程序可通过该端口与 RabbitMQ 建立 TCP 连接，并完成后续的异步消息通信
RABBITMQ_DEFAULT_USER：用于设置登陆控制台的用户名，这里我设置 admin
RABBITMQ_DEFAULT_PASS：用于设置登陆控制台的密码，这里我设置 admin

容器启动成功后，可以在浏览器输入地址： http://localhost:15672/ 访问控制台

SpringBoot RabbitMQ 整合使用

登陆后：

SpringBoot RabbitMQ 整合使用

简单描述下上图中中控制台的列表的作用：

Overview ：用于查看 RabbitMQ 的一些基本信息（消息队列、消息发送速率、节点、端口和上下文信息等）
Connections：用于查看 RabbitMQ 客户端的连接信息
Channels：用户查看 RabbitMQ 的通道信息
Exchange：用于查看 RabbitMQ 交换机
Queues：用于查看 RabbitMQ 的队列
Admin：用于管理用户，可增加用户

创建项目

在 IDEA 中创建一个 SpringBoot 项目结构：

SpringBoot RabbitMQ 整合使用

SpringBoot 框架中已经内置了对 RabbitMQ 的支持，如果你看过官方文档的话，就可以看到的，我们需要把依赖 spring-boot-starter-amqp 引入就行。

1、 pom.xml 引入依赖后如下：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>

	<groupId>com.zhisheng</groupId>
	<artifactId>rabbitmq</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<packaging>jar</packaging>

	<name>rabbitmq</name>
	<description>Demo project for Spring Boot RabbitMQ</description>

	<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>1.5.9.RELEASE</version>
		<relativePath/> <!-- lookup parent from repository -->
	</parent>

	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
		<java.version>1.8</java.version>
	</properties>

	<dependencies>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
			<scope>test</scope>
		</dependency>

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-amqp</artifactId>
		</dependency>
	</dependencies>

	<build>
		<plugins>
			<plugin>
				<groupId>org.springframework.boot</groupId>
				<artifactId>spring-boot-maven-plugin</artifactId>
			</plugin>
		</plugins>
	</build>
</project>

2、 application.properties 配置修改如下：

spring.rabbitmq.addresses=localhost:5672
spring.rabbitmq.username=admin
spring.rabbitmq.password=admin

3、 消息发送类 RabbitMQClient.java

package com.zhisheng.rabbitmq.client;

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * Created by zhisheng_tian on 2018/1/23
 */
@Component
public class RabbitMQClient {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void send(String message) {
        rabbitTemplate.convertAndSend("zhisheng", message);
    }
}

就这样，发送消息代码就实现了。

这里关键的代码为 rabbitTemplate.convertAndSend() 方法， zhisheng 这个是路由规则（routingKey），它的值表明将消息发送到指定的队列 zhisheng 中去，这里跟了下源码，发现 convertAndSend() 方法最后调用的方法其实是一个 doSend() 方法。

SpringBoot RabbitMQ 整合使用

4、消息接收类

package com.zhisheng.rabbitmq.server;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * Created by zhisheng_tian on 2018/1/23
 */
@Component
public class RabbitMQServer {

    @RabbitListener(queues = "zhisheng")
    public void receive(String message) {
        System.out.println("收到的 message 是：" + message);
    }
}

你看，这里就有个 RabbitListener 一直在监听着队列 zhisheng 。

当然这个队列是必须要我们自己在应用程序中创建好，它不会像我之前写的文章《SpringBoot Kafka 整合使用》中的 Kafka 一样，Kafka 它会在用到队列的时候动态的创建，不需要我们提前创建好。

那么在 RabbitMQ 中该如何创建队列呢？

SpringBoot RabbitMQ 整合使用

如上图所示：这样我们就创建好了一个 zhisheng 的队列，当程序开始运行时，消息接收类会持续监听队列 zhisheng 中即将到来的消息。

5、运行项目

需要在启动类中注入发送消息的类，并且提供 init 方法，在 init 方法中调用发送消息类的 send() 方法

@PostConstruct
public void init() {
	rabbitMQClient.send("发送消息----zhisheng-----");
}

需要注意的是：init() 方法带有 @PostConstruct 注解，被 @PostConstruct 修饰的方法会在构造函数之后执行。

启动项目就可以发现控制台已经接收到消息了。

SpringBoot RabbitMQ 整合使用

6、单线程测试性能

看到上面图片中注释掉的代码没？那就是用来测试消息发送的性能的，我发送 10000 条消息看看总共耗时多少。

SpringBoot RabbitMQ 整合使用

10000 条消息发送耗时：215ms。这是在单线程下，下次可以和其他的 MQ 测试对比下，并且也可以在多线程的环境下测试性能。

同时从控制台可以看到发送的速率：

SpringBoot RabbitMQ 整合使用

7、多线程测试性能

开了10 个线程，每个线程发送 10000 条消息。

init 方法代码如下：

@PostConstruct
    public void init() {
        StopWatch stopWatch = new StopWatch();
        stopWatch.start();

        int threads = 10;
        ExecutorService executorService = Executors.newFixedThreadPool(threads);

        final CountDownLatch start = new CountDownLatch(1);
        final CountDownLatch end = new CountDownLatch(threads);

        for (int i = 0; i < threads; i++) {
            executorService.execute(() -> {
                try {
                    start.await();
                    for (int i1 = 0; i1 < 10000; i1++) {
                        rabbitMQClient.send("发送消息----zhisheng-----");
                    }
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } finally {
                    end.countDown();
                }
            });
        }
        start.countDown();
        try {
            end.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            executorService.shutdown();
        }


        stopWatch.stop();
        System.out.println("发送消息耗时：" + stopWatch.getTotalTimeMillis());
    }

耗时：4063ms

控制台显示如下图：

SpringBoot RabbitMQ 整合使用

8、注意

这里测试发送的消息直接是 String 类型的，你也可以测试下 Bean 类，这需要注意需要序列化。

以上就是本文的全部内容，希望本文的内容对大家的学习或者工作能带来一定的帮助，也希望大家多多支持码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。

码农书籍

The Sovereign Individual

James Dale Davidson、William Rees-Mogg / Free Press / 1999-08-26 / USD 16.00

Two renowned investment advisors and authors of the bestseller The Great Reckoning bring to light both currents of disaster and the potential for prosperity and renewal in the face of radical changes ......一起来看看《The Sovereign Individual》这本书的介绍吧!

码农工具