干货总结：新一代消息缓冲区 Pulsar

ition1、 Partition2、 Partition3、 Partition4 、 Partition5 五个八区， Partition1 和 Partition4 由 Broker1 妥善处理， Partition2 和 Partition5 由 Broker2 妥善处理， Partition3 由 Broker3 妥善处理。

从 Pulsar 社区原版的 golang-sdk 可以看不止，HTTP的 Producer 和 Consumer 在加载的时候，亦都会与每一个 Topic-Partition 创建人链接，并且都会NSA是否是有一新近 Partition，以创建人一新近连通。

1.2.2. 非无论如何 topic

都可用户只能， Pulsar 都会留有所有不想获知的立即到 BookKeeper 里。无论如何 Topic 的立即在 Broker 重为启或者 Consumer 不止现问题时留有下来。

除了无论如何 Topic ， Pulsar 也赞同非无论如何 Topic 。这些 Topic 的立即只普遍存在于内存里，不都会机密文件系统到机密文件系统。

1.2.3. 跳过 topic

由于业务自然语言妥善处理不止现异常，立即一般无需被再度商品。Pulsar 赞同产品销售同时将立即邮寄到都可的 Topic 和跳过 Topic ，并所选允许延时和仅次于跳过次数。当配备了允许生产者启动时跳过时，如果立即不想有人被商品成功，都会被留有到跳过 Topic 里，并在所选延时间隔时间后，再度被商品。

1.2.4. 死信 topic

当 Consumer 商品立即不止错时，可以通过配备跳过 Topic 对立即顺利启动跳过，但是，如果当立即至少了仅次于的跳过次数仍妥善处理最终时，该怎么办呢？Pulsar 发放了死信 Topic ，通过配备 deadLetterTopic，当立即降到仅次于跳过次数的时候， Pulsar 都会将立即启动时到死信 Topic 里顺利启动留有。

1.3. 订户（subion） 1.3.1. 订户并不一定（Subion type）

独占（Exclusive）SinglePartitionExclusive 下，只允许 Subion 普遍存在一个生产者，如果多个生产者常用同一个订户名称去订户同一个 Topic ，则都会报错。如下布，只有 Consumer A-0 可以商品数据库。 灾备（Failover）Failover 下，一个 Subion 里可以有多个生产者，但只有 Master Consumer 可以商品数据库。当 Master Consumer 断开连通时，立即都会由下一个被选里的 Consumer 顺利启动商品。如下布，Consumer-B-0 是 Master Consumer 。当 Consumer -B-0 最终发生问题与 Broker 断开连通时， Consumer-B-1 将带进下一个 Master Consumer 来商品数据库。 八区 Topic：Broker 都会按照生产者的队列和商品名的顺序排列对生产者顺利启动顺序排列，将 Topic 均匀地再度分配给队列极很低的生产者。 非八区 Topic：Broker 都会根据生产者订户的非八区 Topic 的间隔时间顺序排列选择生产者。 共享（Shared）Shared 里，多个生产者可以可选到同一个 Subion 上。立即通过 round robin 即轮询组态分领到有所不同的生产者，并且每个立即仅都会被分领到一个生产者。当生产者断开连通，所有被邮寄生产者但不想有人被获知的立即将被再度妥善处理，分领到其它能活的生产者。如下布, Consumer-C-1 、 Consumer-C-2 、 Consumer-C-3 都可以订户 Topic 商品数据库。 Key_SharedKey_Shared 里，多个 Consumer 可以可选到同一个 Subion 。立即在传输给 Consumer 时，具有不同键的立即只都会传输给同一个 Consumer 。

1.3.2. 订户方式也（Subion modes）

Durable （无论如何订户）：列上是或多或少的，都会保留立即并保持列上历史记录的位置。当 Broker 再度启动时，可以从 BookKeeper 里恢复列上，立即可以从列上去年历史记录的位置最终商品。都可用户只能，都是无论如何转化成订户。 NonDurable（非无论如何订户）：列上不是或多或少的，当 Broker 宕机时，列上都会丢失并不能恢复，所以立即不能最终从去年商品的位置开始最终商品。 1.3.3. 多意象订户 正则表达式，例如：persistent://public/default/finance-.* 确切所选 Topic 列表 2. Pulsar 产品销售 （Producer）

