JMS临时队列丢弃第一条消息

Question

我通过命名的JMS队列将JMS请求发送到Weblogic 10.3服务器，并通过临时队列接收回复。

客户（裸体）：

//init
Destination replyQueue = session.createTemporaryQueue();
replyConsumer = session.createConsumer(replyQueue);
...
//loop
TextMessage requestMessage = session.createTextMessage();
requestMessage.setText("Some request")
requestMessage.setJMSReplyTo(replyQueue);
requestProducer.send(requestMessage);
Message msg = replyConsumer.receive(5000);
if (msg instanceof TextMessage) {
    ...
} else { ... }
//loop end

服务器MDB（消息驱动bean）：

public void onMessage(Message msg) {
    if (msg instanceof TextMessage) {
        ...
        TextMessage replyMessage = jmsSession.createTextMessage();
        replyMessage.setText("Some response");
        replyMessage.setJMSCorrelationID(msg.getJMSCorrelationID());
        replyProducer.send(replyMessage);
    }
}

问题是第一个服务器回复经常丢失！也就是说，ReplyConsumer.receive（5000）每4-5个回复都以超时结束。当消费者收到第一个答案时，它将继续收到所有剩余的答案，所以问题只出在临时队列创建后通过临时队列发送的第一条消息上。

我的问题是：我是否必须为临时队列设置一些特殊的设置，以便它在创建后从一开始就工作？或者其他任何暗示？

更多信息：

• 在本地开发机器上测试时，临时队列没有问题。只有在群集的Weblogic服务器上测试时，消息才会丢失。但是，除了一个实例，我已经关闭了所有群集成员。
• 我已经验证了服务器成功回复了客户端发送的所有请求（通过计数发送的请求和发送的回复），服务器以毫秒的顺序回复，即使是丢失的回复。
• 当我用常规命名队列替换临时队列时，问题就消失了！所以问题似乎不在我的代码中。
• 我也尝试过修改回复消息的过期、持久、延迟等，但没有成功。这样我就排除了响应到达早于客户端开始读取队列的情况，然后消息立即过期，客户端没有机会处理它。
• 编辑：我也尝试过使用异步ReplyConsumer.setMessageListener（this），而不是同步onsumer.receive（5000）。行为没有改变，临时队列中的第一条消息仍然丢失。

编辑：我使用的Weblogic服务器（或集群）似乎有问题。因为当我将服务器应用程序部署到另一个Weblogic集群时，一切都开始正常工作了！这两个集群的配置应该相同——那么有什么不同呢？Weblogic没有发出错误信号，这让我很害怕。

Answer 1

您的问题似乎是，有时服务器正在接收发布，并在您的消费者开始接收之前将其丢弃。

绕过它的方法是使用异步接收（复制onsumer.setMessageListener）调用，而不是当前的阻塞调用（复制onsumer.receive（5000）），并将调用与其他消费者代码一起添加到代码中。

这样，在发出请求之前，您已经在监听回复了。

希望有帮助。

编辑：只是读到你正在使用一个临时队列，所以我的第一句话不正确。然而，作为一个实验，尝试我的其余反应，看看它是否会改变你所看到的行为