首页 > 其他分享 >写mq消息失败

写mq消息失败

时间:2023-12-19 18:12:50浏览次数:35  
标签:name producer Producer 失败 消息 timeout mq message rocketmq

 

有时候解决问题的方式很简单,如下:
消费模式:
        集群模式
普通消息:
        单向发送
pom.xml配置

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>2.0.4</version>
</dependency>

1. 使用下面代码向mq写消息

rocketMQTemplate.convertAndSend(message.getMqTopic(), message.getMqMessage());

1.1 yaml配置文件内容

rocketmq:
  name-server: ip:端口
  producer:
    group: "G-Group_REQ"
    send-msg-timeout: 30000

1.2 报错:sendDefaultImpl call timeout; nested exception is org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout


2. 使用下面代码

DefaultMQProducer producer = new DefaultMQProducer(message.getMqGroup());
producer.setNamesrvAddr(namesrvAddr);
producer.setSendMsgTimeout(30000);
producer.start();
Message msg = new Message(message.getMqTopic(), message.getMqMessage().getBytes());
producer.send(msg);

2.1 yaml配置文件内容

rocketmq:
  name-server: ip:端口

2.2 报错:Send [3] times, still failed, cost [9490]ms, Topic: T-costcont-WelfareCostApproval, BrokersSent: [a, a, a]
See http://rocketmq.apache.org/docs/faq/ for further details.
2.3 报错:The producer group[G-costcont-WelfareCostApproval_REQ] has been created before, specify another name please.
See http://rocketmq.apache.org/docs/faq/ for further details.


3. 官方解释:
3.1 SEND_MSG_FAILED
异常信息
       Send [xxx] times, still failed, cost [xxx]ms, Topic: xxx, BrokersSent ...
原因
       1)Producer消息发送异常。在 SYNC 模式下总共发送 3 次,在 ASYNC 和 ONEWAY 模式下发送 1 次。
解决方法
       1)Producer发送消息的timeout参数是否过小。
       2)确保Broker正常。
       3)确保 Producer 和 Broker 之间的连接正常。
3.2 GROUP_NAME_DUPLICATE_URL
异常信息
       The producer group[xxx] has been created before, specify another name please.
原因
       1)同名消费组已启动,注册失败。
解决方法
       1)重命名新的消费者组。
       2)同名的消费者组常闭,然后重新开始。


最终多方排查是:Producer 和 Broker 之间的连接问题,切换环境执行就没问题了。

标签:name,producer,Producer,失败,消息,timeout,mq,message,rocketmq
From: https://www.cnblogs.com/ZhaoHS/p/17833199.html

相关文章

  • IBM MQ 异常:com.ibm.mq.MQException
    出现两种现象:1、ibmmq通道不活动2、用程序读取ibmmq时,出现:com.ibm.mq.MQException查阅队列管理器的log(C:\ProgramData\IBM\MQ\qmgrs\IBMMQMANAGER\errors),发现:3、解决办法如下:查考链接:https://blog.csdn.net/weixin_39970855/article/details/114608063......
  • 安防视频云平台/可视化监控云平台EasyCVR获取设备录像失败,该如何解决?
    视频云存储/安防监控EasyCVR视频汇聚平台基于云边端智能协同,支持海量视频的轻量化接入与汇聚、转码与处理、全网智能分发、视频集中存储等。GB28181音视频流媒体视频平台EasyCVR拓展性强,视频能力丰富,具体可实现视频监控直播、视频轮播、视频录像、云存储、回放与检索、智能告警、......
  • RabbitMQ 安装(Centos7)
    1.下载rabbitmq和erlang1.1erlanghttps://github.com/rabbitmq/erlang-rpm/releases1.2rabbitMQhttps://github.com/rabbitmq/rabbitmq-server/releases/download/v3.12.10/rabbitmq-server-3.12.10-1.el8.noarch.rpm2.安装上传工具(非必要)yuminstalllrzsz.x86_64......
  • 使用RocketMQ实现消息顺序消费
    消息的顺序消费在很多交易型的业务场景中都会被要求实现,而且,消息队列的顺序消费解决方案在很多互联网公司的面试中经常会被问到。索尔老师在使用了多个消息队列后发现,虽然每个消息队列都有各自的顺序消费解决方案,但是RocketMQ经过了多年电商的洗礼,其功能性的要求,已经设计的非常全面......
  • 避坑合集|芝麻免押失败排查思路超详细总结(小程序场景)
    在使用小程序对接芝麻免押时,遇到了一些报错,估计把这个接口的坑都踩了个遍,这篇汇总一下我在芝麻免押上遇到的免押失败问题合集,大家注意避坑~对接流程......
  • python 升级pip失败
    有时候通过pip包管理器安装包时会报错pip版本过低,需要更新版本很多人就根据提示升级了。升级是有个步骤的,先卸载原来的,在安装新的版本有时候,卸载成功了,安装却失败了,导致pip直接没了如果原来的被卸载了,可以执行python-mensurepip--user在重新将旧版本安装升级过程中有一......
  • 记一次postgresql数据库插入记录失败的问题。。。
    代码在测试环境中运行了一段时间,之前都没有问题,突然pg数据库中的某个表不能插入记录了,具体来说是新插入的主键与表中已有记录的主键重复导致入库失败,但是主键设置的是自增策略,理论上说,不会重复。网上看到有人说需要设置下该表主键对应序列的下一个值。查看表的数据定义语句如下......
  • Nacos配置:发布失败,请检查参数是否正确
    一、表象:页面1:报错1:caused:PreparedStatementCallback;badSQLgrammar[SELECTid,data_id,group_id,tenant_id,app_name,content,md5,gmt_create,gmt_modified,src_user,src_ip,c_desc,c_use,effect,type,c_schema,encrypted_data_keyFROMconfig_infoWHEREdata_id......
  • window下rabbitmq安装教程
    RabbitMq简介1.1消息队列中间件简介消息队列中间件是分布式系统中重要的组件,主要解决应用耦合,异步消息,流量削锋等问题实现高性能,高可用,可伸缩和最终一致性[架构]使用较多的消息队列有ActiveMQ(安全),RabbitMQ,ZeroMQ,Kafka(大数据),MetaMQ,RocketMQ以下介绍消息队列在实际应用中常用的使......
  • M1 Docker 部署rocketmq
    1、克隆镜像arm64镜像代码编译镜像,docker直接安装会报错所以选择编译gitclonehttps://github.com/apache/rocketmq-docker.git  cdrocketmq-docker #注意这里centos固定不要改镜像版本可以改shbuild-image.sh4.8.0centos 第二步:拉取mqconsole镜像: candice06......