当前位置： 首页 > news >正文

RocketMQ重复消费问题的原因

news 文章来源：https://blog.csdn.net/uniquewonderq/article/details/129704889 2025/5/18 5:21:16

文章目录

  • 概览
  • 消息发送异常时重复发送
  • 消费消息抛出异常
  • 消费者提交offset失败
  • 服务端持久化offset失败
  • 主从同步offset失败
  • 重平衡
  • 清理长时间消费的消息
  • 总结

概览

在这里插入图片描述

消息发送异常时重复发送

首先，我们来瞅瞅RocketMQ发送消息和消费消息的基本原理。

在这里插入图片描述
如图，简单说一下上图中的概念：

  • Broker，就是RocketMQ的服务端，如上图就有两个服务实例
  • Topic就是一类消息集合的名字
  • Queue就是Topic的对应的队列，消息都存在Queue上，每个Topic都会有自己的几个Queue
    所以，整个消息发送和消费过程大致如下：
  1. 生产者在发送消息之前根据负载均衡

相关文章：

RocketMQ重复消费问题的原因

文章目录 概览消息发送异常时重复发送消费消息抛出异常消费者提交offset失败服务端持久化offset失败主从同步offset失败重平衡清理长时间消费的消息总结概览 消息发送异常时重复发送 首先，我们来瞅瞅RocketMQ发送消息和消费消息的基本原理。 如图，简单说一下上图中的概念： …...

编程日记 2023/3/22 18:27:06

proxy详细介绍与使用

proxy详细介绍与使用 proxy 对象用于创建一个对象的代理，是在目标对象之前架设一个拦截，外界对该对象的访问，都必须先通过这个拦截。通过这种机制，就可以对外界的访问进行过滤和改写。 ES6 原生提供 Proxy 构造函数，…...

编程日记 2023/3/22 18:22:04

基于YOLOv5的舰船检测与识别系统（Python+清新界面+数据集）

摘要：基于YOLOv5的舰船检测与识别系统用于识别包括渔船、游轮等多种海上船只类型，检测船舰目标并进行识别计数，以提供海洋船只的自动化监测和管理。本文详细介绍船舰类型识别系统，在介绍算法原理的同时，给出Python的实…...

编程日记 2023/4/12 17:21:27

【C#】List数据去重

系列文章 【C#】单号生成器（定义编号规则、流水号、产生业务单号） 本文链接：https://blog.csdn.net/youcheng_ge/article/details/129129787 【C#】日期范围生成（构建本周开始、结束日期） 本文链接：https…...

编程日记 2023/4/12 17:22:27

避免踩坑，教给你VSCode中最常用到的6项功能

这里为程序员介绍VSCode中包含的许多令人兴奋的Tips。 1. 插件市场中免费下载使用CodeGeeX插件 AI辅助编程工具CodeGeeX，是完全免费，开源开放给所有开发者使用。程序员普遍反应使用这个插件后，代码编写效率提升2倍以上。 CodeGeeX插件拥有…...

编程日记 2023/3/22 18:06:58

ThingsBoard开源物联网平台智慧农业实例快速部署教程（Ubuntu、CentOS适用）

ThingsBoard部署教程文档 文章目录ThingsBoard部署教程文档1. JDK环境安装2. 安装thingsBoard2.1 ThingsBoard软件包安装2.2 PostgreSQL安装2.3 PostgreSQL初始化配置3. 修改ThingsBord的配置4. 运行安装脚本测试5. 访问测试6. 导入一个仪表盘库6.1 导出仪表盘并导入自己的项目…...

编程日记 2023/3/22 18:01:56

【Java Spring基本问题】记录面试题宝典中自己不熟悉的Spring问题

文章目录Spring Bean定义装配Spring Bean生命周期Spring Bean容器Spring 循环依赖Spring 事务Autowired和ResourceSpring Bean定义装配 参考文章 1. 定义Spring Bean的三种方式 XML文件定义Spring Bean JavaConfig定义Spring Bean Component注解定义SpringBean 2. 装配Spri…...

编程日记 2023/4/12 17:23:52

I2C协议简介 Verilog实现

I2C协议 IIC 协议是三种最常用的串行通信协议（I2C，SPI，UART）之一，接口包含 SDA（串行数据线）和 SCL（串行时钟线），均为双向端口。I2C 仅使用两根信号线&#xf…...

编程日记 2023/3/22 17:51:53

服务器被DDoS攻击，怎么破？

