binge124 2022-07-31 10:04 采纳率: 50%
浏览 60
已结题

RocketMQ发送同步消息正常,异步消息和单向消息报错

问题遇到的现象和发生背景

RocketMq发送消息问题

问题相关代码,请勿粘贴截图
public void asyncSendMessageTest() throws InterruptedException {
        Message message = MessageBuilder.withPayload("测试异步消息").build();
        rocketMQTemplate.asyncSend("topic3", message, new SendCallback() {
            @Override
            public void onSuccess(SendResult sendResult) {
                log.info("asyncSendResult:" + sendResult);
            }
            @Override
            public void onException(Throwable e) {
                log.info("asyncSendResult:" + e);
            }
        });
 
    Thread.sleep(50000);
}
运行结果及报错内容

2022-07-31 09:55:52.737 INFO 9196 --- [enderExecutor_1] c.y.producer.ProducerApplicationTests : asyncSendResult:org.apache.rocketmq.client.exception.MQClientException: Send [1] times, still failed, cost [3050]ms, Topic: topic3, BrokersSent: [MS-XCWWDZXWLRFO]
See http://rocketmq.apache.org/docs/faq/ for further details.
//以上是异步消息报错,以下是单向消息报错
Caused by: org.apache.rocketmq.client.exception.MQClientException: Send [1] times, still failed, cost [3493]ms, Topic: topic3, BrokersSent: [MS-XCWWDZXWLRFO]
See http://rocketmq.apache.org/docs/faq/ for further details.

Caused by: org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendKernelImpl call timeout

我的解答思路和尝试过的方法

同步消息是可以运行成功的,就异步消息和单向消息运行不成功。

我想要达到的结果

麻烦有懂的大lao给解决以下,已经头疼1天了。

  • 写回答

2条回答 默认 最新

  • 林晓风 2022-07-31 10:30
    关注

    应该是你的服务端有问题,重新安装一下RocketMQ服务试试

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论 编辑记录
查看更多回答(1条)

报告相同问题?

问题事件

  • 系统已结题 8月8日
  • 已采纳回答 7月31日
  • 修改了问题 7月31日
  • 创建了问题 7月31日

悬赏问题

  • ¥15 FOC simulink
  • ¥15 咨询一下有关于王者荣耀赢藏战绩
  • ¥100 求购一套带接口实现实习自动签到打卡
  • ¥50 MacOS 使用虚拟机安装k8s
  • ¥500 亚马逊 COOKIE我如何才能实现 登录一个亚马逊账户 下发新 COOKIE ..我使用下发新COOKIE 导入ADS 指纹浏览器登录,我把账户密码 修改过后,原来下发新COOKIE 不会失效的方式
  • ¥20 玩游戏gpu和cpu利用率特别低,玩游戏卡顿
  • ¥25 oracle中的正则匹配
  • ¥15 关于#vscode#的问题:把软件卸载不会再出现蓝屏
  • ¥15 vimplus出现的错误
  • ¥15 usb无线网卡转typec口