Dojo
话题
新佳
订阅
极道
元认知
元逻辑
元设计
元编程
元语言
ESB消息总线技术
事件总线和消息队列的区别
了解事件总线 Event Bus 和消息队列 Message Queue 之间的差异可以帮助架构师和开发人员根据他们的特定需求决定使用哪种模式。在本文中,我们将探讨 Event Bus 和 Message Queue 之间的区别,并根据各种场景提供有关使用哪种模式的见解。
为什么我们放弃 RabbitMQ 并用 Postgres 队列取而代之?
我们最近从我们的系统中删除了 RabbitMQ,并将其替换为构建在我们的 Postgres 数据库之上并用 SQL 编写的队列。它极大地提高了我们系统的可靠性和弹性。这是对这一变化、其背后的基本原理以及我们是如何做到的的记录。 注意:这不是
一张图比较:RabbitMQ、Kafka和ActiveMQ
RabbitMQ: 基于Erlang构建 支持多种协议,包括AMQP、MQTT和STOMP。 以开发人员友好而闻名。 非常适合多个消费者的复杂路由。 Kafka: 基于Scala和Java
如何选择使用API或消息传递 ?
让我们首先看看API,它似乎是最主要的选择: APIAPI定义了允许两个应用程序相互通信的契约。这种契约的形式是服务器承诺提供的协议和样式,而客户应该遵守。 AP
东南亚Grab如何降低Kafka流量成本?
Grab 是东南亚领先的超级应用平台,提供对消费者重要的日常服务。Grab 不仅仅是一款叫车和送餐应用程序,还在该地区提供广泛的按需服务,包括移动、食品、包裹和杂货配送服务、移动支付以及遍及 8 个国家 428 个城市的金融服务。 Grab 的实时
类似“银联”的美国银行间即时支付系统FedNow上线
美联储周四宣布,其新的即时支付系统 FedNow 服务现已上线。各种规模的银行和信用社都可以注册并使用这一工具,在一年中的任何一天的任何时间为客户即时转账。 首先,35 家早期采用的银行和信用社以及美国财政部财政服务局已准备好通过 FedNow 服
Redpanda简介
在本教程中,我们将讨论一个名为Redpanda的强大事件流平台。这是对事实上的行业流媒体平台Kafka 的竞争,有趣的是,它还与 Kafka API 兼容。 我们将了解 Redpanda 的关键组件、功能和用例,创建用于将消息发布到 Redpanda 主题
使用 Java JMS 读取和写入 IBM MQ 队列
在本教程中,我们将学习如何使用 Java JMS(Java 消息服务)从 IBM MQ 队列读取和写入消息。 在本文中: 我们探讨设置 JMS 连接、会话和消息生产者/接收者以与 IBM MQ 队列交互的过程。 我们还介绍 IBM
Java运行时添加Camel路由
Apache Camel是一个 Java 框架,可以轻松实现各种企业集成模式 (EIP),从而为企业集成提供解决方案。 集成模式中的常见任务之一是根据特定规则和条件确定运行时的消息路由。Apache Camel 通过提供一种实现动态路由器 EIP
KIP-932:Kafka用作一个简单的队列
简单队列要求:无消息排序要求 想使用Kafka作为一个简单的队列? 有了新的KIP-932:引入共享(消费者)群体 之前的Kafka消费者组Kafka常
绕开事件驱动架构5个坑
事件驱动架构 (EDA) 并不是什么新鲜事物,如果您四处搜索,您一定会找到很多有关此架构概念的信息。 您会了解企业服务总线 (ESB) 或队列的差异、领域驱动设计 (DDD) 的重要性,甚至找到有关如何编码流、实现连接器、使用架构注册表等的指南。
Apache Kafka – 集群架构
Apache Kafka 到目前为止已经非常适合开发可靠的互联网规模的流应用程序,这些应用程序还具有容错能力,并且能够处理实时和可扩展的需求。在本文中,我们将重点介绍 Java 中的 Kafka 集群架构。 在本文中,我们将了解 Apache Kafka
企业集成两种架构模式
在本文中,我们将探讨一些可用于不同集成项目的架构模式。 在详细介绍集成架构之前,了解集成架构中常用的组件及其应用很有用。 1、集成平台:这是集成架构的主要组成部分。集成平台执行集成流程并提供一组连
如何在Camel中Post一个请求?
Apache Camel是一个强大的开源集成框架。它提供了一套成熟的组件来与各种协议和系统进行交互,包括HTTP。 在本文中,我们将学习如何使用 Apache Camel 向外部服务器发出 POST 请求。我们首先定义一个使用 JSON 字符串和
Spring Boot和Dapr实现发布/订阅消息传递
在本文中,我们使用 Spring Boot 和 Dapr 构建了一个松耦合的发布/订阅消息系统。通过利用 Dapr 对消息代理的抽象及其与 Spring Boot 的集成,我们简化了消息传递逻辑,而无需依赖特定的基础架构。我们还演示了如何使用 Testcontainers 在本地运行和测试整个设置,
MuleSoft:批处理的最佳实践
在当今数据驱动的世界中,组织经常需要高效、准确地处理大量数据。无论是迁移大量数据集、在系统之间同步记录,还是执行复杂的数据转换,批处理在确保这些任务可靠、按时完成方面都发挥着关键作用。 本文深入探讨了 Mule 4 中批处理的最佳实践,并提供了有关如何设计
每秒百万消息,Kafka如何精准记账?
在本文中,我们将介绍 Kafka 如何管理底层偏移量、您必须准备应对的故障场景,以及偏移量如何帮助您保持系统一致性(即使服务不断启动和停止)。我们还将了解其他技术如何应对类似的挑战。 关键: Kafka怎么记录消息读到哪儿了?
Go进程内pub/sub事件总线:快Channel4倍
Go应用程序的简单内部事件总线, 高性能:每秒处理数百万个事件,比Go原来的普通Channel快 4 倍到 10 倍。 快速的进程内事件调度程序 这个包为Go提供了一个高性能的进程内事件调度器,非常适合解
下页
关闭