消息队列系统

  
共有 1241 2 3 4 ... 9 下一页

事件模式:使用幂等消费者(收件箱)检测重复消息

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

2023年流Stream预测 - tspann

23-01-01 504 1k

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

ActiveMQ中虚拟目的地

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

基于Spring Integration和Apache Camel的SEDA

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

亚马逊的分布式计算宣言 - werner

22-11-17 947 6k

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

Postgres 序列问题如何影响您的消息传递保证 ?

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

Knative Eventing 的三种实现方法 | Mete

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

Dendrite项目从Kafka迁移到NATS

22-10-06 510 1k

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

事件驱动API架构的五个协议

22-10-02 627 6k

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

Timestone:Netflix 的高吞吐量、低延迟优先队列系统

22-09-30 658

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

Apache Camel 路由简介

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

消息队列和消息总线有什么区别?

22-07-22 820

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

Apache Kafka重试和维护重试事件的顺序

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

RabbitMQ的脑裂踩坑 - ryanrodemoyer

22-07-17 1007 1 4k

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

Golang漏桶算法限速 - ITNEXT

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