如何理解JMS中的“同步”和“异步”消息传递？

Question

阅读了JMS的一些文档后，我完全对短语synchronous和感到困惑asynchronouns。

参见本页：http :
//docs.oracle.com/cd/E19798-01/821-1841/bncdq/index.html

同步

您可以使用receive方法来同步使用一条消息。调用start方法后，您可以随时使用此方法：

connection.start();
Message m = consumer.receive();
connection.start();
Message m = consumer.receive(1000); // time out after a second

要异步使用消息，请使用消息侦听器，这将在下一节中介绍。

异步

JMS消息侦听器消息侦听器是一个对象，充当消息的异步事件处理程序。此对象实现MessageListener接口，其中包含一个方法onMessage。在onMessage方法中，您定义消息到达时要执行的操作。

您可以使用setMessageListener方法向特定的MessageConsumer注册消息侦听器。例如，如果定义一个实现了MessageListener接口的名为Listener的类，则可以按以下方式注册消息侦听器：

Listener myListener = new Listener();
consumer.setMessageListener(myListener);

我有两个问题：

1. 据我了解，JMS的本质是异步的。生产者将消息发布到队列/主题，不需要等待消费者。这是异步行为。怎么可能是“同步的”？

2. 如果“ mesageListener”是异步的，但是在对spring-jms的测试中，我发现它始终在线程中运行。这意味着，如果我写Thread.sleep(2000)在onMessage，它必须等待下一个处理消息之前2秒。它是“异步的”吗？

Answer 1

如果您这样更好地理解它，请consumer.receive()使用 拉 模型：您从队列中读取内容，并被阻止等待此消息，直到消息出现或超时为止。

使用侦听器使用 推 模型：注册一个侦听器，并在收到消息时在单独的线程中调用该侦听器。

一切都在Java线程中完成，并且侦听器调用也不例外。侦听器消息处理是否阻止队列中其他消息的处理，取决于有多少个线程专用于消息处理。如果将Spring配置为使用5个线程池来异步处理消息，则5个侦听器将能够并行处理消息。