消息队列系统

23-01-22 695 3k

检测重复消息的唯一方法是在生产者端为事件生成一个唯一标识符。只有使用这些标识符，消费者才可能知道它第二次处理同一条消息，而不是具有相同属性的不同消息。为了防止两次处理同一条消息，常用的方法是将它... 详细

23-01-01 552 1k

Apache Pulsar、Apache Flink SQL as a Service、Apache Pinot等流Stream架构技术预测： Apache Pulsar 2023年，Pul... 详细

22-12-15 895 4k

虚拟目的地允许我们创建映射到一个或多个物理目的地的逻辑目的地。虚拟目的地是逻辑目的地，是映射到一个或多个物理目的地的队列或主题的组合。它提供松散耦合的消息传递配置，当应用程序在多个实例上运行时尤其... 详细

22-11-28 1035 6k

SEDA，或阶段化事件驱动架构，是Matt Welsh在他的博士论文中提出的一种架构风格。论文。它的主要优点是可伸缩性、支持高并发流量和可维护性。由于可伸缩性是SEDA的核心目标，因... 详细

22-11-17 1079 6k

在将近25年之后，我将完整地发表《分布式计算宣言》，这是亚马逊早期的一份内部文档，它改变了我们电子商务平台的架构。亚马逊的系统架构的一个非常简短的历史：在我们深入了解亚马逊的架构历史... 详细

22-11-01 1170 6k

让我们更深入地讨论在 Postgres 之上潜在的基于轮询的实现。假设我们将使用的表结构： CREATE TABLE publications( -- the autoinc... 详细

22-10-07 615 6k

当涉及到它支持的不同事件传递方法时， Knative Eventing 文档有点混乱。它讨论了事件代理和触发器，还讨论了源、服务、渠道和订阅。什么时候用什么？目前还不清楚。让... 详细

22-10-06 585 1k

Matrix 是建立在分布式数据结构之上的实时通信联合协议，Dendrite是一个按照微服务架构建立的Matrix家庭服务器的实现。我们使用 Kafka 作为在微服务组件之间分发事... 详细

22-10-02 698 6k

在这篇文章中，我们将讨论 5 种常见的事件驱动方法——WebSockets、WebHooks、REST Hooks、Pub-Sub和Server Sent Events。我们将定义它们的本质和作用，... 详细

22-09-30 749

Timestone：Netflix 的高吞吐量、低延迟优先队列系统，内置支持不可并行化的工作负载。 Timestone 是我们内部构建的高吞吐量、低延迟优先级排队系统，用于支持我们的媒体编码平台 ... 详细

22-09-14 713 2k

在这篇博客中，我们介绍使用 Apache Camel 框架进行面向消息开发的几个关键要素。它使开发人员能够集成多种技术并与各种端点（例如文件、队列和外部服务）进行数据通信，同时易于使用。介... 详细

22-07-22 976

消息队列消息队列是从一个应用程序接收一堆消息，并在先进先出（FIFO）的基础上将它们传递给一个或多个其他应用程序。消息队列由发布者和消费者组成。我们所说的发布者将消息留给队列。消费者也接收... 详细

22-07-21 884 7k

重试非常重要，尤其是在微服务系统中，这些服务必须经常协作才能处理请求。如果一个服务只中断了几秒钟会发生什么？其他服务应该在放弃之前向客户抛出错误或重试多次。举个简单的例子：通过http链式... 详细

22-07-17 1143 1 4k

我的手表嗡嗡作响，在黎明前的昏迷中，我无法辨认这是警报还是电话。时间是凌晨 4 点 45 分：我们最大的客户报告说他们的请求需要两个多小时才能返回结果。我们认为这是因为我们的RabbitMQ消息系统... 详细

22-06-23 1013 6k

分布式系统中最常见的可靠性模式之一是限制任务处理的速率。此任务可以是要处理的请求或事件。这样做是为了平滑流量的形状并避免流量突发，或者在底层系统运行时仅允许在任何给定时间进行最大特定数量的操作。速率... 详细