Producer 是连通 topic 的程序，它将立即公开发计划表到一个 Pulsar broker 上。

2.1. 到访方式也

立即转转化成者有多种方式也到访 Topic ，可以常用以下几种方式将立即邮寄到 Topic 。

Shared：都可用户只能，多个转转化成者可以将立即邮寄到同一个 Topic。 Exclusive：在这种方式也下，只有一个产品销售可以将立即邮寄到 Topic ，当其他产品销售在此之后邮寄立即到这个 Topic 时，都会最终发生错误。只有独占 Topic 的产品销售最终发生宕机时（Network Partition ）该产品销售都会被驱逐，一新近产品销售才能产生并向 Topic 邮寄立即。 WaitForExclusive：在这种方式也下，只有一个产品销售可以将立即邮寄到 Topic 。当已有转转化成者和 Topic 建立连通时，其他产品销售的创建人都会起而不都会产生错误。如果希望要转用领导者选举组态来选择生产者的话，可以转用这种方式也。 2.2. TCP方式也

当将立即邮寄到八区 Topic 时，无需所选立即的TCP方式也，这立即了立即将都会被邮寄到哪个八区 Topic 。Pulsar 有以下三种立即TCP方式也，RoundRobinPartition 为都可用户TCP方式也。

RoundRobinPartition：如果立即不想有人所选 key，为了降到仅次于并能量，产品销售都会以 round-robin （轮询）方式将立即公开发计划表到所有八区。比如说 round-robin 并不是作主要用途任意实际上的立即，而是作主要用途延后妥善处理的批次边境线，以适当批妥善处理适当。如果立即所选了 key，八区产品销售都会根据 key 的 hash 绝对值将该立即再度分配到互换的八区。这是都可用户的方式也。 SinglePartition：如果立即不想有人所选 key，产品销售将都会随机选择一个八区，并公开发计划表所有立即到这个八区。如果立即所选了 key，八区产品销售都会根据 key 的 hash 绝对值将该立即再度分配到互换的八区。 CustomPartition：快捷键方式也，用户可以创建人快捷键TCP方式也，通过发挥作用 MessageRouter 模块发挥作用快捷键TCP规范。 2.3. 试验性妥善处理

Pulsar 赞同对立即顺利启动试验性妥善处理。试验性妥善处理开业后， Producer 都会在一次请里总和并邮寄一批立即。试验性妥善处理时的立即比例有所不同仅次于立即数（单次试验性妥善处理请可以邮寄的仅次于立即数）和仅次于公开发计划表延后（单个请的仅次于公开发计划表反向）立即。掀开试验性妥善处理后，再加的比例是试验性妥善处理的请据统计，而不是立即据统计。

2.3.1. 目录获知组态

通常只能，只有 Consumer 获知了试验性请里的所有立即，这个试验性请才都会被认定为已妥善处理。当这批立即不想有人全部被获知的只能，最终发生故障时，都会致使一些已获知的立即被重为复获知。

为了避开 Consumer 重为复商品已获知的立即， Pulsar 从 Pulsar 2.6.0 开始转用试验性目录获知组态。如果开业试验性目录获知组态， Consumer 将筛选不止已被获知的试验性目录，并将试验性目录获知请邮寄 Broker 。Broker 控管试验性目录的获知精神状态并监控每批目录的获知精神状态，以避开向 Consumer 邮寄已获知的立即。当该批讯息的所有目录都被获知后，该批讯息将被删减。

都可用户只能，目录获知组态处于中止精神状态。掀开目录获知组态将产生致使更为多内存所需。

2.3.2. key-based batching

key_shared 方式也下，Broker 都会根据立即的 key 来分发立即，但都可用户的试验性妥善处理方式也，不能适当将所有的不同的 key 都自带到同一批里，而且 Consumer 在送降到批数据库时，都会都可用户把第一个立即的 key 当作这批立即的 key ，这都会致使立即的错乱。因此 key_shared 方式也下，不赞同都可用户的试验性妥善处理。

key-based batching 能够适当 Producer 在自带立即时，将不同 key 的立即自带到同一批里，从而 consumer 在商品的时候，也能够商品到所选 key 的批数据库。

