返回顶部
首页 > 资讯 > 服务器 >RocketMQ发送消息失败排查
  • 866
分享到

RocketMQ发送消息失败排查

linux服务器 2023-09-16 07:09:57 866人浏览 独家记忆
摘要

RocketMQ发送消息失败排查 错误信息: RocketMQ Message hasn't been sent. Caused by Send [1] times, still failed, co

RocketMQ发送消息失败排查

错误信息:

RocketMQ Message hasn't been sent. Caused by Send [1] times, still failed, cost [1982]ms, Topic: course-log-topic, BrokersSent: [broker-a]

错误截图:
在这里插入图片描述

(一)查看消费者情况

# 查看命令mqadmin consumerProgress -n localhost:9876

查看结果:
在这里插入图片描述
说明:发现对应的订阅组已经离线(查看对应的项目MQ地址和配置都是正确的),然后从服务日志中也看不出更多的问题

(二)调整服务日志

说明:调整服务日志级别到info,通过详细的日志信息定位发送失败的原因

日志截图:
在这里插入图片描述
说明:日志不断打印closeChannel: close the connection to remote address[] result: true

排查思路

  1. mq端口配置是否配置正确 或者说 rocketmq是否启动正常
  2. rocketmq broker ip主机 brokerIP 是否配置正常
  3. 网络是否正常

1、通过netstat -ntlp查看mq端口是否存在

在这里插入图片描述
发现MQ服务是正常启动的,端口也在

2、查看MQ的brokerIP

# 查看broker配置sh ./bin/mqbroker -m

查看截图:
在这里插入图片描述
通过ifconfig查看服务器IP
在这里插入图片描述
说明:发现MQ的brokerIP默认使用了第一张网卡Docker0,而不是eth0的网卡,导致服务通过IP无法访问发送

解决方案:在配置文件conf/broker.conf中通过brokerIP1=X.X.X.X(访问IP)指定brokerIP
配置截图:
在这里插入图片描述

注意事项:
说明:
如果是集群需要配置brokerIP1、brokerIP1
默认不配置brokerIP1和brokerIP2时,都会根据当前网卡选择一个IP使用,当你的机器有多块网卡时,很有可能会有问题。比如,我遇到的问题是我机器上有两个IP,一个公网IP,一个私网IP,结果默认选择的走公网IP,这是不正确的,我期望的是所有业务内部通信都走内网。

  • brokerIP1:当前broker监听的IP
  • brokerIP2:存在broker主从时,在broker主节点上配置了brokerIP2的话,broker从节点会连接主节点配置的brokerIP2来同步

来源地址:https://blog.csdn.net/qq_27354909/article/details/129261381

--结束END--

本文标题: RocketMQ发送消息失败排查

本文链接: https://lsjlt.com/news/409509.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

