在以下代码片段中:
Connection connection=getConnection();
try {
Session session=connection.createSession();
try {
Queue queue=session.createQueue("foobar");
MessageConsumer consumer=null;
try {
consumer = session.createConsumer(queue);
}
catch(JMSException e) {
// Under what circumstances does this happen?
}
try {
// ...
}
finally {
if(consumer != null) consumer.close();
}
}
finally {
session.close();
}
}
finally {
connection.close();
}
什么情况下会抛出捕获的JMSException
?当发生这种情况时,处理 JMSException 的正确方法是什么?我已经阅读了 JMS 和 ActiveMQ 文档的相关部分,但它似乎没有在这一点上提供任何指导(显然,除了使用 try
/catch
)。还请原谅做作的代码示例!
例如,如果session
以某种方式“变坏”,是否会发生JMSException
,因此拆除consumer
是正确的事情> 和 session
并重新开始?或者这是否意味着连接
已经坏了,所以我应该拆除并重建应用程序中基于该连接的所有内容?或者,对 createConsumer()
的调用是否会暂时失败,而使用同一 session 重试该调用可能会成功?
类似地,这些行何时会抛出 JMSException
,忽略诸如关闭的 Session
或 Connection
之类的内容:
Message message=consumer.receive();
producer.send(message);
我想了解一般情况下应如何在 JMS 中处理 JMSException
,但特定于 ActiveMQ 的答案也很好。 (事实上,任何答案都可能必须特定于特定的实现,因为 JMS 只是一个规范。)
最佳答案
抛出异常的原因有多种。最常见的是由于网络或代理故障而导致连接丢失。其他原因可能是代理资源耗尽、安全违规等。
为了避免网络连接问题引起的异常,您可以使用 ActiveMQ 的故障转移传输让客户端自动重新连接。 JMS 中有许多异常类型,因此您可以测试给定的错误,例如检查消费者创建或生产者发送是否由于安全异常而失败。如果您不知道实际原因,那么最常见的做法就是拆除并重建连接资源。这就是为什么使用故障转移更好,因为您可以通过让客户端处理检测和响应来避免大量工作。
关于java - 使用 JMS(特别是 ActiveMQ)时处理 JMSException?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/20955117/