通过损坏的网络发送 JMS 消息

Question

我正在使用 ActiveMQ 执行一些简单的测试，以了解它在不稳定网络上的表现。第一个测试包括将消息发送到远程队列的生产者。该消息是 ObjectMessage 类型，其中包含可序列化的内容（对象列表）。

在良好的网络下，一切正常，但是当我启动相同的测试 using netem 以模拟包裹丢失、延迟和损坏时，在尝试提取消息内容时使用消息时出现以下错误：

2011-03-16 11:59:21,791 错误 [com.my.MessageConsumer] 无法从字节构建正文。原因：java.io.StreamCorruptedException：无效句柄值：017E0007 javax.jms.JMSException：无法从字节构建正文。原因：java.io.StreamCorruptedException：无效句柄值：017E0007

因此，似乎消息在发送到远程队列时已损坏，但无论如何都已存储，只有在消费时，消费者才会看到消息已损坏。

之后我将使用本地队列和网络连接器将消息转发到远程队列，我希望它能解决问题，但令我惊讶的是生产者和生产者之间没有任何形式的验证保证正确交付的目的地（至少是校验和或类似的东西），我做错了什么还是正常行为？

我这里现在没有代码，但是超级简单，就是一个 MessageListener：

公共类 myMessageConsumer 实现 MessageListener{ public void onMessage(消息消息){ 尝试 { 如果（消息实例对象消息）{ ObjectMessage myMessage = (ObjectMessage) 消息； 列表 dtoList = (List) myMessage.getObject(); } } 捕捉（异常前）{ ex.printStackTrace(); } } }

如果需要确切的代码，我会在假期回来时提供，但就是这样。

Answer 1

代理不会验证它处理的每条消息的内容，这将极大地浪费时间并显着减慢消息发送速度。客户端收到错误消息并抛出 JMSException 以指示消息内容已损坏，这足以让您的应用正确响应。

Answer 2

你的代码在哪里？

如果该异常来自您的代码，那么您可能遇到了错误。例如，接收到消息时出现一些 JMS 错误，但会弄乱错误处理并尝试处理结果。对于您描述的测试，您需要重点关注客户端的错误处理。

我没有使用 ActiveMQ 的经验，但它允许损坏的消息传递似乎非常令人惊讶。并不是说我希望 JMS 实现解包 ObjectMessage 以进行检查。只是它应该提供已发送内容的逐字节未损坏副本。否则就报错。