本文是该系列的第五篇。第一篇: 模式第二篇: OAuth第三篇: 对话第四篇: 消息对于实时消息，我们将使用 服务器发送事件 Server-Sent Events 。这是一个打开的…
相信很多的小伙伴在面试的时候，涉及到MQ的面试题，消息丢失是必问面试题之一。那么对于消息丢失你又是如何理解的呢？下面我们一起来看一下。本文以 Kafka 举例说明。一、什么是消息丢…
在上一篇文章中，我们对MQ中的消息丢失有了一定的了解，相信再次被面试官问到时心里也就有了底气了。文章的地址我放在下面，还没有看的可以跳过去看一下。面试官：对于MQ中的消息丢失你是如…
在分布式系统中，消息队列扮演着至关重要的角色，它解耦了系统组件，提高了系统的可扩展性和可靠性。然而，在使用消息队列时，我们经常会遇到一些问题，如消息丢失、顺序消费、消息积压和重复消…
大家好，我是三友~~这篇文章我准备来聊一聊RocketMQ消息的一生。不知你是否跟我一样，在使用RocketMQ的时候也有很多的疑惑：消息是如何发送的，队列是如何选择的？消息是如何…
通常来说，使用消息队列主要能为我们的系统带来下面三点好处：异步处理削峰/限流降低系统耦合性除了这三点之外，消息队列还有其他的一些应用场景，例如实现分布式事务、顺序保证和数据流处理。…
我是码哥，可以叫我靓仔。今天来聊一聊 Kafka 消息队列的使用场景和核心架构实现原理，帮助你全面了解 Kafka 其内部工作原理和设计理念。。Apache Kafka 是一个高吞…
作为一个程序员，假设你有 A、B 两个服务，A 服务发出消息后，不想让 B 服务立马处理到。而是要过半小时才让 B 服务处理到，该怎么实现？这类延迟处理消息的场景非常常见，举个例子…
前言 因为工作中需要用到分布式的延时队列，调研了一段时间，选择使用 Redisson DelayedQueue，为了搞清楚内部运行流程，特记录下来。 总体流程大概是图中的这个样子，…
本篇文章不再介绍RabbitMQ具体实现原理，直接介绍如何保证消息的可靠性问题。所谓可靠性，指消息不重不漏。文章导读图片生产者消费者模型 生产者-消费者模型用于描述两类进程（生产…
马不停蹄地，让我们开始第一个章节。这篇博客是一个引子，从一个故事开始，讲述数据在OceanBase的存储引擎中的存储形式与流转过程，希望能让大家对OceanBase的存储架构产生印…
