我应该如何测试连接是否可用?

我想在程序开始时确定MQ服务是否正常工作。

我构造了一个错误地址消息,并调用了start()方法,但没有抛出异常,也没有任何提示。一切似乎都很好。

import org.apache.rocketmq.client.exception.MQClientException; import org.apache.rocketmq.client.producer.DefaultMQProducer;

public class MQTest {

public static void main(String[] args) throws MQClientException {
	
	DefaultMQProducer producer = new DefaultMQProducer("default");
	producer.setNamesrvAddr("undefinde:-1");
	
	producer.start();		
	
}

}

我也没有找到任何其他方法,比如ping()、createConn()。

当前的解决方案是尝试向不存在的Topic发送消息,然后根据异常消息确定服务是否可用。

但这似乎还不够优雅,有好的解决方案吗?

原提问者GitHub用户KevinBlandy

展开
收起
芬奇福贵 2023-05-26 10:50:38 113 分享 版权
1 条回答
写回答
取消 提交回答
  • 您可以在dir~/logs/rocketmqlogs/rocketmq_client.log中查看客户端日志

    原回答者GitHub用户maixiaohai

    2023-05-26 17:15:12
    赞同 展开评论
问答分类:
问答标签:
问答地址:

阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践,通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式,助力制造业企业高效上云,实现系统稳定、应用敏捷智能。拥抱云原生,让创新无处不在。

还有其他疑问?
咨询AI助理