非同期通信を同期する

Question

データを受信し、非同期IBM MQ要求を介してデータをチェックするRESTサービスがあります。

RESTコントローラ：

@RestController 
@RequestMapping("/request") 
public class RequestController { 

    @RequestMapping(method = RequestMethod.POST) 
    public Response postRequest(@RequestBody Request request) { 

     String data = request.getData(); 

     jmsSender.send(data); 

     // Now I need the response from MQ 
     // String mqResponse = ... 
     if (mqIsValid(mqResponse)) { 
      return createValidResponse(); 
     } 
     return createNotValidResponse(); 
    } 
} 

MQ送信者：

@Service 
public class JmsSender { 

    public void send(String data) { 
     jmsTemplate.convertAndSend("QUEUE.TO.MQ", data); 
    } 

} 

MQ受信機：私は正しい応答を作成するためにMQから右のデータを待つことができますどのように

@Component 
public class JmsReceiver { 

    @JmsListener(destination = "QUEUE.FROM.MQ, containerFactory = "DefaultJmsListenerContainerFactory") 
    public void receiveMessage(String message) { 
     // How to pass the message to the controller? 
    } 

} 

コントローラー？

BlockingQueueをこのように使用することは可能ですか？here？私の場合は、データを区別する必要があります。私はブロッキングキューから最初のデータを取ることはできません。

たとえば、2つのREST要求（データ：abcおよびxyz）が同時に存在する場合。 MQから得た最初の答えだけでなく、正しい答えに確実に答えることができますか？

また、MQインターフェイスを変更することもできません。

Answer 1

私は適切な解決策を見つけることができなかったので、データを取得するための簡単な待機メカニズムを作成しました。

MqReceiver：

@Component 
public class JmsReceiver { 

    private final Lock lock; 
    private final Condition containsKey; 
    private final Map<String, String> responses; 

    public JmsReceiver() { 
     this.lock = new ReentrantLock(); 
     this.containsKey = lock.newCondition(); 
     this.responses = new HashMap<>(); 
    } 

    @JmsListener(destination = "QUEUE.FROM.MQ", containerFactory = "DefaultJmsListenerContainerFactory") 
    public void receiveMessage(String message) { 
     put(getKeyFromMessage(message), message); 
    } 

    public String get(String key) throws InterruptedException { 
     lock.lock(); 
     try { 
      while (!responses.containsKey(key)) { 
       containsKey.await(); 
      } 
      return responses.get(key); 
     } finally { 
      lock.unlock(); 
     } 
    } 

    public void put(String key, String messagee) { 
     lock.lock(); 
     try { 
      responses.put(key, messagee); 
      containsKey.signalAll(); 
     } finally { 
      lock.unlock(); 
     } 
    } 

} 

これは、コントローラで使用することができます：

@RestController 
@RequestMapping("/request") 
public class RequestController { 

    @RequestMapping(method = RequestMethod.POST) 
    public Response postRequest(@RequestBody Request request) { 

     String data = request.getData(); 

     jmsSender.send(data); 

     String key = getKeyFromData(data); 
     // waits until MQ sends the data 
     String mqResponse = jmsReceiver.get(key); 

     if (mqIsValid(mqResponse)) { 
      return createValidResponse(); 
     } 
     return createNotValidResponse(); 
    } 
} 

Answer 2

以下のようにCountDownLatchを試してみてください。

@RestController 
@RequestMapping("/request") 
public class RequestController { 

    @RequestMapping(method = RequestMethod.POST) 
    public Response postRequest(@RequestBody Request request) { 
     final CountDownLatch jmsLatch = new CountDownLatch (1); 

     String data = request.getData(); 

     jmsSender.send(data, jmsLatch); 

     try { 
      latch.await(); // wait untill latch counted down to 0 
     } catch (InterruptedException e) { 
      return createNotValidResponse(); 
     } 

     return createValidResponse(); 
    } 
} 

コントローラからCountDownLatchを取得するためにsendメソッドを変更します。

@Service 
public class JmsSender { 

    public void send(String data, final CountDownLatch jmsLatch) { 
     jmsLatch.await(); 
     jmsTemplate.convertAndSend("QUEUE.TO.MQ", data); 
    } 

} 

受信メソッドを変更して、同じCountDownLatchをコントローラから取得します。

@Component 
public class JmsReceiver { 

    @JmsListener(destination = "QUEUE.FROM.MQ", containerFactory = "DefaultJmsListenerContainerFactory") 
    public void receiveMessage(String message, final CountDownLatch jmsLatch) { 
     // Pass the message to the controller 
     jmsLatch.countDown(); 
    } 

} 

ここのトリックは、あなたが送信者と受信者のクラスに、コントローラから同じたCountDownLatchインスタンスを広げて、あなたがメッセージを受信した後、カウントダウンメソッドを呼び出す必要があります。