Kafka网络通信模型

本文主要是介绍Kafka网络通信模型，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

先说NIO reactor

原始的方式 全部一个线程完成

• networkclient
• acceptor
• dispathch
• hander
• networkclient

增加一个处理器负责处理业务 Processor 线程池专门处理 handler

• networkclient
• acceptor
• (多线程)Processor pool 【新增】
• dispathch
• hander
• networkclient

主从Reactor多线程模式 增加一个 认证线程

• networkclient
• acceptorpool(多线程) 【新增】
• acceptor dispathch
• acceptor
• (多线程)Processor pool
• Processor dispathch
• hander
• networkclient

kafaka模型

• networkclient
• acceptor
• ProcessorPool
• ProcessorPool dispathch to requestQueuePool
• requesthanderPool from requestQueuePool
• requesthanderPool dispathch to apis
• apis to requestQueuePool
• requestQueuePool to ProcessorPool
• ProcessorPool to networkclient

requesthanderPool(多线程)from request queue] --->

这篇关于Kafka网络通信模型的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！