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

消息队列如何保证消息可靠性（kafka以及RabbitMQ）

news 来源：原创 2025/7/19 1:43:46

RabbitMQ保证消息可靠性

生产者丢失消息

MQ丢失消息

消费端丢失了数据

Kakfa的消息可靠性

生产者的消息可靠性

Kakfa的消息可靠性

消费者的消息可靠性

RabbitMQ保证消息可靠性

生产者丢失消息

1.事务消息保证

生产者在发送消息之前，开启事务消息随后生产者发送消息，消息发送之后，如果消息没有被MQ接收到的话，生产者会收到异常报错，生产者回滚事务，然后重试消息，如果收到了消息，就能提交事务了

@Autowired
private RabbitTemplate rabbitTemplate;public void sendTransactionalMessage() {ConnectionFactory connectionFactory = rabbitTemplate.getConnectionFactory();Channel channel = connectionFactory.createConnection().createChannel(false);try {channel.txSelect(); // 开启事务channel.basicPublish("exchange", "routing.key", null, "message".getBytes());channel.txCommit(); // 提交事务} catch (Exception e) {channel.txRollback(); // 出错回滚}
}

2.使用confirm机制

普通confirm机制，就是发送消息之后，等待服务器confirm之后再发送下一个消息

rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> {if (ack) {System.out.println("消息成功发送到Broker");} else {System.out.println("消息发送失败，原因：" + cause);}
});rabbitTemplate.convertAndSend("exchange", "routing.key", "message");

批量confirm机制，每发送一批消息之后，等待服务器confirm

Channel channel = connection.createChannel(false);
channel.confirmSelect();for (int i = 0; i < 100; i++) {channel.basicPublish("exchange", "routing.key", null, ("msg" + i).getBytes());
}
channel.waitForConfirms(); // 等待所有消息确认

异步confirm机制，服务器confirm一个或者多个消息之后，客户端（生产者）能够通过回调函数来确定消息是否被confirm（推荐）

SortedSet<Long> pendingSet = Collections.synchronizedSortedSet(new TreeSet<>());
channel.confirmSelect();channel.addConfirmListener(new ConfirmListener() {public void handleAck(long tag, boolean multiple) {if (multiple) pendingSet.headSet(tag + 1).clear();else pendingSet.remove(tag);}public void handleNack(long tag, boolean multiple) {System.err.println("未确认消息：" + tag);if (multiple) pendingSet.headSet(tag + 1).clear();else pendingSet.remove(tag);}
});while (true) {long seq = channel.getNextPublishSeqNo();channel.basicPublish("demo.exchange", "demo.key",MessageProperties.PERSISTENT_TEXT_PLAIN, "hello".getBytes());pendingSet.add(seq);
}

MQ丢失消息

防止MQ的丢失数据的话，方法就是开启RabbitMQ的持久化，消息写入之后（也就是到了MQ之后）就直接持久化到磁盘中，即使Rabbimq自己挂了之后，会恢复数据。

设置持久化步骤

创建queue的时候直接设置持久化，此时就能持久化queue的元数据（不是消息）

@Bean
public Queue durableQueue() {return new Queue("myQueue", true); // true 表示持久化
}

发送消息的时候指定消息为deliveryMode设置为2，也就是设置消息为持久化，此时消息可以持久化磁盘上

MessageProperties props = new MessageProperties();
props.setDeliveryMode(MessageDeliveryMode.PERSISTENT);
Message message = new Message("content".getBytes(), props);
rabbitTemplate.send("exchange", "routing.key", message);

极端情况：

消息写到RabbitMQ之后，但是还没有持久化到磁盘之后直接挂了，导致内存中消息丢失。

解决方法：持久化与生产者的confirm机制配合，当且仅当持久化了消息之后，再confirm，避免数据与消息丢失，此时生产者收不到ack，也是可以自己重发

消费端丢失了数据

意思就是消息已经拉取到了信息，还没有处理（注意这是已经告诉MQ我拉取到数据了），结果进程挂了，重启之后继续消费下一条消息，导致中间的这一条没有消费到，此时数据丢失了。

利用ack机制处理

取消RabbiMQ的自动ack，也就是一个api，可以在消费端消费完了消息之后再调用api告诉MQ我们收到并且处理了该消息。如果没有返回ack，RabbitMQ会把该消息分配给其他的consumer处理，消息不会丢失。通过配置处理