不想有人所选 key 的立即在自带成批后，这一批数据库也是不想有人 key 的， Broker 在分发这批立即时，都会常用 NON_KEY 作为这批立即的 key 。

2.4. 立即并行

开业并行后，如果立即不等至少允许邮寄的仅次于立即不等时， Producer 都会将零碎立即分割成多个并行立即，并将并行立即与立即的软件包按顺序排列邮寄到 Broker。

在 Broker 里，并行立即都会和都可立即以不同的方式机密文件系统在 Ledger 里。唯一的区别是， Consumer 无需内存并行立即，并在送降到所有的并行立即后将其合并成无论如何的立即。如果 Producer 不能立即公开发计划表立即的所有并行， Consumer 不能在立即的大试验性间隔时间内送降到所有的并行，那么 Consumer 已送降到的并行立即就都会大试验性。

Consumer 都会将并行的立即拼接在独自一人，并将它们加到送达器算子调用里。HTTP从送达器算子调用里商品立即。当 Consumer 商品到零碎的大立即并获知后， Consumer 就都会邮寄与该大立即共同点的所有并行立即的获知。

2.4.1. 妥善处理一个 producer 和一个订户 consumer 的并行立即

如下布标明，当产品销售向意象邮寄一批大的并行立即和都可的非并行立即时。推论产品销售邮寄的立即为 M1，M1 有三个并行 M1-C1，M1-C2 和 M1-C3。这个 Broker 在其监管的 Ledger 之；还有留有所有的三个块立即，然后以不同的顺序排列分领到生产者（独占/灾备方式也）。生产者将在内存内存所有的块立即，直到寄送所有的立即块。将这些立即合并带进零碎的立即 M1，邮寄妥善处理进程。

2.4.2. 多个产品销售和一个产品销售妥善处理块立即

当多个产品销售公开发计划表块立即到单个意象，这个 Broker 在同一个 Ledger 之；还有留有来自有所不同产品销售的所有块立即。如下标明，产品销售 1 公开发计划表的立即 M1，M1 由 M1-C1, M1-C2 和 M1-C3 三个块一组。产品销售 2 公开发计划表的立即 M2，M2 由 M2-C1, M2-C2 和 M2-C3 三个块一组。这些特定立即的所有并行是顺序排列排列的，但是其在 Ledger 之；还有可能不是月份的。这种方式都会给生产者带来一定的内存负担。因为生产者都会为每个大立即在内存开辟一块缓冲区，以便将所有的块立即合并为零碎的大立即。

3. Pulsar 生产者 （Consumer）

Consumer 向 Broker 邮寄 flow permit request 以获取立即。在 Consumer 横有一个算子调用，主要用途送达从 Broker 启动时来的立即。

3.1. 立即获知

Pulsar 发放两种获知方式也：

总和获知：生产者只无需获知最后一条寄送的立即，在此此前的立即，都不都会被再行次邮寄生产者。 单条获知：生产者无需获知任意立即并邮寄 ack 给 Broker 。

如布，上方为总和获知方式也，当生产者邮寄 M12 的获知立即给 Broker 后， Broker 都会把 M12 此前的立即和 M12 一样都上标为已获知。下方为单条获知方式也，当生产者邮寄 M7 的获知立即给 Broker 后， Broker 都会把 M7 这条立即上标为已获知。当生产者邮寄 M12 的获知立即给 Broker 后， Broker 都会把 M12 这条立即上标为已获知。

3.1.1. AcknowledgmentsGroupingTracker

立即的单条获知和总和获知并不是直接邮寄获知请给 Broker，而是把请转交给 AcknowledgmentsGroupingTracker 妥善处理。

为了适当立即获知的精度，并避开 Broker 送降到非常很低并发的 ack 请，Tracker 都可用户赞同试验性获知，即使是单条立即的获知，也都会先转入算子调用，然后再行一批发往 Broker。在创建人 consumer 的时候，可以设 acknowledgementGroupTimeMicros，都可用户只能，每 100ms 或者大块至少 1000 时，AcknowledgmentsGroupingTracker 都会邮寄一批获知请。如果设为 0，则每次获知立即后，Consumer 亦都会立即邮寄获知请。

