本文是该系列的第五篇。 第一篇: 模式 第二篇: OAuth 第三篇: 对话 第四篇: 消息 对于实时消息，我们将使用 服务器发送事件 Server-Sent Events 。这是一个打开的连接，我们可以在其中传输数据流。我们会有个端点，用户会在其中订阅发送给他的所有消息。 消息户端 在 HTTP 部分之前，让我们先编写一个 映射 map ，让所有客户端都监听消息。 像这样全局初始化： type

相信很多的小伙伴在面试的时候，涉及到MQ的面试题，消息丢失是必问面试题之一。那么对于消息丢失你又是如何理解的呢？ 下面我们一起来看一下。 本文以 Kafka 举例说明。 一、什么是消息丢失？ 消息丢失的定义是：在消息传递的过程中，在某个环节意外丢失，也就是消息没有成功的发送或者没有被正确的接收。 生产者未能成功发送消息。 消费者未能正确接收消息。 消费者未能正确处理消息。 对于第三条可以理解为特殊

在上一篇文章中，我们对MQ中的消息丢失有了一定的了解，相信再次被面试官问到时心里也就有了底气了。 文章的地址我放在下面，还没有看的可以跳过去看一下。 面试官：对于MQ中的消息丢失你是如何理解的？ 我们经常说的消息堆积通俗点讲就是消费者消费不了了，造成消息在MQ中堆着，然后越来越多，所以说消息堆积是在消费者阶段的问题。 那么发生消息堆积的原因有哪些呢？ 一、消息堆积的原因 消费者挂掉。 消费者与 M

在分布式系统中，消息队列扮演着至关重要的角色，它解耦了系统组件，提高了系统的可扩展性和可靠性。然而，在使用消息队列时，我们经常会遇到一些问题，如消息丢失、顺序消费、消息积压和重复消费。本文将深入探讨这些问题的原因，并提供相应的解决方案。 1. 消息丢失 消息丢失可能发生在生产者、消息队列或消费者中的任何一个环节。为了防止消息丢失，我们可以采取以下措施： 生产者确认机制：确保消息已成功发送到队列。许

大家好，我是三友~~ 这篇文章我准备来聊一聊RocketMQ消息的一生。 不知你是否跟我一样，在使用RocketMQ的时候也有很多的疑惑： 消息是如何发送的，队列是如何选择的？ 消息是如何存储的，是如何保证读写的高性能？ RocketMQ是如何实现消息的快速查找的？ RocketMQ是如何实现高可用的？ 消息是在什么时候会被清除？ ... 本文就通过探讨上述问题来探秘消息在RocketMQ中短暂而

通常来说，使用消息队列主要能为我们的系统带来下面三点好处： 异步处理 削峰/限流 降低系统耦合性 除了这三点之外，消息队列还有其他的一些应用场景，例如实现分布式事务、顺序保证和数据流处理。 如果在面试的时候你被面试官问到这个问题的话，一般情况是你在你的简历上涉及到消息队列这方面的内容，这个时候推荐你结合你自己的项目来回答。 异步处理 通过异步处理提高系统性能 将用户请求中包含的耗时操作，通过消息队

我是码哥，可以叫我靓仔。今天来聊一聊 Kafka 消息队列的使用场景和核心架构实现原理，帮助你全面了解 Kafka 其内部工作原理和设计理念。。 Apache Kafka 是一个高吞吐量、分布式的流处理平台，广泛应用于实时数据管道和流处理应用中。 Kafka 以其高性能、低延迟、扩展性和可靠性，成为了大数据生态系统中的重要组件。 1.消息队列有什么作用 消息队列是一种进程间通信或者同一个进程中不同

作为一个程序员，假设你有 A、B 两个服务，A 服务发出消息后，不想让 B 服务立马处理到。而是要过半小时才让 B 服务处理到，该怎么实现？ 这类延迟处理消息的场景非常常见，举个例子，比如我每天早上到公司后都会点个外卖，我希望外卖能在中午送过来，而不是立马送过来，这就需要将外卖消息经过延时后，再投递到商家侧。 那么问题就来了，有没有优雅的解决方案？当然有，没有什么是加一层中间层不能解决的，如果有，

前言 因为工作中需要用到分布式的延时队列，调研了一段时间，选择使用 Redisson DelayedQueue，为了搞清楚内部运行流程，特记录下来。 总体流程大概是图中的这个样子，初看一眼有点不知从何下手，接下来我会通过以下几点来分析流程，相信看完本文你能了解整个运行流程。 基本使用 内部数据结构介绍 基本流程 发送延时消息 获取延时消息 初始化延时队列 基本使用 发送延迟消息代码如下，发送了一条

本篇文章不再介绍RabbitMQ具体实现原理，直接介绍如何保证消息的可靠性问题。所谓可靠性，指消息不重不漏。 文章导读 图片 生产者消费者模型   生产者-消费者模型用于描述两类进程（生产者和消费者）之间的数据交互。可以被认为是独立的服务，生产者负责生成数据，消费者负责处理这些数据。在分布式系统中，队列在其中扮演了消息（数据）传递的功能。 图片 关于消息队列的作用，一般解读为： 解耦：生产者和消费

马不停蹄地，让我们开始第一个章节。这篇博客是一个引子，从一个故事开始，讲述数据在OceanBase的存储引擎中的存储形式与流转过程，希望能让大家对OceanBase的存储架构产生印象。  在世界的某一处，温柔的风正将空气中的水汽卷向云层。慢慢地，天空中逐渐形成了厚厚的积云，当积云无法再承受更多的时候，它开始发出轰隆隆的雷鸣声。不一会儿，淅淅沥沥的雨落到了山林，形成了一条不大不小的林间小溪