前言

在我前面的部落格中，多處使用了@Async來實現非同步任務排程，具體請參考部落格：

在沒有使用spring boot之前，我們的做法是在配置檔案中定義一個任務池，然後將@Async註解的任務丟到任務池中去執行，那麼在spring boot中，怎麼來實現非同步任務的呼叫了，方法更簡單。

我們還是結合前面

這篇部落格裡面的程式碼來實現。

一、功能說明

消費者在監聽到佇列裡面的訊息時，將接收訊息的任務作為非同步任務處理。

二、程式碼修改

消費者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);
	}
}
 

消費者2：

package com.chhliu.springboot.jms;

import org.springframework.jms.annotation.JmsListener;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Component;

@Component
public class Consumer2 {

	@JmsListener(destination = "mytest.queue")
	@SendTo("out.queue")
	public String receiveQueue(String text) {
		System.out.println(Thread.currentThread().getName()+":Consumer2收到的報文為:"+text);
		return "return message"+text;
	}
}
 

在測試類上新增如下註解：

package com.chhliu.springboot.jms;

import javax.jms.Destination;

import org.apache.activemq.command.ActiveMQQueue;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
@EnableAsync // 開啟非同步任務支援
public class SpringbootJmsApplicationTests {
	
	@Autowired
	private Producer producer;
	
	@Test
	public void contextLoads() throws InterruptedException {
		Destination destination = new ActiveMQQueue("mytest.queue");
		
		for(int i=0; i<100; i++){
			producer.sendMessage(destination, "myname is chhliu!!!");
		}
	}

}
 

三、測試結果

DefaultMessageListenerContainer-1:Consumer2收到的報文為:myname is chhliu!!!
從out.queue佇列收到的回覆報文為:return messagemyname is chhliu!!!
SimpleAsyncTaskExecutor-45:Consumer收到的報文為:myname is chhliu!!!
DefaultMessageListenerContainer-1:Consumer2收到的報文為:myname is chhliu!!!
從out.queue佇列收到的回覆報文為:return messagemyname is chhliu!!!
SimpleAsyncTaskExecutor-46:Consumer收到的報文為:myname is chhliu!!!
DefaultMessageListenerContainer-1:Consumer2收到的報文為:myname is chhliu!!!
從out.queue佇列收到的回覆報文為:return messagemyname is chhliu!!!
SimpleAsyncTaskExecutor-47:Consumer收到的報文為:myname is chhliu!!!
DefaultMessageListenerContainer-1:Consumer2收到的報文為:myname is chhliu!!!
從out.queue佇列收到的回覆報文為:return messagemyname is chhliu!!!
SimpleAsyncTaskExecutor-48:Consumer收到的報文為:myname is chhliu!!!
DefaultMessageListenerContainer-1:Consumer2收到的報文為:myname is chhliu!!!
從out.queue佇列收到的回覆報文為:return messagemyname is chhliu!!!
SimpleAsyncTaskExecutor-49:Consumer收到的報文為:myname is chhliu!!!
DefaultMessageListenerContainer-1:Consumer2收到的報文為:myname is chhliu!!!
從out.queue佇列收到的回覆報文為:return messagemyname is chhliu!!!
SimpleAsyncTaskExecutor-50:Consumer收到的報文為:myname is chhliu!!!
DefaultMessageListenerContainer-1:Consumer2收到的報文為:myname is chhliu!!!

從上面的測試結果可以看出，由於消費者2沒有使用非同步任務方式，所以消費者2消費訊息都是由固定的執行緒DefaultMessageListenerContainer-1這個執行緒來處理的，而消費者1由於使用了非同步任務的方式，每次處理接收到的訊息都是由不同的執行緒來處理的，當接收到訊息時，直接將任務丟到任務池中去處理，而主執行緒則繼續跑，從測試結果中還可以推斷出，spring boot預設使用了newCachedThreadPool執行緒池來實現。

四、非同步任務有返回

在實際的開發中，我們會經常遇到非同步任務有返回的情況，那麼在spring boot中，怎麼來實現了？

下面以非同步發郵件為例，來進行說明，示例程式碼如下：

@Async("taskExecutePool") // 非同步任務會提交到taskExecutePool任務池中執行
	public Future<Response> doSendEmail(MailInfo mailInfo) {// 非同步任務返回，使用Future<Response>來非同步返回
		log.info(Thread.currentThread().getName()+"呼叫了doSendEmail非同步方法!");
		SendMailSession session = null;
		Response res = new Response();
		boolean isOK = sendEmail(mailInfo);// 具體發郵件的方法
    if(isOK){        
        res.setSuccess(true);    
    }else{
        res.setSuccess(false);
    }
 return new AsyncResult<Response>(res);

返回之後怎麼使用？示例程式碼如下：

Future<Response> result = taskJob.doSendEmail(mailInfo);
			res = result.get(6, TimeUnit.SECONDS);

這樣就可以獲取到非同步任務的返回了！