请稍等 ...
×

采纳答案成功!

向帮助你的同学说点啥吧!感谢那些助人为乐的人

使用rocketmq第一次发消息很慢

使用rocketmq第一次发消息很慢,不设置发消息的超时时间会图片描述报超时异常

正在回答

1回答

您好,这个应该是网络问题导致的。

RocketMQ目前不支持IP变化(这意味着机器一旦重新被分配IP的话,可能会导致消费问题:因为Name Server存储了Topic和Producer之间的映射关系,映射关系发生变化了)

我百度了一下,建议您按照这篇文章解决:

https://blog.csdn.net/mefly521/article/details/84394483

也就是启动时,指定一下Broker的实际IP,另外如果是Windows,务必记得关闭下防火墙

----------

此外,个人不建议在实际项目中直接使用RocketMQ的API,这是因为如果你直接用RocketMQ的API,那么很可能被RocketMQ绑死,带来的问题:

  1. 想换用其他的MQ实现,基本不可能,因为API完全不一样;

  2. 如果未来,新版本的RocketMQ的API发生变更,你的业务代码要到处修改;

  3. 开发需要单独学习这一套MQ的API

建议使用:

  1. Spring Messaging编程模型

  2. Spring Cloud Stream编程模型

实现消息收发。

这样:

  1. 想换MQ实现,编程模型上都不会变;

  2. 由编程模型实现新版RocketMQ的适配;

  3. 不管用什么MQ(RocketMQ/Kafka/RabbitMQ),模型都是一样的,会一套就能搞定各种MQ的消息收发!


0 回复 有任何疑惑可以回复我~
  • 提问者 慕用5498483 #1
    老师,问题解决了,我下载的rocketmq有问题,重新换了个链接下载,就没这个问题了。。。
    回复 有任何疑惑可以回复我~ 2019-08-09 17:46:28
  • 大目 回复 提问者 慕用5498483 #2
    哟西? 解决就好…请问最后使用的下载链接是?版本是?能否帮忙告知一下哦,我做个备注,以后有其他同学遇到类似问题时,可以回溯。
    回复 有任何疑惑可以回复我~ 2019-08-09 18:09:54
  • 提问者 慕用5498483 回复 大目 #3
    官网引导的下载页面:https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.5.2/rocketmq-all-4.5.2-bin-release.zip有好多地址,第一次使用的是以http为标题的地址,在http标题上面还有一个推荐的下载地址,下载后解压并启动rocketmq好了一次。。。。。第二次又出现了第一次发消息很慢的情况。最新发现是macbook连手机的wifi不会出现这个问题。。。。。。。。可能是网络设备的问题,在单网卡的容器环境下应该不会出现这个问题。然后就不纠结这个事情了,如果出现这个问题,可以在项目初始化的时候先发一条没用的消息,以后用的时候就不会出现这个问题了。
    回复 有任何疑惑可以回复我~ 2019-09-07 11:15:36
问题已解决,确定采纳
还有疑问,暂不采纳
意见反馈 帮助中心 APP下载
官方微信