栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

Python RocketMQ 报错及其解决方法

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Python RocketMQ 报错及其解决方法

Python RocketMQ 报错及其解决方法
  • 1 报错信息
  • 2 定位原因
    • 2.1 RocketMQ-Python-SDK
    • 2.2 实例信息
  • 3 解决方法
    • 3.1 instance_id
    • 3.2 协议

某天根据某同事给的RocketMQ实例接入信息,配置好后准备收发和订阅普通消息:Python调用阿里MQ HTTP SDK,然而却一直报错…

1 报错信息

Consume Message Fail! Exception:MQClientNetworkException (“NetWorkException”, “Remote end closed connection without response”)

查阅了相关文档:消息队列RocketMQ版常见问题,并没有找到相应的报错和解决方法,于是只能静下心来查找具体原因。

2 定位原因 2.1 RocketMQ-Python-SDK


RocketMQ-SDK如上,Python相关的SDK只能走http协议。
Remote end closed connection without response,远程端关闭连接无响应,那么原因只能是配置信息有误。于是自己登录阿里后台,查看MQ跟协议相关信息,果然,所创建group协议不对—初步查看只注意到这个很明显的点。

重新创建http群组接入后,依旧报错;

2.2 实例信息

只能从实例 到 Topic 到 Group依次排查,最终确认为:所给实例ID不对,给的是实例名称;接入点给的不对,Python应该是HTTP 协议客户端接入点,给的是TCP 协议客户端接入点;

3 解决方法 3.1 instance_id

instance_id即实例id,并非实例名称,实例id可从实例列表或实例详情获得。

3.2 协议

除了group区分tcp 和 http协议外,,MQ实例也区分http和tcp,所以如果是用python接入的话,记得选用 HTTP 协议客户端接入点

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/591340.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号