在没有使用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); } }
分享名称:springboot异步(Async)任务调度实现方法-创新互联
路径分享:https://www.cdcxhl.com/article4/ddsjie.html
成都网站建设公司_创新互联,为您提供营销型网站建设、移动网站建设、品牌网站建设、品牌网站设计、服务器托管、Google
声明:本网站发布的内容(图片、视频和文字)以用户投稿、用户转载内容为主,如果涉及侵权请尽快告知,我们将会在第一时间删除。文章观点不代表本网站立场,如需处理请联系客服。电话:028-86922220;邮箱:631063699@qq.com。内容未经允许不得转载,或转载时需注明来源: 创新互联