zoukankan      html  css  js  c++  java
  • Kafka2.0服务端写入和读取流程

    写入流程

      Kafka 服务端通过KafkaApishandle()方法来统一处理请求,ApiKeys枚举了能被handle() 方法处理的请求类型吗,如果是PRODUCE类型,表示有生产者客户端发送了消息,之后将消息传递给副本管理器处理。

      副本管理器会将消息追加到分区 leader 副本的日志文件中,然而实际上并不是直接写入磁盘的,Kafka 会将日志的段 segment 缓存到跳跃表ConcurrentSkipListMap。写入日志时,首先会从缓存中查找段,如果能找到,则向该段中追加记录,记录包含日志文件、索引文件、时间戳文件。日志文件会被写入FileChannel 中,索引文件和时间戳文件会被写入MappedByteBuffer中。最后,后台调度程序会周期地将段文件刷新到磁盘持久化。

      如果段缓存中没有找到合适的段,则通过FileChannel来打开一个新的段,返回磁盘文件的段映射,封装为 segment 后,再缓存到跳跃表中,供下一次追加日志时使用。

    日志的写入处理流程

    写入日志流程

    索引和偏移量的写入处理流程

    写入索引和偏移量流程

    读取流程

      如果请求是FETCH类型,表示有消费者客户端发送了拉取请求,同样,将请求传递给副本管理器处理。

      副本管理器在写入日志时,将段缓存到了跳跃表中,因此读取时,可以直接从跳跃表中获取段,向该段发起读取操作。首先,利用二分查找算法,查找mmap中的索引文件,根据索引文件记录的日志偏移量,遍历查找FileChannel中的日志文件所在的位置,最后,根据偏移量和需要拉取的大小获取日志片段,返回给消费者。

    日志的读取处理流程

    读取日志流程

  • 相关阅读:
    oracle 常用SQL
    ActiveMQ持久化方式
    集中队列的模式
    EDA: Event-Driven Architecture事件驱动架构
    ActiveMQ消息队列介绍
    Nginx 用log_format设置日志格式
    log4j的ConversionPattern参数的格式含义
    真正的轻量级WebService框架——使用JAX-WS(JWS)发布WebService
    Java的注解机制——Spring自动装配的实现原理
    java interface 默认值
  • 原文地址:https://www.cnblogs.com/bigshark/p/11210876.html
Copyright © 2011-2022 走看看