问题遇到的现象和发生背景
接入rocketmq5.0 jar服务放在与rocketmq放在一台服务器运行,但是一直报错,发送不了消息,查半天感觉没人遇到过这种错
用代码块功能插入代码,请勿粘贴截图
DefaultMQProducer producer = new DefaultMQProducer("DefaultGroup");
producer.setNamesrvAddr("192.168.5.2:9876");//121.36.155.171
producer.setVipChannelEnabled(false);
producer.setSendMsgTimeout(10000);
try {
producer.start();
} catch (Exception e) {
log.error("RocketmqConfig启动生产者出错!e:", e);
}
Message m = new Message("test", tag, body.getBytes(StandardCharsets.UTF_8));
try {
SendResult send = producer.send(m);
log.info("发送消息成功!!!!send:{}", send);
} catch (MQClientException | RemotingException | MQBrokerException | InterruptedException e) {
e.printStackTrace();
}