十年网站开发经验 + 多家企业客户 + 靠谱的建站团队
量身定制 + 运营维护+专业推广+无忧售后,网站问题一站解决
在没有使用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);
}
}