3.2. 叫停获知

当 Consumer 不能妥善处理一条立即并希望再度商品时， Consumer 可以邮寄一个叫停获知的立即给 Broker ， Broker 都会再度将这条立即邮寄 Consumer 。如果开业了试验性妥善处理，那这一批里的所有立即亦都会再度邮寄生产者。

如果开业了试验性妥善处理，那这一批里的所有立即亦都会再度邮寄生产者。

3.2.1. NegativeAcksTracker

叫停获知和其他立即获知一样，不都会立即请 Broker，而是把请转交给 NegativeAcksTracker 顺利启动妥善处理。Tracker 里历史记录着任意立即以及无需延后的间隔时间。Tracker 都可用户是 33ms 左右一个间隔时间记号顺利启动检查，都可用户反向是 1 分钟，抽走不止早已到期的立即并会有再度邮寄。Tracker 普遍存在的意义是为了合并请。另另有如果反向还不想到，立即都会暂普遍存在内存，如果业务横有大量的立即无需延后商品，还是劝告常用 reconsumeLater 模块。NegativeAck 唯一的好处是不无需任意立即都所选间隔时间，可以一个系统设反向。

3.3. redelivery backoff 组态

通常只能可以常用叫停获知来降到妥善处理立即最终后再度妥善处理立即的意在，但通过 redelivery backoff 可以更为好的发挥作用这种意在。可以通过所选立即跳过的次数、立即重为发的延后来再度商品妥善处理最终的立即。

3.4. 获知了事

除了叫停获知和 redelivery backoff 组态另有，还可以通过掀开启动时重为传输组态来妥善处理从未获知的立即。开业启动时重为传输后，client 都会在 ackTimeout 间隔时间内监控从未获知的立即，并在立即获知了事后启动时向全权负责再度邮寄从未获知的立即请。

如果掀开了试验性妥善处理，那这批立即亦都会再度邮寄 Consumer 。 与获知了事相比，叫停获知都会更为合适。因为叫停获知能更为正确地地控制单个立即的再行交付，并避开在立即妥善处理时引起的至少获知了事而致使无效的再行重为传。 3.5. 立即预拉取

Consumer HTTP SDK 都会都可用户预先拉取立即到 Consumer 本地，Broker 横都会把这些早已启动时到 Consumer 本地的立即历史记录为 pendingAck，这些立即既不都会再行邮寄给别的生产者，也不都会 ack 了事，除非当前 Consumer 被中止，立即才都会被再度邮寄。Broker 横有一个 RedeliveryTracker 模块，这个 Tracker 都会历史记录立即到底被再度邮寄了多少次，任意立即启动时给生产者时，都会先从 Tracker 的杂凑表里查询一下重为邮寄的次数，和立即一并启动时给生产者。

3.6. 从未获知的立即妥善处理

如果立即被生产者商品后一直不想有人获知怎么办？

unAckedMessageTracker 里控管了一个间隔时间轮，间隔时间轮的记号根据 ackTimeout 、tickDurationInMs 这两个参数转转化成，每个记号间隔时间= ackTimeout / tickDurationInMs。新近锁定的立即都会加到最后一个记号，每次配备亦都会清空算子调用竖第一个记号，并新近增一个记号加到算子调用细，适当记号据统计不变。每次配备，算子调用竖记号之里的立即将都会被清理，unAckedMessageTracker 都会启动时把这些立即做重为邮寄。

重为邮寄就是HTTP邮寄一个 redeliverUnacknowledgedMessages 立即给 Broker。每一条启动时给生产者但是从未 ack 的立即，在 Broker 横亦都会有一个等价来历史记录（pengdingAck），这是用来避开重为复邮寄的。会有重为邮寄后，Broker 都会把互换的立即从这个等价之里清空，然后这些立即就可以再行次被商品了。

4. Pulsar 客户服务横

Broker 是 Pulsar 的一个无精神状态元件，主要交由运转以下两个元件：

http 客户服务：发放为产品销售和生产者监管任务和 Topic 查询的 REST API。Producer 通过连通到 Broker 来邮寄立即， Consumer 通过连通到 Broker 来送达立即。 配备器；发放异步 http 客户服务，主要用途小数点数据库的传送。 4.1. 立即获知与现存

