springboot通过消息队列异步通信
前端时间公司项目的一个新需求，需要编写一个独立的程序，收到请求时做一些逻辑判断之后如果逻辑通过则通知主服务做相应的处理，于是我选择使用mq实现这一通信。通过消息队列中间件，我们可以轻松实现微服务直接通信的解耦。废话不多说，先码个简单的示例。
1、通过docker启动一个rabbitmq服务
若没有安装docker环境，请先安装docker和docker-compose，可以参考我之前的博客进行安装。
建立mq工作目录mkdir -p /data/docker/mq-demo
建立编排文件docker-compose.yml方便管理 （传送门）
mq:
image: daocloud.io/rabbitmq:3-management
net: host
environment:
- RABBITMQ_DEFAULT_USER=demo
- RABBITMQ_DEFAULT_PASS=mypassword
restart: always
执行启动命令docker-compose up -d
然后打开浏览器访问http://你的虚拟机ip:15672 ，使用demo:mypassword登录
管理界面首页如图
rabbitmq监听的端口
到这里我们的mq服务就已经搭建好了
2、建立消息生产者项目
启动idea，通过Spring Initializr建立一个Spring Boot项目。
勾选web和rabbitmq依赖
创建好项目之后，pom文件内容如下
<?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>xyz.itmx.mq.demo</groupId>
<artifactId>mq-demo</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>mq-demo</name>
<description>Demo project for Spring Boot</description>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.2.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-amqp</artifactId>
</dependency>
<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>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
所以如果你想在现有项目中使用mq，只需加入上图标红的依赖即可
修改配置文件，配置mq的地址
server.port=8081
spring.rabbitmq.host=192.168.199.254
spring.rabbitmq.port=5672
spring.rabbitmq.username=demo
spring.rabbitmq.password=mypassword
创建一个队列
package xyz.itmx.mq.demo.mqdemo.config;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* Created by itmx on 2018/6/13.
*/
@Configuration public class MQConfig {
private final static String MY_DEMO_QUEUE = "MY_DEMO_QUEUE";
@Bean public Queue Queue() {
return new Queue(MY_DEMO_QUEUE);
}
}
再创建一个控制器
package xyz.itmx.mq.demo.mqdemo.controller;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import xyz.itmx.mq.demo.mqdemo.config.MQConfig;
/**
* Created by itmx on 2018/6/13.
*/
@RestController
public class IndexController {
@Autowired
private AmqpTemplate rabbitTemplate;
@GetMapping("/send")
public String send(String msg){
if(StringUtils.isEmpty(msg)){
return "msg参数不可为空！";
}
rabbitTemplate.convertAndSend(MQConfig.MY_DEMO_QUEUE,msg);
return "OK，Now " + System.currentTimeMillis();
}
}
接下来我们运行这个springboot项目，在浏览器访问：http://localhost:8081/send?msg=are you ok?
然后回到mq管理页面，在队列选项卡中可以看到有一个名叫 MY_DEMO_QUEUE 的队列有一条消息没有被消费掉。接下来我们创建另一个项目去消费这一条消息。
3、创建消息消费者项目
同样的启动idea，通过Spring Initializr建立一个Spring Boot项目。
创建过程与上步骤一致。
配置文件如下
server.port=8082
spring.rabbitmq.host=192.168.199.254
spring.rabbitmq.port=5672
spring.rabbitmq.username=demo
spring.rabbitmq.password=mypassword
只改了tomcat端口
同样创建一个队列，队列名字与上一个项目一致
package xyz.itmx.mq.demo.mqdemo.config;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* Created by itmx on 2018/6/13.
*/
@Configuration
public class MQConfig {
public final static String MY_DEMO_QUEUE = "MY_DEMO_QUEUE";
@Bean public Queue Queue() { return new Queue(MY_DEMO_QUEUE);
}
}
接下来创建一个消费者
package xyz.itmx.mq.demo.mqdemo.receiver;
import org.slf4j.Logger; import org.slf4j.LoggerFactory;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
import xyz.itmx.mq.demo.mqdemo.config.MQConfig;
/**
* Created by itmx on 2018/6/13.
*/
@Component
@RabbitListener(queues = MQConfig.MY_DEMO_QUEUE)
public class DemoReceiver {
private Logger logger = LoggerFactory.getLogger(getClass());
@RabbitHandler public void process(String msg) {
logger.info("收到消息：{}",msg);
}
}
启动本项目，可以在控制台中看到刚刚发送的消息，继续在浏览器发送消息，控制台可以持续接收到消息
到此，一个简单的mq使用就结束了。
4、更多使用技巧
本来想自己码一份加深印象的，但是
从截图中可以看出，我现在的时间不早了，敬请请前往