文章目录前言网站受到DDoS的症状判断是否被攻击查看网络带宽占用查看网络连接TCP连接攻击SYN洪水攻击防御措施TCP/IP内核参数优化iptables 防火墙预防防止同步包洪水（Sync Flood）Ping洪水攻击（Ping of Death）控制单个IP的最大并发…...

编程日记 2023/4/27 13:21:07

实现完全二叉树

文章目录1、树概念及结构2、孩子兄弟表示法3、二叉树3.1、二叉树的概念3.2、特殊的二叉树3.3、二叉树的存储4、堆的性质5、数组结构实现完全二叉树1、结构体的定义2、初始化堆3、销毁堆4、交换函数5、向上调整函数6、插入数据7、向下调整函数8、删除堆顶数据函数9、判断是否空堆…...

编程日记 2023/3/22 17:41:51

【独家】华为OD机试 - 矩阵最值（C 语言解题）

最近更新的博客 华为od 2023 | 什么是华为od，od 薪资待遇，od机试题清单华为OD机试真题大全，用 Python 解华为机试题 | 机试宝典【华为OD机试】全流程解析+经验分享,题型分享,防作弊指南华为od机试，独家整理 已参加机试人员的实战技巧本期题目：矩阵最值 题目 给定一个仅包…...

编程日记 2023/3/22 17:36:49

C++模板(进阶)

文章目录非类型模板参数类模板的特化类模板的概念函数模板特化类模板的特化全特化偏特化参数的进一步限制模板的分离编译模板的优缺点非类型模板参数 模板参数分类型形参与非类型形参. 类型形参: 出现在模板参数列表中,跟在class,typename之类的参数类型名称. 非类型形参: 就是…...

编程日记 2023/3/22 17:31:47

【数据分析之道(二)】列表

文章目录专栏导读1、列表介绍2、访问列表中的值3、列表增加和修改4、删除元素5、列表函数6、列表方法专栏导读 ✍ 作者简介：i阿极，CSDN Python领域新星创作者，专注于分享python领域知识。 ✍ 本文录入于《数据分析之道》，本专栏针…...

编程日记 2023/3/22 17:26:45

架构师必须要掌握的大小端问题

一、什么是大端和小端 所谓的大端模式，就是高位字节排放在内存的低地址端，低位字节排放在内存的高地址端。 所谓的小端模式，就是低位字节排放在内存的低地址端，高位字节排放在内存的高地址端。 简单来说：大端——高尾端，小端——低尾端 举个例子，比如数字 0x12 34 56 78…...

编程日记 2023/3/22 17:21:43

2023年ACM竞赛班 2023.3.20题解

目录 瞎编乱造第一题 瞎编乱造第二题 瞎编乱造第三题 瞎编乱造第四题 瞎编乱造第五题 不是很想编了但还是得编的第六题 不是很想编了但还是得编的第七题 还差三道题就编完了的第八题 还差两道题就编完了的第九题 太好啦终于编完了 为啥一周六天早八阿 瞎编乱造第一题…...

编程日记 2023/3/22 17:16:41

什么是语法糖？Java中有哪些语法糖？

本文从 Java 编译原理角度，深入字节码及 class 文件，抽丝剥茧，了解 Java 中的语法糖原理及用法，帮助大家在学会如何使用 Java 语法糖的同时，了解这些语法糖背后的原理1 语法糖语法糖（Syntactic Sugar&#…...

编程日记 2023/3/22 17:11:39

STM32学习（五）

GPIO General Purpose Input Output，通用输入输出端口，简称GPIO。 作用： 采集外部器件的信息（输入）控制外部器件的工作（输出） GPIO特点 1，不同型号，IO口数量可能不一样…...

编程日记 2023/3/22 17:06:38

STM32的CAN总线调试经验分享

相关文章 CAN总线简易入门教程 CAN总线显性电平和隐性电平详解 STM32的CAN总线调试经验分享 文章目录相关文章背景CAN总线CAN控制器CAN收发器调试过程硬件排查CAN分析仪芯片CAN控制器调试总结背景 最近负责的一个项目用的主控芯片是STM32F407IGT6，需要和几个电机控…...

编程日记 2023/4/12 17:25:46

深度剖析自定义类型（结构体、枚举、联合）——“C”

各位CSDN的uu们你们好呀，今天，小雅兰的内容是心心念念的结构体啦，其实在此之前，我也写过结构体的知识点，只是并没有很深入，那么，今天我会仔细来学习自定义类型的知识点，下面&#xf…...