spring:rabbitmq:listener:simple:acknowledge-mode: manual

Kakfa的消息可靠性

生产者的消息可靠性

在kafka中，可以在producer（生产段）设置一个参数，也就是ack=all，要求每个数据，必须写入所有的replica（也就是所有该分区的副本），才认为是接收成功。该参数设置的是你的leader接收到消息后，所有的follower都同步到消息后才认为写成功

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("acks", "all"); // 等待所有副本确认
props.put("retries", Integer.MAX_VALUE); // 无限重试
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");KafkaProducer<String, String> producer = new KafkaProducer<>(props);
ProducerRecord<String, String> record = new ProducerRecord<>("my-topic", "key", "value");producer.send(record, (metadata, exception) -> {if (exception == null) {System.out.println("发送成功：" + metadata.offset());} else {exception.printStackTrace();}
});
producer.close();

Kakfa的消息可靠性

kafka默认是会将消息持久化到磁盘上的，但是还是有情况会导致丢失数据

kafka某个broker宕机，随后重新选举partition的leader。倘若在该broker中的partition中的leader副本中的消息，还没有被其他broker中的follower同步，此时同步缺失的数据就丢失了，也就是少了一些数据

解决方法：

给 topic 设置 replication.factor 参数：这个值必须大于 1，要求每个 partition 必须有至少 2 个副本。
在 Kafka 服务端设置 min.insync.replicas 参数：这个值必须大于 1，这个是要求一个 leader 至少感知到有至少一个 follower 还跟自己保持联系。
在 producer 端设置 acks=all ：这个是要求每条数据，必须是写入所有 replica 之后，才能认为是写成功了。
在 producer 端设置 retries=MAX （很大很大很大的一个值，无限次重试的意思）：这个是要求一旦写入失败，就无限重试，卡在这里了。

按照上面的配置之后，leader的切换就不会导致数据缺失了。

消费者的消息可靠性

唯一可能也是类似于RabbitMQ中的，也就是说你消费到该消息的时候，消费者自动提交offset，让kafka以为你消费好了该消息，但是自己还没处理就宕机后，会导致重启后没有消费该消息。

解决方法：

关闭kafka默认的自动提交offset，通过消费端业务逻辑处理完消息后，再手动提交offset，当然这里就是会导致重复消费了，这里就是幂等性的问题了。比如你刚处理完，还没提交 offset，结果自己挂了，此时肯定会重复消费一次

手动提交api：consumer.commitSync();

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "my-group");
props.put("enable.auto.commit", "false"); // 关闭自动提交
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Arrays.asList("my-topic"));while (true) {ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));for (ConsumerRecord<String, String> record : records) {// 处理消息System.out.println("处理消息：" + record.value());}// 手动提交 offsetconsumer.commitSync();
}

消息队列如何保证消息可靠性（kafka以及RabbitMQ）

目录 RabbitMQ保证消息可靠性生产者丢失消息 MQ丢失消息消费端丢失了数据 Kakfa的消息可靠性生产者的消息可靠性 Kakfa的消息可靠性消费者的消息可靠性 RabbitMQ保证消息可靠性生产者丢失消息 1.事务消息保证生产者在发送消息之前，开启事务消息随后生…...

编程日记 2025/7/19 1:43:46

基于STM32、HAL库的BMP390L气压传感器驱动程序设计

一、简介： BMP390L 是 Bosch Sensortec 生产的一款高精度气压传感器，专为需要精确测量气压和海拔高度的应用场景设计。BMP390L 具有更低的功耗、更高的精度和更快的响应速度。二、硬件接口： BMP390L 引脚STM32L4XX 引脚说明VDD3.3V电源GNDGND地SCLPB6 (I2C1 SCL)I2C 时钟线…...

编程日记 2025/7/17 18:57:29

QMK键盘固件中LED锁定指示灯的配置与使用详解（实操部分+拓展）

QMK键盘固件中LED锁定指示灯的配置与使用详解大家好！今天就跟大家一起探索QMK固件中LED锁定指示灯的配置与使用。无论你是键盘DIY新手还是老司机，相信这篇教程都能帮你解锁新技能！一、基础配置：定义LED引脚在QMK固件中配置LED锁定指示灯非常简单，只需在config.h文件…...

