返回顶部
  • 发帖数18
  • 粉丝3

文字是我们记忆时代的最后力量。巴比特媒介,申请专栏请投稿chic@8btc.com,WeChat:archie2,欢迎和我分享你对区块链的一切想法。

  • 最佳新人

    注册账号后积极发帖的会员
  • 活跃会员

    经常参与各类话题的讨论,发帖内容较有主见
  • 热心会员

    经常帮助其他会员答疑
  • 推广达人

    积极宣传本站,为本站带来更多注册会员

[数字资产] 关于SpringBoot使用Roocketmq报错No route info of this topic

  [复制链接]
币圈王 显示全部楼层 发表于 2020-8-13 11:05:28 |阅读模式 打印 上一主题 下一主题
56
已解决

关于SpringBoot使用Roocketmq报错No route info of this topic

  • 币圈王
  • 版主
  • 2020-08-13 11:05:28
  • 发布在 问答/互助
1711 1
一次使用Roocketmq,我的程序放在本机上,Roocketmq放在阿里云的一台服务器上,我在主配置文件中配置了服务器公网ip和Roocketmq的topic,名为stock。但是在使用时出现错误:


  1. org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, stock
复制代码


服务器的Roocketmq是4.3.2,程序的Roocketmq是4.3.0版本,SpringBoot版本2.0.5
我开启Rocketmq的命令如下:
(1)开启NameServer
  1. sh bin/mqnamesrv &
  2. The Name Server boot success. serializeType=JSON
复制代码

(2)开启mqbroker

  1. nohup sh mqbroker -n localhost:9876 autoCreateTopicEnable=true &
  2. #查看日志
  3. tail -f ~/logs/rocketmqlogs/broker.log
  4. #日志显示结果:
  5. 2020-08-11 00:08:41 INFO brokerOutApi_thread_4 - register broker to name server localhost:9876 OK
  6. 2020-08-11 00:09:11 INFO brokerOutApi_thread_1 - register broker to name server localhost:9876 OK
  7. 2020-08-11 00:09:41 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
  8. 2020-08-11 00:09:41 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 179890 bytes
  9. 2020-08-11 00:09:41 INFO brokerOutApi_thread_2 - register broker to name server localhost:9876 OK
  10. 2020-08-11 00:10:11 INFO brokerOutApi_thread_3 - register broker to name server localhost:9876 OK
  11. 2020-08-11 00:10:41 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
  12. 2020-08-11 00:10:41 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 179890 bytes
  13. 2020-08-11 00:10:41 INFO brokerOutApi_thread_4 - register broker to name server localhost:9876 OK
  14. 2020-08-11 00:11:11 INFO brokerOutApi_thread_1 - register broker to name server localhost:9876 OK
复制代码

(3)通过下面命令查看发现存在名为stock的topic
  1. sh mqadmin topicList -n localhost:9876
复制代码

我在网上找到了同样的问题,
有的是说要查看防火墙,但我的防火墙是关闭的:
  1. systemctl stop firewalld.service
  2. Failed to stop firewalld.service: Unit firewalld.service not loaded.
复制代码

有的说是要导入fastjson-1.2.29.jar,我也导入了。
我发现使用命令
  1. sh mqadmin clusterList -n localhost:9876
复制代码

显示出来的DefaultCluster的Addr字段是服务器的私网ip,不知道这是否是正确的?
想请教各位怎么解决?

最佳答案

admin管理员 关注Ta

2020-08-13 11:05:29

给的信息不够全哈。比如你的 rocketmq 配置到底是怎么样的。 根据作者提供的现有代码。以下是我的推测。 broker 默认的端口是 10911. 请确认。阿里云开放的端口配置 是否有放开 10911 端口。 客户端是先从 namesrv 获取 broker 的地址。之后,都是直接跟 broker 通信的。所以放开 9876 还不够!
查看完整内容
回复

使用道具 举报

精彩评论1

admin 显示全部楼层 发表于 2020-8-13 11:05:29
给的信息不够全哈。比如你的 rocketmq 配置到底是怎么样的。

根据作者提供的现有代码。以下是我的推测。

broker 默认的端口是 10911. 请确认。阿里云开放的端口配置 是否有放开 10911 端口。
客户端是先从 namesrv 获取 broker 的地址。之后,都是直接跟 broker 通信的。所以放开 9876 还不够!
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

星点互联 成立于2014年8月,是目前国内优秀的开源技术社区,拥有超过300万会员,形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容,为IT开发者提供了一个发现、使用、并交流开源技术的平台。
  • 官方手机版

  • 微信公众号

  • 商务合作