使用选择器从队列读取jms消息

Question

我有一个java客户机，它在队列中发送jms消息（“队列请求”）。该消息包含一个int属性（“id”），其中包含唯一的客户端id号。消息正在处理中，然后进入另一个队列（“队列响应”）。如何让客户机等到具有其id的消息在队列中，然后读取它。我曾尝试使用侦听器并实现onMessage，但当收到消息时，我如何停止侦听？

Answer 1

在JMS中，您需要为队列指定侦听器，以便在发送消息时，选择特定的侦听器来接收消息。在Spring中，您可以在bean配置文件中指定侦听器，例如：

<bean id="myListener" class="mypackage.MyMessageListener" />

<bean id="queueBean" class="org.apache.activemq.command.ActiveMQTopic">
    <constructor-arg value="Queue-Request"/>
</bean>

<bean id="myListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    <property name="connectionFactory" ref="connectionFactoryBean" />
    <property name="destination" ref="queueBean" />
    <property name="messageListener" ref="myListener" />
</bean>

然后您可以编写类MyMessageListener来实现MessageListener接口：

public class MyMessageListener implements MessageListener {
    public void onMessage(Message message) {
        //handle message here ...
    }   
}

这将确保MyMessageListener将从队列中获取发送的消息。请注意，队列是p2p的，因此如果消息是由MyMessageListener接收的，则不订阅此队列的其他侦听器将不会接收该消息。

Answer 2

可以使用JMSReplyTo来实现JMS同步。在发送相同会话的原始消息时创建临时队列。开始监听临时队列，并将原始消息JMSReplyTo设置为TmpQueue。

使用临时队列接收器。receive（）使线程等待（同步）

完整的示例代码可以在中找到

http://jmsexample.zcage.com/