spring boot整合rocketmq时候 报错
RocketMQ:closeChannel: close the connection to remote address[] result: true
不能消费topic的消息,是不是除了9876端口还需要开启其他端口;我是客户端,只需要访问就可以;本地
运行可以访问,发布到服务器不行了,服务器开启了9876端口防火墙,本地所有端口都开启了
@Service
@RocketMQMessageListener(topic = "RLT_TEST_TOPIC", selectorExpression = "tag2", consumerGroup = "Con_Group_Three")
public class Consumer implements RocketMQListener<MessageExt> {
@Override
public void onMessage(MessageExt messageExt) {
byte[] body = messageExt.getBody();
String msg = new String(body);
log.info("监听到消息:msg={}", msg);
}
}
RocketMQ:closeChannel: close the connection to remote address[] result: true
开启其他端口的防火墙吗?
消费topic的消息