qq_40784183 2022-01-19 15:00 采纳率: 0%
浏览 48

spring boot整合rocketmq时候 报错

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的消息

  • 写回答

1条回答 默认 最新

  • IT不码农 2022-01-19 15:25
    关注

    rocketmq 的地址配对了吗,我看错误信息了没打出来呀,是不是没配置上

    评论

报告相同问题?

问题事件

  • 创建了问题 1月19日

悬赏问题

  • ¥15 fastreport怎么判断当前页数
  • ¥15 Kylin-Desktop-V10-GFB-Release-JICAI_02- 2207-Build14-ARM64.iso有没有这个版本的系统啊
  • ¥15 能不能通过蓝牙将传感器数据传送到手机上
  • ¥20 100元python和数据科学实验项目
  • ¥15 根据时间在调用出列表
  • ¥15 R 包chipseeker 安装失败
  • ¥15 Veeam Backup & Replication 9.5 还原问题
  • ¥15 vue-print-nb
  • ¥15 winfrom的datagridview下拉框变成了黑色,渲染不成功
  • ¥20 利用ntfy实现短信推送