2 天前 / u561252
#本文翻译自 StreamNative 博客《Achieving Broker Load Balancing with Apache Pulsar》。 作者 Heesung Sohn、王锴，StreamNative 开发工程师。 校对与整理：StreamNative。 译者简介王中兴，eBay 消息中间件团队成员。 简介本文将探讨负载均衡在分布式计算系统中的重要性，并深入分析 Pulsar 处理 Broker 负载均衡的方式。首先我们介绍 Pulsar 中的 Topic-Bundle 分组、Bundle-Broker 归属关系以及负载数据模型。然后讲解 Pulsar 的负载均衡逻辑，通过时序图来展示 Bundle 的分配、拆分和缩减过程。
229 天前 / kafeidou
Spring 官方的 RSocket Broker 其实开发已经非常久了，我以为会伴随着 Spring Cloud 2021.0 发布的，但是没有发生。不过 Spring RSocket Broker 还是发布了最新的 0.3 版本，虽然还是预览版，但目前已经可用，考虑官方还没有提供对应的文档，大家入门做 Demo 还有些困难，所以这篇文章就是帮你快速入门 Spring RSocket Broker，同时解析一下 RSocket Broker 的特性。 一 Spring RSocket Broker 架构 首先让我们看一下 Spring RSocket Broker 的架构图，如下： RSocket Broker 为一个集群对外提供服务，其主要服务就是应用注册和 RSocket 请求的转发...
1064 天前 / 公众号「后端进阶」
Broker 启动的主函数入口： org.apache.rocketmq.broker.BrokerStartup: public static void main(String[] args) { start(createBrokerController(args));}1.创建配置类 初始化配置主要任务是根据 properties 文件以及命令行参数值，创建了以下配置类： nettyServerConfig：封装了作为消息队列服务器的配置信息nettyClientConfig：封装了作为NameServer客户端配置信息brokerConfig：封装了 Broker 配置信息messageStoreConfig：封装了 RocketMQ 存储系统的配置信息 1.Broker 初始化 2.1 配置文件加载 主题配置加载： result = result && t...
1122 天前 / 虞大胆
正如人们在各种日常活动中存在着形形色色的代理机制一样，在计算机科学领域，代理机制乃是解决各种复杂难解问题的基本途径之一。 小到对象/实体之间的通信，大到子系统、系统乃至超系统的设计，都会应用到代理。应用的广泛导致了代理有着不同的形态，主要有Agent、Proxy、Broker和Delegate。弄清各种代理的异同，对于理解系统的设计和实现，是有帮助的。 Agent：自主性代理Agent是分布智能的基础单元。它具有一定程度的独立行为能力与智能,同时又遵从分布系统中某种统一的标准。在分布式环境中，Agent 可以和客户端不在一台主机上。
1522 天前 / 柳年思水
本篇接着讲述 Controller 对于监听器的处理内容 —— Broker 节点上下线的处理流程。每台 Broker 在上线时，都会与 ZK 建立一个建立一个 session，并在/brokers/ids下注册一个节点，节点名字就是 broker id，这个节点是临时节点，该节点内部会有这个 Broker 的详细节点信息。