本文是该系列的第五篇。第一篇: 模式第二篇: OAuth第三篇: 对话第四篇: 消息对于实时消息，我们将使用 服务器发送事件 Server-Sent Events 。这是一个打开的连接，我们可以在其中传输数据流。我们会有个端点，用户会在其中订阅发送给他的所有消息。消息户端在 HTTP 部分之前，让我
2024-07-17
相信很多的小伙伴在面试的时候，涉及到MQ的面试题，消息丢失是必问面试题之一。那么对于消息丢失你又是如何理解的呢？下面我们一起来看一下。本文以 Kafka 举例说明。一、什么是消息丢失？消息丢失的定义是：在消息传递的过程中，在某个环节意外丢失，也就是消息没有成功的发送或者没有被正确的接收。生产者未能成
2024-06-06
在上一篇文章中，我们对MQ中的消息丢失有了一定的了解，相信再次被面试官问到时心里也就有了底气了。文章的地址我放在下面，还没有看的可以跳过去看一下。面试官：对于MQ中的消息丢失你是如何理解的？我们经常说的消息堆积通俗点讲就是消费者消费不了了，造成消息在MQ中堆着，然后越来越多，所以说消息堆积是在消费者
2024-06-06
在分布式系统中，消息队列扮演着至关重要的角色，它解耦了系统组件，提高了系统的可扩展性和可靠性。然而，在使用消息队列时，我们经常会遇到一些问题，如消息丢失、顺序消费、消息积压和重复消费。本文将深入探讨这些问题的原因，并提供相应的解决方案。1. 消息丢失消息丢失可能发生在生产者、消息队列或消费者中的任何
2024-06-05
大家好，我是三友~~这篇文章我准备来聊一聊RocketMQ消息的一生。不知你是否跟我一样，在使用RocketMQ的时候也有很多的疑惑：消息是如何发送的，队列是如何选择的？消息是如何存储的，是如何保证读写的高性能？RocketMQ是如何实现消息的快速查找的？RocketMQ是如何实现高可用的？消息是在
2024-06-04
通常来说，使用消息队列主要能为我们的系统带来下面三点好处：异步处理削峰/限流降低系统耦合性除了这三点之外，消息队列还有其他的一些应用场景，例如实现分布式事务、顺序保证和数据流处理。如果在面试的时候你被面试官问到这个问题的话，一般情况是你在你的简历上涉及到消息队列这方面的内容，这个时候推荐你结合你自己
2024-05-29
我是码哥，可以叫我靓仔。今天来聊一聊 Kafka 消息队列的使用场景和核心架构实现原理，帮助你全面了解 Kafka 其内部工作原理和设计理念。。Apache Kafka 是一个高吞吐量、分布式的流处理平台，广泛应用于实时数据管道和流处理应用中。Kafka 以其高性能、低延迟、扩展性和可靠性，成为了大
2024-05-28
作为一个程序员，假设你有 A、B 两个服务，A 服务发出消息后，不想让 B 服务立马处理到。而是要过半小时才让 B 服务处理到，该怎么实现？这类延迟处理消息的场景非常常见，举个例子，比如我每天早上到公司后都会点个外卖，我希望外卖能在中午送过来，而不是立马送过来，这就需要将外卖消息经过延时后，再投递到
2024-05-22
前言 因为工作中需要用到分布式的延时队列，调研了一段时间，选择使用 Redisson DelayedQueue，为了搞清楚内部运行流程，特记录下来。 总体流程大概是图中的这个样子，初看一眼有点不知从何下手，接下来我会通过以下几点来分析流程，相信看完本文你能了解整个运行流程。 基本使
2024-05-13
本篇文章不再介绍RabbitMQ具体实现原理，直接介绍如何保证消息的可靠性问题。所谓可靠性，指消息不重不漏。文章导读图片生产者消费者模型 生产者-消费者模型用于描述两类进程（生产者和消费者）之间的数据交互。可以被认为是独立的服务，生产者负责生成数据，消费者负责处理这些数据。在分布式系统中，队列在其
2024-05-09
马不停蹄地，让我们开始第一个章节。这篇博客是一个引子，从一个故事开始，讲述数据在OceanBase的存储引擎中的存储形式与流转过程，希望能让大家对OceanBase的存储架构产生印象。 在世界的某一处，温柔的风正将空气中的水汽卷向云层。慢慢地，天空中逐渐形成了厚厚的积云，当积云无法再承受
2024-05-07