RocketMQ发送延迟消息时报错，发送同步消息却正常

延时消息代码如下：

Message<Mdds> message = MessageBuilder.withPayload(mdds).build();
// 延迟第3级发送（延迟10秒）
rocketMQTemplate.syncSend(MessageConstant.TOPIC_ORDER, message, 1000, 3);

能正确调用的方法如下：

rocketMQTemplate.convertAndSend(MessageConstant.TOPIC_ORDER, mdds);

错误详情如下：

org.springframework.messaging.MessagingException: sendDefaultImpl call timeout; nested exception is org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout

解决方法：

设置的超时时间为3s以上，问题解决，代码如下：

rocketMQTemplate.syncSend(MessageConstant.TOPIC_ORDER, message, 3000, 3);

注意：网上很多错误方法，如修改配置文件broker.conf，并在mqbroker运行命令时增加参数 -c ../conf/broker.conf，并在mqnamesrv运行命令时增加-n 127.0.0.1:9876，这些解决不了问题！如果是配置错误，不可能成功发送同步的消息

我建了一个私域流量运营的社群，欢迎朋友们进群一起交流，想进群关注并私信我吧、

RocketMQ发送延迟消息时报错，发送同步消息却正常相关推荐

rockemq 发送延迟消息_RocketMQ系列（五）广播与延迟消息
今天要给大家介绍RocketMQ中的两个功能,一个是"广播",这个功能是比较基础的,几乎所有的mq产品都是支持这个功能的:另外一个是"延迟消费",这个应该算是R ...
rockemq 发送延迟消息_58分布式消息队列WMB设计与实践
背景为了能够承载58业务的快速扩展及海量的用户访问,分布式系统已经成为公司一种主流架构设计.而消息队列是大型分布式系统中不可或缺的通信桥梁,在分布式系统解耦.异步通信.事件通知.流量削峰等业务场景中 ...
rocketMQ的消息介绍、发送方式和消费方式
rocketMQ中消息有以下几种普通消息:消息队列中没有特性的消息顺序消息:严格按照顺序发布和消费的消息,先发布的消息一定会先被消费,可以分为全局顺序消息:所有消息严格按照先入先出的顺序来发布和 ...
发送延迟消息_微信延迟消息的发送方式
Part one. 如何使用微信来发送延迟消息呢? Part two. 之前一次偶然的机会,想要定时发送一个消息给朋友,于是产生了微信能否发送定时消息这个念头.去百度了一下,找到了方法.微信是可以定时 ...
SpringBoot整合RocketMQ之环境搭建以及Producer发送消息
https://github.com/apache/rocketmq-spring/releases/tag/2.0.0https://github.com/apache/rocketmq-sprin ...
（转） RabbitMQ学习之spring整合发送同步消息（注解实现）
http://blog.csdn.net/zhu_tianwei/article/details/40918477 上一篇文章通过xml配置rabbitmq的rabbitTemplate,本节将使用注 ...
企业微信推送消息延迟_企业微信发送应用消息的实现
企业号升级到企业微信后,发送应用消息的接口也变化了不少,除了原来的文本.图片.文件.语音.视频.图文消息等消息外,增加了文本卡片.markdown消息.小程序通知消息等内容,不过它们都可以共用一个接口 ...
RocketMQ源码解析：Producer发送消息+Broker消息存储
文章目录 1. Producer 发送消息 2. Broker 接收消息 1. Producer 发送消息先上一段简单的生产者代码 public static void main(String[] ...
RocketMQ 实战-SpringBoot整合RocketMQ同步消息、异步消息、单向消息
官方样例:https://gitee.com/apache/rocketmq/blob/master/docs/cn/RocketMQ_Example.md 1. 同步消息 producer向 bro ...

RocketMQ发送延迟消息时报错，发送同步消息却正常

延时消息代码如下：

RocketMQ发送延迟消息时报错，发送同步消息却正常相关推荐

最新文章

热门文章