Kafka Server Reactor设计模型

简介: Kafka Server Reactor设计模型

image.png

image.png

Acceptor

监听客户端的连接请求,并建立和客户端的数据传输通道,然后为这个客户端指定一个Processor,它的工作就到此结束,这样它就可以去响应下一个客户端的连接请求了。

Processor

主要职责是负责从客户端读取数据和将响应返回给客户端,它本身不处理具体的业务逻辑,每个Processor都有一个Selector,用来监听多个客户端,因此可以非阻塞地处理多个客户端的读写请求,Processor将数据放入RequestChannel的RequestQueue中和从ResponseQueue读取响应。


Handler(kafka.server.KafkaRequestHandler,kafka.server.KafkaApis)的职责是从RequestChannel中的RequestQueue取出Request,,处理以后再将Response添加到RequestChannel中的ResponseQueue中。


目录
相关文章
|
消息中间件 Java Kafka
Spring Boot集成Kafka动态创建消费者与动态删除主题(实现多消费者的发布订阅模型)
Spring Boot集成Kafka动态创建消费者与动态删除主题(实现多消费者的发布订阅模型)
17088 1
Spring Boot集成Kafka动态创建消费者与动态删除主题(实现多消费者的发布订阅模型)
|
8月前
|
消息中间件 Java Kafka
聊聊 Kafka: Consumer 源码解析之 poll 模型
聊聊 Kafka: Consumer 源码解析之 poll 模型
267 0
|
10月前
|
消息中间件 存储 Kafka
Kafka 实战开篇-讲解架构模型、基础概念以及集群搭建(下)
Kafka 实战开篇-讲解架构模型、基础概念以及集群搭建(下)
149 0
|
10月前
|
消息中间件 NoSQL 中间件
Kafka 实战开篇-讲解架构模型、基础概念以及集群搭建(上)
Kafka 实战开篇-讲解架构模型、基础概念以及集群搭建
167 0
|
消息中间件 存储 缓存
【Kafka源码】万字长文详解Kafka网络模型、副本机制(下)
【Kafka源码】万字长文详解Kafka网络模型、副本机制
139 0
【Kafka源码】万字长文详解Kafka网络模型、副本机制(下)
|
消息中间件 存储 设计模式
一文读懂kafka消息拉取机制|线程拉取模型
一文读懂kafka消息拉取机制|线程拉取模型
一文读懂kafka消息拉取机制|线程拉取模型
|
消息中间件 Kafka
面试必问 | 聊聊Kafka的消费模型?
面试必问 | 聊聊Kafka的消费模型?
223 0
面试必问 | 聊聊Kafka的消费模型?
|
消息中间件 存储 负载均衡
Kafka实战(二)-Kafka消息模型核心概念(下)
Kafka实战(二)-Kafka消息模型核心概念(下)
193 0
Kafka实战(二)-Kafka消息模型核心概念(下)
|
消息中间件 存储 NoSQL
Kafka实战(二)-Kafka消息模型核心概念(上)
Kafka实战(二)-Kafka消息模型核心概念(上)
151 0
Kafka实战(二)-Kafka消息模型核心概念(上)
|
消息中间件 缓存 网络协议

热门文章

最新文章