Pulsar Broker 都会都可用户删减早已被所有 Consumer 获知的立即，并以 backlog 的方式无论如何转化成机密文件系统所有从未被获知的内立即。

Pulsar 的 message retention(立即现存) 和 message expiry (立即大试验性)这两个特性可以修改 Broker 的都可用户设。

Message retention: 保留 Consumer 已获知的立即。通过现存规范的设定，可以适当早已被获知且合理现存规范的立即无论如何地留有在 Pulsar 里，而不想有人被现存规范覆盖、早已被获知的立即都会被删减。 Message expire（立即大试验性）：设从未获知立即的能活时长（TTL）。通过设立即的 TTL，有些即使还不想有人被获知，但早已至少 TTL 的立即，也都会被删减。 4.2. 立即去重为

发挥作用立即去重为的一种方式是适当立即仅转转化成一次，即产品销售幂等。这种方式的缺点是把立即去重为的岗位交给应用去做。

在 Pulsar 里， Broker 赞同配备掀开立即去重为，用户不无需为了立即去重为去修改 Producer 的代码。开业立即去重为后，即使一条立即被多次邮寄到 Topic 上，这条立即也只都会被无论如何转化成到机密文件系统一次。

如下布，从未掀开立即去重为时， Producer 邮寄立即 1 到 Topic 后， Broker 都会把立即 1 无论如何转化成到 BookKeeper ，当 Producer 又邮寄立即 1 时， Broker 都会把立即 1 再行一次无论如何转化成到 BookKeeper 。掀开立即去重为后，当 Producer 再行次邮寄立即 1 时， Broker 不都会把立即 1 再行一次无论如何转化成到机密文件系统。

4.2.1. 去重为原理

Producer 对每一个邮寄的立即，亦都会转用递增的方式转转化成一个唯一的 sequenceID，这个立即都会置放 message 的软件包里传输给 Broker 。同时， Broker 也都会控管一个 PendingMessage 算子调用，当 Broker 离开邮寄成功 ack 后， Producer 都会将 PendingMessage 算子调用里的对于的 Sequence ID 删减，表示 Producer 任务这个立即生产成功。Broker 都会历史记录针对每个 Producer 送降到的仅次于 Sequence ID 和早已妥善处理完的仅次于 Sequence ID。

当 Broker 掀开立即去重为后， Broker 都会对每个立即请顺利启动是否是去重为的辨别。寄送的最一新近 Sequence ID 是否是等于 Broker 横历史记录的两个维度的仅次于 Sequence ID，如果等于则不重为复，如果小于或等于则立即重为复。立即重为复时， Broker 横都会直接离开 ack，不都会最终走紧接著的机密文件系统妥善处理系统设计。

4.3. 立即延后传输

延时立即功能允许 Consumer 能够在立即邮寄到 Topic 后过一段间隔时间才能商品到这条立即。在这种组态里，立即在公开发计划表到 Broker 后，都会被机密文件系统在 BookKeeper 里，当到立即特定的反向时，立即就都会传输给 Consumer 。

下布为立即延后传输的组态。Broker 在机密文件系统延后立即的时候不都会顺利启动特殊的妥善处理。当 Consumer 商品立即的时候，如果这条立即设了反向，则都会把这条立即加入 DelayedDeliveryTracker 里，当到了所选的邮寄间隔时间时，DelayedDeliveryTracker 才都会把这条立即启动时给生产者。

4.3.1. 延后邮寄原理

在 Pulsar 里，可以通过两种方式发挥作用延后邮寄。分别为 deliverAfter 和 deliverAt。

deliverAfter 可以所选基本的反向指头，deliverAt 可以所选立即在多长间隔时间后商品。两种方式本质时一样的，deliverAt 方式下，HTTP都会量转化成不止基本的反向指头邮寄 Broker 。

