240 发简信
IP属地:北京
  • Apache Pulsar 源码走读(五)服务端消息流转逻辑概述

    版权归本人所有,如果转载请联系本人 这篇大致说一下消息从写入到读取在Apache Pulsar服务端是怎么串起来的。( 这篇不会详细说明每个逻辑怎么走的,不过会给读者一个整体...

  • Apache Pulsar 源码走读(四)TopicLookup请求处理(二)

    上一篇说到实际的核心逻辑是这2行代码 这里传递的参数将loadTopicsInBundle 设置了成true。我们看下在处理lookup请求过程中是否有loadtopic的逻...

  • Apache Pulsar 源码走读(三)TopicLookup 请求处理(一)

    简单逻辑说明通过topic名字确定namespace查找这个namespace的bundle分配信息根据bundle分配信息来确认这个topic属于哪个bundle根据bun...

  • 120
    Apache Pulsar 源码走读(二)二进制协议

    pulsar 使用protocolBuf 作为二进制协议编写的工具 本文主要说明其中几个主要的RPC 的作用。并大致说一下这个几个RPC会被使用的位置。具体每个字段的含义会在...

  • Apache Bookkeeper —— SingleDirectoryDBLedgerStorage

    主要成员变量 主要作用 可以读写ledger,维护ledger的位置(index) 保存ledger相关的metadata 支持checkpoint 写入Entry 写入会直...

  • Apache Bookkeeper —— Journal 源码分析

    简单梳理一下这个类的作用和逻辑。 主要功能 充当WAL 写请求处理:首先在Bookkeeper服务端收到了写Entry的请求之后会交给Bookie来处理Bookie.addE...

  • 120
    PulsarClient 解析(一)

    PulsarClient 让我们看一下这个类的主要方法 创建producer/consumer/reader 元数据信息相关 transaction相关 close方法 Cl...

  • Apache Pulsar 源码走读(一)启动

    1.启动入口 PulsarStandaloneStarter在standalone模式下,主要启动了以下几个服务 PulsarService PulsarAdmin Loca...

  • 深夜学算法之SkipList:让链表飞

    1. 前言 上次写Python操作LevelDB时提到过,有机会要实现下SkipList。摘录下wiki介绍: 跳跃列表是一种随机化数据结构,基于并联的链表,其效率可比拟二叉...