使用rabbitmq实现异步解耦
使用步骤：
1、pom依赖
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId>
</dependency>2、yml配置文件
spring:rabbitmq:host: 127.0.0.1port: 5672username: guestpassword: guestvirtual-host: /3、发送消息
/** 测试rabbitmq的使用* */
@Autowired
private RabbitTemplate rabbitTemplate;@RequestMapping("/send")
public boolean send(String message) {//现在我要阻塞5000ms/5秒钟// 如果代码写在控制层此时执行结果是5020毫秒 把一些耗时操作放在监听者中 异步解耦，接口可以先返回数据，避免接口响应时间过长try {Thread.sleep(5000);} catch (InterruptedException e) {throw new RuntimeException(e);}// 队列名称（一定要记得创建队列simple.queue 在FanoutConfig.class中）String queueName = "simple.queue";// 消息// 发送消息rabbitTemplate.convertAndSend(queueName, message);return true;
}4、接受消息
package cn.xue.user.controller;import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Component
public class SpringRabbitListener {@RabbitListener(queues = "simple.queue")public void listenSimpleQueueMessage(String msg) {//如果把一些耗时操作放到这里 rabbitmq会异步执行
// try {
// Thread.sleep(5000);
// } catch (InterruptedException e) {
// throw new RuntimeException(e);
// }System.out.println("spring 消费者接收到消息：【" + msg + "】");}}5、创建队列，必须有这个配置类，否则会报错
package cn.xue.user.controller;import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/*
* 创建队列
* */
@Configuration
public class FanoutConfig {/*** 创建第1个队列 simple.queue*/@Beanpublic Queue fanoutQueue1(){return new Queue("simple.queue");}}结论
上面的 Thread.sleep(5000); 是为了模拟耗时操作
如果把 Thread.sleep(5000);写在send中，请看执行时长（5474ms）
如果把 Thread.sleep(5000);写在监听者中，请看执行时长（130ms）
这样的话即实现了异步执行，也会减少代码之间的耦合度