DelayedDeliveryTracker 都会历史记录所有无需延后邮寄的立即的 index 。index 由 Timestamp、 Ledger ID、 Entry ID 三均一组，其里 Ledger ID 和 Entry ID 主要用途定位该立即，Timestamp 除了历史记录无需邮寄的间隔时间，还主要用途延后队列算子调用顺序排列。DelayedDeliveryTracker 都会根据反向对立即顺利启动顺序排列，反向最短的置放前面。当 Consumer 在商品时，如果有到期的立即无需商品，则根据 DelayedDeliveryTracker index 的 Ledger ID、 Entry ID 寻觅互换的立即顺利启动商品。如下布， Producer 左至右邮寄 m1、m2、m3、m4、m5 这五条立即，m2 不想有人设反向，所以都会被 Consumer 直接商品。m1、m3、m4、m5 在 DelayedDeliveryTracker 都会根据反向顺利启动顺序排列，并在到达反向时，左至右被 Consumer 顺利启动商品。

4.4. Bundle

我们知道， Topic 八区都会散推到有所不同的 Broker 里，那 Topic 八区和 Broker 的父子关系是如何控管的呢？当某个 Broker 扭矩过很低时， Pulsar 怎么妥善处理呢？

Topic 八区与 Broker 的共同点是通过 Bundle 组态顺利启动监管的。

每个 namespace 普遍存在一个 Bundle 列表，在 namesapce 创建人时可以所选 Bundle 的比例。Bundle 其实是一个移去组态，每个 Bundle 仅有 namespace 整个 hash 范围的一均。每个 Topic (八区) 通过 hash 运算落到都可的 Bundle 复线，进而寻觅当前复线共同点的 Broker 。每个 Bundle 可选唯一的一个 Broker ，但一个 Broker 可以有多个 Bundle 。

T3 的 hash 结果推到[0xC000000L——0x0000000L]里，这个 hash 范围的 Bundle 互换 Broker 3， Broker 3 都会对 T3 顺利启动妥善处理。

Bundle 可以根据可选的 Broker 的扭矩顺利启动动态的修改、可选。当 Bundle 可选的 Broker 的 Topic 数过多、扭矩过很低时，亦都会会有 Bundle 拆掉分，将改以的 Bundle 拆掉分成 2 个 Bundle ，并将其里一个 Bundle 再度再度分配给有所不同的 Broker ，以降低原 Broker 的 Topic 数或扭矩。

5. Pulsar 机密文件系统层（Bookkeeper）

BookKeeper 是 Pulsar 的机密文件系统元件。

对于 Pulsar 的每个 Topic（八区），其数据库并不都会固定的再度分配在某个 Bookie 上，基本的自然语言发挥作用我们在 Bundle 一节早已讨论过，而 Topic 的天体物理学机密文件系统，实际上是通过 BookKeeper 元件来发挥作用的。

5.1. 移去机密文件系统

种概念：

Bookie：BookKeeper 的一均，妥善处理无需无论如何转化成的数据库。 Ledger：BookKeeper 的机密文件系统自然语言三组，可主要用途新近增撰写数据库。 Entry：粘贴到 BookKeeper 的数据库实体。当试验性生产时，Entry 为多条立即，当非试验性生产时，Entry 为单条数据库。

Pulsar 在天体物理学上转用移去机密文件系统的方式也，机密文件系统粒度比八区更为细转化成、机密文件系统扭矩更为适度。如布，一个八区 Topic-Partition 2 的数据库由多个移去一组。每个移去作为 BookKeeper 里的一个 Ledger ，均匀的分布并机密文件系统在 BookKeeper 的多个 Bookie 链表里。

基于再度分配机密文件系统的组态，使得 Bookie 的适配可以即时启动，无需任何数据库粘贴或者移往。当 Bookie 适配时，Broker 可以立刻推断出并感知一新近 Bookie ，并在此之后将一新近移去 Segment 粘贴到新近减低的 Bookie 里。

如上布，在 Broker 里，立即以 Entry 的方式新近增的方式粘贴到 Ledger 里，每个 Topic 八区都有多个非月份 ID 的 Ledger，Topic 八区的 Ledger 同一时刻只有一个处于可撰写精神状态。

Topic 八区在机密文件系统立即时，都会先寻觅当前常用的 Ledger ，转转化成 Entry ID（每个 Entry ID 在同一个 Ledger 内是递增的）。当 Ledger 的较宽或 Entry 个数至少阈绝对值时，新近立即都会机密文件系统到新近 Ledger 里。每个 messageID 由[Ledger ID， Entry ID， Partition 编号，batch-index]一组。( Partition :立即归属于的 Topic 八区，batch-index:是否是为试验性立即)

