即使明确设置了名称服务器,RocketMQ 也会报告“没有名称服务器,请设置它”

问题描述

它发生在 Spring-Boot + dubbo 项目中。 一个模块出现这种异常,而其他模块运行良好。 这个异常也出现在测试用例中,但奇怪的是,下面的代码在 main 方法中应该没有任何问题地运行。 有没有人遇到过这样的问题,可以给我一些建议,非常感谢。

@Test
public void testNamesrv() throws MQClientException,RemotingException,InterruptedException,MQbrokerException {
    DefaultMQProducer producer = new DefaultMQProducer("test_producer");
    producer.setNamesrvAddr("127.0.0.1:9876");
    producer.start();
    Message testMessage = new Message("test_topic","testMessage".getBytes());
    SendResult send = producer.send(testMessage);//exception: no name server,please set it
    System.out.println(send);
}

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)