你的位置:首页 > 信息动态 > 新闻中心
信息动态
联系我们

Pulsar源码解析

2021/12/30 17:38:41

一、消息的生产与发送

  1. 连接建立
    Pulsar源码解析-客户端-PulsarClient构建
  2. 生产者创建(包含Topic创建原理)
    Pulsar源码解析-非分区Producer创建的底层实现
    Pulsar源码解析-分区Producer创建的底层实现
  3. 消费者创建
    Pulsar源码解析-客户端-单个消费者ConsumerImpl创建底层实现
    Pulsar源码解析-客户端-多消费者MultiTopicsConsumerImpl创建底层实现
    Pulsar源码解析-服务端-消费者创建的底层实现
  4. 生产者-发送消息原理
    Pulsar源码解析-客户端-生产者消息发送底层实现
    Pulsar源码解析-服务端-Producer消息发送底层实现
  5. 消费者-消费消息原理
    Pulsar源码解析-客户端-单个消费者ConsumerImpl创建底层实现
    Pulsar源码解析-客户端-多消费者MultiTopicsConsumerImpl创建底层实现
    Pulsar源码解析-客户端-消费者接收消息的底层实现
    Pulsar源码解析-服务端-消费者消息拉取的底层实现