猜你喜欢
  • RocketMQ发送消息失败排查
    RocketMQ发送消息失败排查 错误信息: RocketMQ Message hasn't been sent. Caused by Send [1] times, still failed, co...
    99+
    2023-09-16
    linux 服务器
  • mq消息发送失败如何解决
    当MQ消息发送失败时,可以尝试以下几种解决方法: 检查MQ服务器状态:确认MQ服务器是否正常运行,并检查连接配置是否正确。 ...
    99+
    2023-10-23
    mq
  • RocketMQ消息发送流程源码剖析
    目录正文读源码1 调用defaultMQProducerImpl.send()2 设置过期时间3 执行defaultMQProducerImpl.sendDefaultImpl()方...
    99+
    2022-11-13
    RocketMQ消息发送流程 RocketMQ 消息
  • RocketMQ的事务消息发送流程是什么
    本篇内容介绍了“RocketMQ的事务消息发送流程是什么”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!事务消息发送流程半消息实现了分布式环境...
    99+
    2023-07-05
  • Kafka中的Producer发送消息失败后如何处理
    当Kafka中的Producer发送消息失败后,可以通过以下几种方式处理: 重试发送:Producer可以设置重试机制,当发送消...
    99+
    2024-04-02
  • RabbitMQ,RocketMQ,Kafka 事务性,消息丢失,消息顺序性和消息重复发送的处理策略问题
    目录消息队列常见问题处理分布式事务什么是分布式事务常见的分布式事务解决方案基于 MQ 实现的分布式事务本地消息表-最终一致性MQ事务-最终一致性RocketMQ中如何处理事务Kafk...
    99+
    2024-04-02
  • RocketMQ消费者没有成功消费消息的问题排查
    背景 今天下游同事反馈,有一些以取消的订单库存还原异常了,导致部分商品库存没有还原。查日志发现没有收到还原消息,但是查看发送方是可以确认消息是已经发了的,那么是什么原因导致消费者没有收到,或者收到后没有处理消息呢。最后发现这些消息的状态都...
    99+
    2023-09-23
    java-rocketmq rocketmq java 开发语言
  • RocketMQ消息队列实现随机消息发送当做七夕礼物
    目录正文1 下载并启动RocketMQ1.1 首先启动name server1.2 然后启动Broker2 生产者3 消费者正文 都在过情人节,前端的小哥哥们给女朋友画个页面,美美的...
    99+
    2024-04-02
  • Springboot中RocketMQ怎么实现消息发送与接收
    本文小编为大家详细介绍“Springboot中RocketMQ怎么实现消息发送与接收”,内容详细,步骤清晰,细节处理妥当,希望这篇“Springboot中RocketMQ怎么实现消息发送与接收”文章能帮助大家解决疑惑,下面跟着小编的思路慢慢...
    99+
    2023-07-02
  • Kafka中Producer如何处理消息发送失败的情况
    在Kafka中,Producer在发送消息时可能会遇到消息发送失败的情况。Producer可以通过以下几种方式来处理消息发送失败的情...
    99+
    2024-03-12
    Kafka
  • Springboot详解RocketMQ实现消息发送与接收流程
    springboot+rockermq 实现简单的消息发送与接收 普通消息的发送方式有3种:单向发送、同步发送和异步发送。 下面来介绍下 springboot+rockermq 整合...
    99+
    2024-04-02
  • SpringBoot集成RocketMQ发送事务消息的原理解析
    目录简介原理具体实现消费者消费者生产者消息监听器消息事务测试正常测试异常测试代码调整执行结果总结简介 RocketMQ 事务消息(Transactional Message)是指应用...
    99+
    2024-04-02
  • Springboot详细讲解RocketMQ实现顺序消息的发送与消费流程
    目录一、创建Springboot项目添加rockermq依赖二、配置rocketmq三、新建一个controller来做消息发送四、创建消费端监听消息消费消息五、启动服务测试顺序消息...
    99+
    2024-04-02
  • Springboot如何整合RocketMQ收发消息
    这篇文章将为大家详细讲解有关Springboot如何整合RocketMQ收发消息,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。Springboot 整合 RocketMQ 收发消息创建springboot...
    99+
    2023-06-22
  • 如何处理消息消费失败
    本篇内容介绍了“如何处理消息消费失败”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!一、介绍在介绍消息中间件...
    99+
    2024-04-02
  • FCM( Firebase) 发送推送消息PHP
    Firebase 的管理后台也有发送测试消息推送的入口,在左侧栏目的 Cloud Messaging 准备工作: 1、准备好 服务器秘钥, 如图 打开postman , 创建一个新的api 请求 1...
    99+
    2023-09-02
    php json 开发语言
  • SpringBoot整合RocketMQ实现消息发送和接收的详细步骤
    我们使用主流的SpringBoot框架整合RocketMQ来讲解,使用方便快捷; 最终项目结构如下: 具体步骤如下: 第一步:新建SpringBoot项目rocketmq-test...
    99+
    2024-04-02
  • 飞书自动发送消息-自动群发消息
    需求: 想通过飞书,定时发送自定义消息给指定的人员或者所有人员.自定义消息可以是文字,图片或音视频. 解决思路: 在飞书创建一个类似微信公众号一样的群发工具 在这个群发工具后台配置功能,获取相关的秘钥 编写代码, 封装好发送...
    99+
    2023-09-01
    PHP Powered by 金山文档
  • RocketMQ消息过滤与查询的实现
    消息过滤 RocketMQ分布式消息队列的消息过滤方式有别于其它MQ中间件,是在Consumer端订阅消息时再做消息过滤的。 RocketMQ这么做是还是在于其Producer端写入...
    99+
    2024-04-02
  • 小程序发送订阅消息,微信公众号发送消息模板
    首先讲两个注意事项 小程序和微信公众号的用户openid是不同的。 小程序需要用户手动授权订阅消息通知(一次性订阅是订阅一次发一次,长期订阅可以多发)。 关于小程序和公众号AppID和AppSecret的获取可以自行百度一下,挺简单的。 小...
    99+
    2023-08-31
    小程序 php
软考高级职称资格查询
编程网,编程工程师的家园,是目前国内优秀的开源技术社区之一,形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容,为IT开发者提供了一个发现、使用、并交流开源技术的平台。
  • 官方手机版

  • 微信公众号

  • 商务合作