开发者社区 > 云原生 > 消息队列 > 正文

RocketMQ中golang sdk 示例起动不了,服务端报错这个怎么解决?

rocketmq5.0 客户端是golang,Apache RocketMQ中golang sdk 示例起动不了,服务端报错这个怎么解决?使用默认命令启动了传输加密怎么关闭?外网访问使用RocketMQ-Dashboard可以连上,golangSDK无法连上?
nohup sh bin/mqnamesrv -c &
nohup sh bin/mqbroker -n
a83123949fd11514e0b63f4ca28ce66c.png
sdk为github.com/apache/rocketmq-clients/golang/v5
a4b7244dad438c1980a10f1e83244bb7.png
客户端显示超时。

展开
收起
十一0204 2023-07-19 13:24:28 173 0
2 条回答
写回答
取消 提交回答
  • 如果您在使用RocketMQ 5.0的Golang客户端时遇到问题,以下是可能解决方案:

    1. Golang SDK示例无法启动:

      • 确保您已经按照官方文档正确安装和配置了RocketMQ Golang SDK,并且将相关依赖项正确导入到您的项目中。
      • 检查示例代码中的配置参数是否正确设置。特别是注意检查NameServer地址、Topic名称等参数的准确性。
      • 查看客户端日志以获取更多的错误信息,帮助定位问题并解决。
    2. 关闭传输加密:

      • 在RocketMQ 5.0及以上版本中,默认启用了传输加密功能。如果您希望关闭传输加密,可以通过修改Broker的配置文件来实现。在broker.conf配置文件中找到isSecurityEnabled=true一行,将其改为isSecurityEnabled=false,然后重启Broker服务即可。
    3. Golang SDK无法连接到外网访问的RocketMQ Dashboard:

      • 确保您的网络环境允许Golang SDK与外网的RocketMQ Broker进行通信。请检查防火墙规则或网络代理等设置,确保没有阻止Golang SDK与RocketMQ Broker之间的连接。
      • 确认您在Golang SDK中正确指定了RocketMQ Broker的地址和端口号。请检查您的代码配置,确保与RocketMQ Broker的通信参数一致。
    2023-07-28 13:47:38
    赞同 展开评论 打赏
  • 意中人就是我呀!

    如果是golang sdk grpc的client 你应该连接proxy【ip:port】的endpoint
    https://github.com/apache/rocketmq-clients/issues/492#event-9645517986 参考一下。换你的proxy端口。你直接连接 remotehost:8080 这个endpoint不行吗?一般不配置这个proxy的端口,默认ws包装过的mqtt应该是8080,剩下我没咋看过..源代码默认就是8080.proxy.properties 好像有这么个文件可以配置。此回答整理至钉群“群2-Apache RocketMQ 中国开发者钉钉群”。

    2023-07-19 13:48:35
    赞同 展开评论 打赏

多个子产品线联合打造金融级高可用消息服务以及对物联网的原生支持,覆盖多行业。

相关产品

  • 云消息队列 MQ
  • 热门讨论

    热门文章

    相关电子书

    更多
    Golang 微服务在腾讯游戏用户运营领域的探索及实践 立即下载
    万亿级数据洪峰下的消息引擎——Apache RocketMQ 立即下载
    基于RocketMQ Prometheus Exporter 立即下载

    相关镜像