编程日记 2025/7/14 1:29:18

【日撸 Java 三百行】Day 12（顺序表（二））

目录 Day 12：顺序表（二） 一、顺序表的方法 1. 顺序查找拓展：顺序查找中的哨兵思想 2. 插入 3. 删除二、代码及测试拓展： 小结 Day 12：顺序表（二） Task： 今天…...

编程日记 2025/7/14 14:54:29

Python爬虫实战：研究ajax异步渲染加密

一、引言在当今数字化时代，数据已成为推动各行业发展的核心驱动力。网络爬虫作为一种高效的数据采集工具，能够从互联网上自动获取大量有价值的信息。然而，随着 Web 技术的不断发展，越来越多的网站采用了 AJAX（Asynchronous JavaScript and XML）异步渲染技术来提升用户体…...

编程日记 2025/7/18 5:33:08

Golang企业级商城高并发微服务实战

Golang企业级商城高并发微服务实战包含内容介绍： 从零开始讲了百万级单体高并发架构、千万级微服务架构，其中包含Rpc实现微服务、微服务的跨语言调用jsonrpc和protobuf、protobuf的安装、protobuf高级语法、protobuf结合Grpc实现微服务实战、微服务服务…...

编程日记 2025/7/17 13:41:35

从经典力扣题发掘DFS与记忆化搜索的本质 -从矩阵最长递增路径入手一步步探究dfs思维优化与编程深度思考

1引子： DFS和递归法的一道经典例题矩阵最长递增子序列这个题写完之后脑袋产生了许多突发奇想： 1 第一个堆栈代码段这些底层C语言内部管理的工具它是怎么进行内存分配的？能不能深究？ 2 第二个这个DFS和计划数组存储的思路到底抽象…...

编程日记 2025/7/15 12:29:23

我开源了一个免费在线工具！UIED Tools

UIED Tools - 免费在线工具集合最近更新：修改了文档说明，优化了项目结构介绍这是设计师转开发的第一个开源项目，bug和代码规范可能有些欠缺。这是一个功能丰富的免费在线工具集合网站，集成了多种实用工具，包括 AI …...

编程日记 2025/7/12 20:10:45

geoserver发布arcgis瓦片地图服务（最新版本）

第一步：下载geoserver服务，进入bin目录启动需要提前安装好JDK环境，1.8及以上版本安装完成，页面访问端口，进入控制台界面,默认用户名密码admin/geoserver 第二步：下载地图破解版全能电子地图下载器&…...

编程日记 2025/7/18 13:58:04

RN 鸿蒙混合开发实践(踩坑)

#三方框架# #React Native # 1 。环境配置； 安装 DevEco 开发工具； Node 版本16； hdc环境配置 hdc 是 OpenHarmony 为开发人员提供的用于调试的命令行工具，鸿蒙 React Native 工程使用 hdc 进行真机调试。hdc 工具通过 OpenHa…...

编程日记 2025/7/18 20:51:52

2025年阿里云ACP大数据分析师认证模拟试题（附答案解析）

这篇文章的内容是阿里云ACP大数据分析师认证考试的模拟试题。所有模拟试题由AI自动生成，主要为了练习和巩固知识，并非所谓的 “题库”，考试中如果出现同样试题那真是纯属巧合。 1、ABC公司现有大量的图片和视频信息，以下哪种产…...

编程日记 2025/7/13 8:13:13

go语言实现IP归属地查询