一个 Ledger 都会根据 Topic 所选的副本比例机密文件系统到多个 Bookie 里。一个 Bookie 可以存放多个不月份的 Ledger。

5.2. 打字数据库的系统设计

Journals ：Journals 机密文件包含 BookKeeper 的公共事务历史记录讯息。在对 Ledger 更为新近此前， Bookie 都会适当更为一新近公共事务讯息早已粘贴到 Journals 。当 Bookie 启动或者才将的 Journals 不等降到阈绝对值时，就都会创建人一个一新近 Journals 。 Entry Logs：Entry Logs 监管从 Bookie 寄送的 Entry 数据库。来自有所不同 Ledger 的 Entry 都会按顺序排列肽键并粘贴到 Entry Logs ，这些 Entry 在 Entry Logs 里的偏移量都会作为指针留有在 Ledger Cache 里，以便快速查询。当 Bookie 启动或者才将的 Entry Logs 不等降到阈绝对值时，就都会创建人一个一新近 Entry Logs 。当才将的 Entry Logs 不想有人与任何活跃的 Ledger 共同点时，就都会被污水抽取器删减。 Index Files：每个 Ledger 亦都会创建人一个 Index file，它除此以另有一个竖和几个固定较宽的 Index page，这些 Index page 历史记录机密文件系统在 Entry Logs 里的 Entry 的偏移量。由于更为新近目录机密文件都会引入随机的机密文件系统 I/O，所以目录机密文件由后台运转的同步线程延后更为新近。这适当了更为一新近快速精度。在目录页无论如何转化成到机密文件系统此前，将它们挤满在 Ledger Cache 里以不方便查询。 Ledger Cache：Ledger Cache 存置放内存池里，这样可以更为很低效地监管机密文件系统竖配备。

5.2.1. 立即的粘贴到

1.将 Entry 新近增粘贴到 Ledger 里。

将这次 Entry 的更为新近操作者粘贴到 Journal 历史记录里，当由多个数据库粘贴到时，可以试验性提交，将数据库刷到 Journal 机密文件系统里。

将 Entry 数据库粘贴到撰写内存里。

离开粘贴到成功声势浩大。

到这之里，立即粘贴到的同步系统设计早已启动。

3-A. 内存里的 Entry 数据库都会根据 Ledger 和粘贴到 Ledger 的间隔时间顺序排列顺利启动顺序排列，试验性粘贴到 Entry Log 里。

3-B. Entry 在 Entry log 里的偏移量以 Index Page 的方式粘贴到 Ledger Cache 里，即 iIdex Files。

Entry Log 和 Ledger Cache 里的 Index File 都会 Flush 到机密文件系统里。

5.2.2. 立即的粘贴到

A.先从撰写内存里以细部中学毕业的方式粘贴到。

B.如果撰写内存从未命里，则从中学毕业内存里粘贴到。

C.如果中学毕业内存从未命里，则从机密文件系统里粘贴到。机密文件系统粘贴到有三步：

C-1.粘贴到 Index Disk，获取 Entry 的偏移量。

C-2.根据 Entry 的偏移量，在 Entry Disk 里快速寻觅 Entry 。

C-3.将 Entry 数据库粘贴到中学毕业内存里。

6. 参见文献

Pulsar 正式文件 BookKeeper 正式文件 【MQ Oteam】Apache Pulsar 技术第三部 - HTTP立即获知 【MQ Oteam】Apache Pulsar 技术第三部 - Message deduplication 这之里的去重为与你希望的可能不一样 【MQ Oteam】Apache Pulsar 技术第三部 - Pulsar 延后立即邮寄解析 Apache 第三部—Pulsar 核心特性解析。

南京看白癜风去哪家医院好
驻马店看妇科哪家医院好
汉中白癜风医院哪里好
四川男科医院预约挂号
株洲看妇科去哪里
什么家用血糖仪好用
家用血糖仪哪个好
哪种家用血糖仪比较好
思密达与肠炎宁颗粒的区别
自己家用的血糖仪选什么好