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

关于RocketMQ使用过程中遇到的坑(持续更新)

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

关于RocketMQ使用过程中遇到的坑(持续更新)

内容为持续更新,遇到了都会在下方总结说明
  • 问题如下:
    • RemotingTooMuchRequestException

问题如下: RemotingTooMuchRequestException

在生产者执行过程中,消息的发送遇到的详情如下:

org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout

我们先看源代码发送消息方式:

	Message message = new Message(topic, tag, dataJson.getBytes(RemotingHelper.DEFAULT_CHARSET));
    defaultMQProducer.send(message);

解决方式一:

  defaultMQProducer.send(message, 8000);
这种方式并非我本人遇到的情况,但查阅说有个别这种原因导致超时。

解决方式二:

 producer.setVipChannelEnabled(false);
这种方式本人亲测,发现生产者是生效的,但消费者comsumer.setVipChannelEnabled(false)依旧有无法解决这个问题

解决方式三:

找运维开通服务器与rocketmq的vip端口10909。本人遇到的问题归根结底是走了mq的vip端口,而端口不通,导致了连接超时,无法进行消息的通讯
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/270858.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

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

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