我正在使用 IBM MQ-7.5。我正在运行一个 jms 客户端，它连接到在其他一些主机上运行的管理器。
我想监控与管理器的 TCP 连接。如果我的客户端与经理的连接中断，我如何获得通知？ IBM MQ API 中是否提供了任何回调或侦听器以了解任何连接中断？
例如。像 ActiveMQ 有http://activemq.apache.org/maven/apidocs/org/apache/activemq/transport/TransportListener.html
谢谢，
阿努杰
【问题讨论】：
对于被丢弃的连接，将通过异常侦听器发送连接中断异常。
JMS 规范的编写使得连接中断等事件仅在同步调用时合法返回。我还建议设置一个异常侦听器，并从所有消息传递操作中捕获异常并采取适当的措施。
【讨论】：
您想在队列管理器端还是在客户端应用程序中监视客户端应用程序连接？
为了获得任何连接问题的通知，MQ JMS 客户端有一个ExceptionListener，可以附加到MQConnection。当与队列管理器的连接出现问题时，将调用此异常侦听器，例如与队列管理器的连接中断。更多详细信息here：查看setExceptionListener 方法的详细信息。调用MQConnection上的setExceptionListener方法注册回调，如下图。
MQQueueConnectionFactory cf = new MQQueueConnectionFactory();
ExceptionListener exceptionListener = new ExceptionListener(){
@Override
public void onException(JMSException e) {
System.out.println(e);
if(e.getLinkedException() != null)
System.out.println(e.getLinkedException());
}
};
MQQueueConnection connection = (MQQueueConnection) cf.createQueueConnection();
connection.setExceptionListener(exceptionListener);
【讨论】：
为了主动检查连接和会话的健康状况，我正在考虑使用以下方法。
/**
* Method to check if connection is healthy or not.
* It creates a session and close it. mqQueueConnection
* is the connection for which we want to check the health.
*/
protected boolean isConnectionHealthy()
{
try {
Session session = mqQueueConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
session.close();
}
catch(JMSException e) {
LOG.warn("Exception occured while checking health of connection. Not able to create " + "new session" + e.getMessage(), e);
return false;
}
return true;
}
/**
* Method to check if session is healthy or not.
* It creates a consumer and close it. mqQueueSession
* is the session for which we want to check the health.
*/
protected boolean isSessionHealthy()
{
try {
MessageConsumer consumer = mqQueueSession.createConsumer(mqQueue);
consumer.close();
}
catch(JMSException e) {
LOG.warn("Exception occured while checking health of the session. Not able to create "
+ "new consumer" + e.getMessage(), e);
return false;
}
return true;
}
它的方法看起来不错吗？
我在这里只有一个恐惧： 我正在 isConnectionhealthy() 方法中创建一个测试会话并关闭它。它不会影响实际用于实际通信的已创建会话吗？我的意思是它会做类似关闭已经创建的会话并开始新的会话吗？
【讨论】：