消息队列MQ

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网络通信模型的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！
您可能喜欢
栏目导航