编程日记 2023/5/1 7:38:28

《水经注地图服务》发布的全球影像数据在水经微图中调用

（本文首发于“水经注GIS”公号，订阅“水经注GIS”公号，为你分享更多GIS技术 ）1、引言古人云：“工欲善其事，必先利其器。”意思是说：工匠想要使他的工作做好，一定要先让工具锋利&…...

编程日记 2023/3/22 16:51:31

MyBatis --- 缓存、逆向工程、分页插件

一、MyBatis的缓存 1.1、MyBatis的一级缓存 一级缓存是SqlSession级别的，通过同一个SqlSession查询的数据会被缓存，下次查询相同的数据，就会从缓存中直接获取，不会从数据库重新访问 使一级缓存失效的四种情况： 1、…...

编程日记 2023/4/12 17:27:33

vue3自定义svg图标组件

可参考： 未来必热：SVG Sprites技术介绍 懒人神器：svg-sprite-loader实现自己的Icon组件 在Vue3项目中使用svg-sprite-loader 前置知识 在页面中，虽然可以通过如下的方式使用img标签，来引入svg图标。但是，…...

编程日记 2023/3/22 16:41:27

智能火焰与烟雾检测系统（Python+YOLOv5深度学习模型+清新界面）

摘要：智能火焰与烟雾检测系统用于智能日常火灾检测报警，利用摄像头画面实时识别火焰与烟雾，另外支持图片、视频火焰检测并进行结果可视化。本文详细介绍基于智能火焰与烟雾检测系统，在介绍算法原理的同时，给出Python的…...

编程日记 2023/3/22 16:36:26

Java实习生------JUC并发编程（多线程）10道面试题打卡⭐⭐⭐

目录 并行和并发有什么区别？ 线程和进程有什么区别？ 创建线程有哪几种方式？ runnable和callable有什么区别？ 线程的状态及转换？ sleep()和wait()的区别？ run()和start()有什么区别？ 在…...

编程日记 2023/3/22 16:31:24

ChatGPT和百度文心一言写用例，谁更强？

文心一言发布的第一时间，就排队申请了邀请码，昨晚看了下，邀请码已经到手，索性就拿一个例子试了一下，看看哪个能够真正意义上的提高生产力，最简单的录制了个GIF动画如下：问题：你是一个…...

编程日记 2023/3/22 16:26:22

设计模式总结

设计模式的六大原则 开放-封闭原则(OCP) (总原则) Open-Close Principle：该对扩展开放，对修改关闭。 目的就是保证程序的扩展性好，易于维护和升级。 开放-封闭原则是面向对象设计的核心所在, 开闭原则是Java世界里最基础的设计原则。 开闭…...

编程日记 2023/3/22 16:21:18

【K8S系列】深入解析Pod对象(一)

目录 序言 1.问题引入 1.1 问题描述 2 问题解答 2.1 pod 属性 2.1.1 NodeSelector 2.1.2 HostAliases 2.1.3 shareProcessNamespace 2.1.4 NodeName 2.1.5 其他pod属性 2.2 容器属性 2.2.1 ImagePullPolicy 2.2.2 Lifecycle 3 总结 4. 投票 序言 任何一件事情&am…...

编程日记 2023/3/22 16:16:16

JVM学习.02 内存分配和回收策略

1、前言《JVM学习.01 内存模型》篇讲述了JVM的内存布局，其中每个区域是作用，以及创建实例对象的时候内存区域的工作流程。上文还讲到了关于对象存货后，会被回收清理的过程。今天这里就着重讲一下对象实例是如何被清理回收的，以及清…...

编程日记 2023/3/22 16:11:14

logstash+elasticsearch+Kibana(ELK)日志收集

文章目录一.安装ELK 7.17二.为Elasticsearch设置密码三.配置logstash四.springboot整合logstash五.spring整合Elastic Search一.安装ELK 7.17 不要一股脑执行以下语句,请观察修改要修改的地方 安装logstash # logstash安装docker run -d --name logstash \-p 5043:5043 -p 5…...

编程日记 2023/4/12 17:27:53

今天面试了一个2年Java经验的

今天去面试了一个26岁的程序员，看了简历，2年经验，本科，写得很牛叉。 Spring cloud alibaba全家桶、redis，分布式锁，服务调用，数据库事务，线程，Zookeeper、Dubbo 、Rabbi…...

编程日记 2023/3/22 16:01:10