效果: 实现代码main.go package mainimport ("encoding/json""fmt""io/ioutil""net/http""os" )type AreaData struct {Continent string json:"continent"Country string json:"country"ZipCode …...

编程日记 2025/7/17 4:32:01

Qt中解决UI线程阻塞导致弹窗无法显示的两种方法

在Qt应用程序开发中，我们经常会遇到这样的问题：当执行一个耗时操作时，整个界面会卡住，无法响应任何用户操作，甚至连一个简单的提示弹窗都无法正常显示。本文将介绍两种解决这个问题的方法，并通过完整的代码示例进行说明。问题描述先来看一个常见的错误示例： #inclu…...

编程日记 2025/7/17 14:14:36

位运算题目：黑板异或游戏

文章目录题目标题和出处难度题目描述要求示例数据范围解法思路和算法代码复杂度分析题目标题和出处标题：黑板异或游戏出处：810. 黑板异或游戏难度 8 级题目描述要求给定一个整数数组 nums \texttt{nums} nums，表示写在黑板…...

编程日记 2025/7/18 18:28:55

LegoGPT，卡内基梅隆大学推出的乐高积木设计模型

LegoGPT 是由卡内基梅隆大学开发的一款创新性乐高积木设计模型，能够根据用户的文本提示生成结构稳固、可组装的乐高模型。该模型基于自回归语言模型和大规模乐高设计数据集进行训练，用户只需输入简单的文字描述，LegoGPT 就能逐步构建出物理稳…...

编程日记 2025/7/13 1:32:11

深度 |国产操作系统“破茧而出”：鸿蒙电脑填补自主生态空白

真心为国内能有像华为这样的技术型公司而自豪，一步步突围技术封锁。从这篇信息，可以给软件从业者一个启示：鸿蒙生态将是一个新的机会，值得好好把握。鸿蒙电脑正成为中国电子信息技术新坐标。超10亿鸿蒙生态设备、2800家鸿蒙智…...

编程日记 2025/7/13 17:09:06

【Python】Python常用数据类型判断方法详解

在Python编程中，准确判断数据类型是处理逻辑分支、类型转换和异常处理的基础。本文结合核心方法与实践场景，系统介绍type()、isinstance()等常用判断方式，并分析其适用性与最佳实践。一、直接类型判断方法 type()函数 • 功能：返回对象的精确类型，适用于简单类型判断。 •…...

编程日记 2025/7/15 17:14:44

【美国将取消对能源之星支持严重影响AI服务器】

1992年美国政府在共和党执政期间推出了影响深远的“能源之星”计划（Energy Star），很多人可能并不知道能源执行计划，但这个蓝色星星标签估计大多数人都不会陌生。能源之星计划从推出以来不止得到各类消费电子制造商认可&#xff0c…...

编程日记 2025/7/16 20:50:50

《 C++ 点滴漫谈：三十七》左值？右值？完美转发？C++ 引用的真相超乎你想象！

摘要本文全面系统地讲解了 C 中的引用机制，涵盖左值引用、右值引用、引用折叠、完美转发等核心概念，并深入探讨其底层实现原理及工程实践应用。通过详细的示例与对比，读者不仅能掌握引用的语法规则和使用技巧，还能理解引用在性能…...

编程日记 2025/7/13 18:27:26

【生产实践】Linux中/usr/bin、/usr/sbin与/usr/local的关系解析（2025年技术规范）

一、核心定位与功能划分 /usr/bin：用户级通用命令库 • 定位：存储系统预装的用户级可执行文件，这些命令通常由Linux发行版官方软件包管理器（如APT、YUM）安装，属于系统默认功能的一部分。 • 示例命令&#…...

编程日记 2025/7/15 18:48:33

数据可视化：用一张图讲好一个故事

在这个信息爆炸的时代，数据无处不在，但如何让复杂的数据变得通俗易懂？数据可视化就是一把神奇的钥匙。它不仅能将枯燥的数字转化为生动的图像，还能挖掘出数据背后隐藏的故事。然而，很多人对数据可视化的理解还停留在表…...

编程日记 2025/7/14 19:51:33

C++获取目录中所有图片路径的函数get_image_paths解析

本文将全面解析一个用于获取目录中图片路径的C函数get_image_paths，从基础语法到高级概念，涵盖C标准库、文件系统操作、异常处理等多个方面。原始代码 std::vector<std::string> get_image_paths(const std::string& directory_path) {log_…...

编程日记 2025/7/18 7:18:02

物联网无线传感方向专业词汇解释

涡旋电磁波(VEMW)：一种具有轨道角动量的电磁波，其特性在于能够在传播过程中携带额外的相位信息，从而增加通信系统的容量和灵活性。波前：波动传播过程中，同一时刻振动相位相同的所有点构成的几何曲面，代表波…...

编程日记 2025/7/16 15:26:21

【C语言指针超详解(五)】--回调函数，qsort函数的理解和使用，qsort函数的模拟实现

目录一.回调函数 1.1--回调函数的概念 1.2--回调函数改造计算器程序二.qsort函数的理解和使用 2.1--qsort函数的理解 2.2--使用qsort函数排序整型数据 2.3--使用qsort函数排序结构数据三.qsort函数的模拟实现 🔥个人主页：草莓熊Lotso的个人主…...

编程日记 2025/7/16 17:23:26

【Linux网络】————HTTP协议详解

作者主页： 作者主页本篇博客专栏：Linux 创作时间 ：2025年5月11日 1. HTTP 协议介绍基本介绍： http协议全称：超文本传输协议，适用于从万维网服务器传输超文本到本地的传送协议。HTTP是一种应用层协议…...

编程日记 2025/7/14 21:10:33

使用WinSW工具将exe注册为window服务

下载工具WinSW(工具在GitHub上打不开就需要魔法VPN) 文件准备将以下文件放在同一个目录（例如：WebSocketService 文件夹）中： WebScoket.exe WinSW-x64.exe WebScoketService.xml ← 服务配置文件 install_service.bat ←…...

编程日记 2025/7/18 1:04:39

远程命令执行RCE概述

远程命令执行RCE诞生于1997年，比SQL注入早1年，据说当时的程序员发现在网站里可以随意的删除网页，就像删除本地文件一样简单，但是这种场景相对不多，因此没有SQL注入广泛，早期的web攻击像现在的护网一样&…...

编程日记 2025/7/15 15:57:17

在 .NET 8 开发的WinForms 程序中展示程序版本号的几种方式

前言欢迎关注dotnet研习社，今天我们讨论一个Winform开发中的一个常见的需求内容“关于程序的版本号显示”。在 WinForms 桌面应用程序开发中，向用户显示当前程序的版本号是一个常见的需求，尤其是在产品发布、更新提示或技术支持场景中尤为…...

编程日记 2025/7/15 2:25:05

[特殊字符] Spring Cloud 微服务项目中 common 模块依赖导致网关启动失败的排查与解决

在进行微服务开发时，我们通常会抽取一个 common 公共模块，封装一些通用配置类、工具类、拦截器、常用组件依赖等，供多个微服务共享使用。但近期在实际开发中，出现了一个典型问题：在 Gateway 网关模块中引入 common 后…...

编程日记 2025/7/17 7:59:17

Java SpringMVC 和 MyBatis 整合关键配置详解

目录一、数据源配置二、MyBatis 工厂配置三、Mapper 扫描配置四、SpringMVC 配置五、整合示例实体类Mapper 接口Mapper XML 文件Service 类控制器JSP 页面六、总结在 Java Web 开发中，SpringMVC 和 MyBatis 是两个常用框架。SpringMVC 负责 Web 层的请求处理和视图渲染，MyBa…...

编程日记 2025/7/18 19:07:25

24.（vue3.x+vite）引入组件并动态挂载（mount）

示例截图组件代码： <template><div><div>{{message }}</div>...

编程日记 2025/7/9 0:31:41

Linux 软件包|服务管理

rpm 指令备注rpm -qa查看已安装软件，可以结合grep过滤查找rpm -e firefox卸载firefoxrpm -ivh firefox-115.12.0-1.el7.centos.i686.rpm安装gcc（只能离线安装） yum 能够从指定的服务器自动下载 RPM 包并且安装指令备注yum list列出所有可…...

编程日记 2025/7/17 17:27:16

前端上传el-upload、原生input本地文件pdf格式(纯前端预览本地文件不走后端接口）

前端实现本地文件上传与预览（PDF格式展示）不走后端接口实现步骤第一步：文件选择使用前端原生input上传本地文件，或者是el-upload组件实现文件选择功能，核心在于文件渲染处理。（input只不过可以自定义样…...

编程日记 2025/7/13 16:47:58

TestNG接口自动化

第一章、 Rest assured接口测试框架一、概述接口自动化的框架，主要是用来做接口自动化测试，返回的报文都是JSON 语法比较简单，只需要掌握常用的方法用例运行的速度非常快断言的机制 Json 封装相关方法，jsonpath，x…...

编程日记 2025/7/14 18:49:47

Parasoft C++Test软件单元测试_实例讲解（指针类型的处理）

系列文章目录 Parasoft C++Test软件静态分析：操作指南（编码规范、质量度量）、常见问题及处理 Parasoft C++Test软件单元测试：操作指南、实例讲解、常见问题及处理 Parasoft C++Test软件集成测试：操作指南、实例讲解、常见问题及处理进阶扩展：自动生成静态分析文档、自动…...

编程日记 2025/7/16 14:23:46

ngx_http_keyval_module动态键值管理

一、模块安装与验证检查模块是否可用 nginx -V 2>&1 | grep --color -o ngx_http_keyval_module如果看到 ngx_http_keyval_module，说明模块已编译进 NGINX。若未找到，请联系你的 NGINX 供应商，获取商业版或重新编译并启用该模块&am…...

编程日记 2025/7/17 7:47:19

面试篇：Spring MVC

基础概念什么是Spring MVC？ Spring MVC 是 Spring Framework 提供的一个基于 Servlet 的 Web 框架，属于 MVC（Model-View-Controller）架构的一种实现。它通过 DispatcherServlet 作为前端控制器，对请求进行分发和调度…...

编程日记 2025/7/19 1:09:09

目录 1.string::find(char ch,size_t pos0) const的模拟实现 2.string::find(const char* str,size_t pos0) const的模拟实现 3.string::size() const和string::capacity() const的模拟实现 4.string::operator[] (size_t pos)和string::operator[] (size_t pos) const的模拟…...

编程日记 2025/7/13 21:23:24

接口出现请求参数格式错误的解决方法

目录前言1. 问题所示2. 原理分析3. 解决方法前言 🤟 找工作，来万码优才：👉 #小程序://万码优才/r6rqmzDaXpYkJZF 爬虫神器，无代码爬取，就来：bright.cn Java基本知识： java框架零基础从入门到精通的学习路线附开源项目面经等（超全）【Java项目】实战CRUD的功能整理…...

编程日记 2025/7/18 13:39:39

MYSQL时间函数、group by 和partition by的区别、组内编号leetcode学习

mysql时间函数 select now(); --当前时间 select current_date() --当前日期 select current_timestamp --同now()select date(2025-04-14 12:34:56) --提取日期部分：2025-04-14 select datediff(2025-4-14,2025-04-10) 日期相差四天 select date_sub(2024-04-14,…...

编程日记 2025/7/16 19:08:31

OpenCV 的 CUDA 模块中用于将一个多通道 GpuMat 图像拆分成多个单通道图像的函数split()

操作系统：ubuntu22.04 OpenCV版本：OpenCV4.9 IDE:Visual Studio Code 编程语言：C11 算法描述 cv::cuda::split 是 OpenCV CUDA 模块中的一个函数，用于将一个多通道的 GpuMat 图像拆分成多个单通道的 GpuMat 图像。这个函数是 CP…...

编程日记 2025/7/15 11:45:38

吴恩达机器学习笔记：单变量线性回归

通过一个例子来开始：这个例子是预测住房价格的，我们要使用一个数据集，数据集包含俄勒冈州波特兰市的住房价格。根据不同房屋尺寸所售出的价格，画出我的数据集。比方说，如果房子是 1250 平方尺大小，你要告诉…...

编程日记 2025/7/17 0:27:25

UI自动化测试框架：PO 模式+数据驱动

🍅 点击文末小卡片，免费获取软件测试全套资料，资料在手，涨薪更快 1. PO 设计模式简介什么是 PO 模式？ PO（PageObject）设计模式将某个页面的所有元素对象定位和对元素对象的操作封装成…...

编程日记 2025/7/16 7:57:46

NestJS 知识框架

一、核心概念 1. 架构基础基于 Express/Fastify 的 Node.js 框架采用模块化设计使用 TypeScript 构建（也支持 JavaScript） 借鉴 Angular 的设计理念 2. 主要组件模块 (Module): 应用的基本组织单元控制器 (Controller): 处理 HTTP 请求服务…...

编程日记 2025/7/16 19:33:00

Porting Linux to a new processor architecture, part 1: The basics

Although a simple port may count as little as 4000 lines of code—exactly 3,775 for the mmu-less Hitachi 8/300 recently reintroduced in Linux 4.2-rc1—getting the Linux kernel running on a new processor architecture is a difficult process. Worse still, the…...

编程日记 2025/7/16 1:45:15

RabbitMQ保证消息可靠性

生产者丢失消息

MQ丢失消息

消费端丢失了数据

Kakfa的消息可靠性

生产者的消息可靠性

Kakfa的消息可靠性

消费者的消息可靠性

相关文章：