使用Ping之前,需要先创建登录器对象,并且使用该登录器对象登录MQ服务器,ping远程服务器的时候,消息的出发节点是登录器对象登录的节点,目的节点是由pingRemoteHost方法的第二个参数指定路由名的节点。
//创建登录器对象,在创建对象时指定要登录的服务器的IP地址,端口号,用户名和密码
//注意:必须将“admin”作为用户名和并提供其密码,因为 AMQ 的管理功能目前
//限制只能由“admin”用户使用。
IMqLoginer loginer = new JaasLoginerImpl("localhost", 4888, "admin", "admin");
try {
loginer.login();
//ping远程服务器,得到消息往返远程服务器的时间,消息的出发节点是loginer登陆上的节点,
//目的节点是第二个参数指定的路由名的节点。
//得到的时间是消息从出发节点到目的节点然后再回到出发节点的时间。
//loginer为登陆的节点,为ping的出发节点。
//"Destination MQ Router Name"为ping的目的节点。
//120000为ping的超时时间,假如在超时时间内消息没有返回出发节点,则抛出超时异常。
long time = Ping.pingRemoteHost(loginer, "Destination MQ Router Name", 120000);
System.out.println(time);
...
} catch (LoginException e) {
//异常处理代码
} catch (JmsAdminException e) {
//异常处理代码
}
...