Spring JMS模板 - 併發調用

Question

我可以使用Spring JMSTemplate進行併發呼叫嗎？

我想同時進行4個外部服務調用，並且正在探索使用Spring的JMSTemplate來並行執行這些調用並等待執行完成。

我正在看的其他選項是使用ExecutorService。

使用其中一個有什麼優勢嗎？

Answer 1

JMSTemplate是線程安全的，因此對其進行並行調用並不是問題。

消息傳遞服務對於大多數任務來說通常足夠快，並且可以以最小的延遲接收消息，所以添加ExecutorService似乎不是您通常需要的第一件事。你真正需要的是正確配置你的JMS連接池並給它足夠的開放連接（在你的情況下有四個連接），以便它可以處理你的並行請求而不會阻塞。

您只需要ExecutorService以防萬一您不關心保證交付，並且您的程序需要極高的速度讓您的消息傳遞服務無法提供，這是極不可能的。

至於從您的外部服務接收回復，您需要使用JMS Request/Reply pattern（您可以在本文中找到示例）。令人高興的是，當你使用Spring時，你可以讓Spring Integration爲你做很多工作。您需要配置outbound-gateway才能發送消息，並需要配置inbound-gateway才能接收響應。從版本2.2開始，您還可以使用reply-listener來簡化客戶端的操作。所有這些組件都包含在the official documentation中（也有示例）。

Answer 2

因此需要使用異步方法與兩個以上的JMS隊列（發送和/或接收）並行通信。最好的選擇是方法級別的usng @Asynch

本示例包含RestTemplate，但在您的情況下創建JmsTemplate bean。

先決條件： - 請創建適當的JMS Bean以連接隊列。正確使用這將有助於調用兩個隊列paralleley。它的作品是肯定的，因爲我已經實施了。由於版權問題，我只是給了骨架。

更多細節：春引導+彈簧非同步 https://spring.io/guides/gs/async-method/

第一步：創建服務類，其中JMS隊列

@EnableAsynch
公共類JMSApplication {

@Autowired 
JmsService jmsService; 

    public void invokeMe(){ 
     // Start the clock 
     long start = System.currentTimeMillis(); 

     // Kick of multiple, asynchronous lookups 
     Future<Object> queue1= jmsService.findqueue1(); 
     Future<Object> queue2= jmsService.findqueue2(); 

     // Wait until they are all done 
     while (!(queue1.isDone() && queue2.isDone())) { 
      Thread.sleep(10); //10-millisecond pause between each check 
     } 

     // Print results, including elapsed time 
     System.out.println("Elapsed time: " + (System.currentTimeMillis() - start)); 
     System.out.println(queue1.get()); 
     System.out.println(queue2.get()); 

    } 
} 

第二步：編寫將包含業務邏輯01的服務方法爲JMS

@Service 
    public Class JmsService{ 

     @Asynch 
     public Object findqueue1(){ 
     //Logic to invoke the JMS queue 
     } 

     @Asynch 
     public Object findqueue2(){ 
     //Logic to invoke the JMS queue 
     } 
    }