发简信
IP属地：海南
[TOC] 前言 本文主要讲解常用加密算法，消息摘要，二进制字符变换等的java实现，对于加密算法本身的原理只会做简单的介绍，详细的原理可百度。 相关概念 加密 加密是指将可...
AuthorizationSlot在SystemSlot之前吧。图上画错了
【sentinel】深入浅出之原理篇SlotChain最近在负责做网关类系统，需要考虑做限流熔断功能，基于QPS，基于线程数，对于集群，单机做限流，熔断，而Sentinel能满足我的所有需求，配置接入方便，设计上很适合做扩展。关...
每个Topic都有一个所属的Broker，所以读写都是通过该Broker进行的。这样提供了很多的好处。 Broker可以将日志的尾部缓存在内存中，这意味着Broker可以不需...
Ledgers和Fragments是在Zookeeper中维护和跟踪的逻辑结构。物理上数据不存储在Ledgers和Fragments对应的文件中。BookKeeper中存储的...
broker简介： pulsar broker是无状态的，Bookeeper集群本身并不执行复制，每个Bookies只是一个跟随者被领导者同志做什么，领导人是Pulsar B...
Pulsar中的逻辑存储体系使用的是Apache BookKeeper。本文仅在Pulsar的背景下介绍BookKeeper。 BookKeeper将数据存储至集群中的节点上...
参考：Apache Pulsar 消息传递模型(1)-消息模型Apache Pulsar 消息传递模型(2)-消息确认Apache Pulsar 消息传递模型(3)-消息保留
设计理念 保证不丢失消息(使用正确的配置且不是整个数据中心故障) 强顺序性保证 可预测的读写延迟 Apache Pulsar选择一致性而不是可用性就像BookKeeper和Z...
与传统的消息传递系统相比，消息在被确认后不会立即被删除。Pulsar在接收消息确认时仅更新cursor,只有在所有订阅已经使用它之后才有可能删除消息。 1 Message r...
当使用跨机器分布的消息传递系统时，可能会发生故障。在消费者从消息传递系统中的主题消费消息的情况下，消费消息的消费者和服务于主题分区的消息代理都可能失败。当发生这样的故障时，能...
1 消息消费 目前的消息流式架构中，消息用例被分为两类：队列和流 Apache Pulsar将队列和流统一为消息传递模型：producer-topic-subscriptio...
1 准备工作 操作系统：macOs运行环境：java8 2 集群组成 zk集群（3个节点）bk集群（3个节点）pulsar集群（3个节点） 3 搭建过程 3.1 zk集群搭建...
订阅模型 Pulsar提供了灵活的消息模型，支持三种订阅类型： Exclusive subscription：排他，只能有一个Consumer，接收一个Topic所有的消息 ...
pulsar和其他的发布订阅系统一样，Pulsar 中的 topic 是被命名的通道，用做从producer到 consumer传输消息。 Topic的名称是具有明确定义结构...
Pulsar 是一个用于服务器到服务器的消息系统，具有多租户、高性能等优势。 Pulsar 最初由 Yahoo 开发，目前由 Apache 软件基金会管理。 Pulsar 的...
