扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
在没有使用spring boot之前，我们的做法是在配置文件中定义一个任务池，然后将@Async注解的任务丢到任务池中去执行，那么在spring boot中，怎么来实现异步任务的调用了，方法更简单。
我们还是结合前面
spring boot整合JMS(ActiveMQ实现)
这篇博客里面的代码来实现。
一、功能说明
消费者在监听到队列里面的消息时，将接收消息的任务作为异步任务处理。
二、代码修改
消费者1：
package com.chhliu.springboot.jms;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
@Component
public class Consumer {
@JmsListener(destination = "mytest.queue")
@Async //该方法会异步执行，也就是说主线程会直接跳过该方法，而是使用线程池中的线程来执行该方法
public void receiveQueue(String text) {
System.out.println(Thread.currentThread().getName()+":Consumer收到的报文为:"+text);
}
} 
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
微信二维码
移动版官网