Uber如何安全保护Kafka基础设施?

Uber 拥有世界上最大的 Apache Kafka 部署之一。它支持 Uber 的大量实时工作流,包括用于传递来自骑手和司机应用程序的事件数据的发布-订阅消息总线,以及后端服务之间的金融交易事件

2 年 前

数据总线(Data Bus)

沟通 你希望组件彼此不了解 数据总线类似于 中介模式,数据总线成员自己决定是否接受任何给定的消息 观察者模式,但支持多对多通信 发布/订阅模式,数据总线将发布服务器和订阅服务器

4 年 前

【求助】JMS的持久性解决办法??急!

我用jboss,怎样管理一个主题里的消息?? 1,我发现一个消息发出去后并没有保存,如果先发布,再订阅的话就无法收到之前发布的信息。我怎样才能在订阅后也能收到主题里所有发过的信息??又怎样删除主题里

10 年 前

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

。 消息总线 消息总线不保证先进先出(FIFO)。订阅消息总线的订阅者可以在不知道发布者的情况下接收已发布的消息。这些模式也称为 pub/sub。 消息由发送 API 发布到总线,然后任何订阅了任何

1 年 前

消息数据库Message DB:PostgreSQL的事件存储和消息存储 - Eventide Blog

Eventide Project团队很高兴宣布Message DB:这是一款基于 PostgreSQL中 作为发布/订阅、事件溯源和事件 微服务 应用程序实现的、功能齐全的事件存储和消息存储

4 年 前

Event Sourcing and Domain Event

domain event是一致的,这个event最终也会发布到event bus上供外部的subscriber消费。但是仔细想想,又觉得十分的不妥。Domain event为什么要包含那么多的信息?外部的订阅

10 年 前

比较Apache Pulsar 和Apache Kafka:统一排队和流式传输 - splunk

。他们按分区顺序消费消息。它们最适用于需要严格排序的流用例。另一方面,共享订阅允许每个主题分区有多个消费者。同一订阅中的每个消费者只接收发布到主题分区的部分消息。共享订阅最适合不需要排序的排队用例

2 年 前

使用Redis PubSub与Spring Boot实现微服务消息模型 - vinsguru

PubSub是用于 微服务 体系结构中服务到服务通信的 异步 消息传递模型:一个服务(发布者,而不是将消息发送给特定的收件人),它发布的消息到一个主题/通道,通过有关各个订阅

3 年 前

未来互联网新模式

发布中心,发布者将他们的内容数据发布到合适的hub通道中,订阅者通过hub通道接受数据. hub的美丽之处在于:HUB能够将数据广播推送到每个订阅者那里。容易伸缩,并且是实时推送,每当发布者有什么新的

10 年 前

甲骨文再次更改Java许可规则:基于员工数量收费

甲骨文再次更改Java收费规则:将 Java 许可收费更改为按用户而不是按处理器 ,价格可能因此会上涨很多。 甲骨文Oracle 自 1 月 23 日起启用新的 Java SE 通用订阅 :这

1 年 前

刚做了一个EDA类库,大家给看看

恩,本人对 EDA 类库有几个基本的需求: 1、支持POCO,消息本身不能继承父类,这样利于序列化和远程传输 2、不能使用字符串作为消息标识,这样容易造成拼写错误 3、消息订阅发布要尽量简单

10 年 前

RabbitMQ新的持久的、可复制的分布式事务一致的仲裁队列 – Richard Seroter

内容大概是: 开启第一个应用是消息发布者,第二个应用是消息的订阅者,第三个应用将在时间到时关闭RabbitMQ节点,模拟故障宕机。 开启消息发布,会看到发布者正在发布订阅者正在订阅。消息从仲裁队列按

4 年 前

事件驱动架构EDA中的组件

通知,这些事件可以从了解它中受益。因此,最早的实时事件驱动系统提出了发布/订阅的概念。 发布/订阅是描述面向事件的消息传递的另一种方式。在发布/订阅范式中,有发布者和订阅者。这些是所有发布/订阅系统

1 年 前

JMS消息在消费者处于集群环境下如何过滤重复数据

目前真实项目中遇到的问题,现在有个订单系统A负责接收来自淘宝,京东旗舰店上传过来的订单数据,进行订单数据验证过滤后将订单信息发布称jms的topic发布在MQ服务器上,有两个消息的监听系统分别为售后

10 年 前

.NET遵循CQRS-ES架构的EventFlow的DDD + CQRS + Event-sourcing源码

  该示例包含以下概念,每个概念如下所示 聚合Aggregates 命令总线和命令 同步订阅 事件存储( GES ) 内存中读取模型。 快照( MongoDb ) Saga 事件发布

3 年 前