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

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 265 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
    赞同 展开评论 打赏

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

相关产品

  • 云消息队列 MQ
  • 相关电子书

    更多
    从 SDK 到编解码:视频直播架构解析 立即下载
    跨平台的云服务SDK需要什么 立即下载
    一个跨平台的云服务SDK需要什么 立即下载