在kafka中。每个broker都是一个server。依照一般理解,server就是一个SocketServer,其不断接收用户的请求并进行处理。在Java中进行网络连接有两种方式一种为堵塞模式一种为非堵塞模式。

Jafka採用非堵塞模式进行网络通讯。在Java的非堵塞模式中,建立socket server的一般流程例如以下:

1.启动ServerSocketChannel并将其绑定到特定的port。

2.将ServerSocketChannel以及其感兴趣的操作注冊到Selector,在这里感兴趣的操作是Accept

3.不断轮询Selector是否有感兴趣的事件发生,假设有则accept远程连接并进行处理

以上基本上是全部网络编程的基本流程,jafka也不例外。在jafka中,类Acceptor具体负责server的实现。该实现比較简单,这里不再做具体的叙述。

须要注意的是,Acceptor接收client的请求后会把其交给Processor类进行处理。用户会在配置文件里配置Processor的个数,Acceptor会议、以round robin的方式将client连接交给Processor进行处理。

最新文章

  1. [项目]WebService涉及到的部分核心代码
  2. MySQL 处理插入过程中的主键唯一键重复值办法
  3. 感恩回馈,《ASP.NET Web API 2框架揭秘》免费赠送
  4. Integer 中的缓存类IntegerCache
  5. oracle信息统计
  6. jQuery学习笔记 - 基础知识扫盲入门篇
  7. java中 File文件常用操作方法的汇总
  8. Sublime Text 2配置
  9. 冒泡算法C#
  10. cadence原理图绘制方法
  11. Eclipse添加小工具_打开当前文件所在文件夹
  12. P73、面试题9:斐波那契数列
  13. winform 窗口点击窗体任意位置移动窗体
  14. 使用 WRK 压力测试工具对 ASP.NET Core 的接口进行压力测试
  15. Spring重温(二)--Spring JavaConfig
  16. [LeetCode&Python] Problem 543. Diameter of Binary Tree
  17. 【note】EtherCAT Configurator 使用之主菜单介绍
  18. C中typedef 函数指针的使用
  19. 如何获取codeforces的完整数据?(玄学方法)
  20. C#连接操作MySQL数据库详细步骤 帮助类等(二次改进版)

热门文章

  1. SDRAM学习笔记
  2. html b标签 语法
  3. Luogu P2309 loidc,卖卖萌
  4. CloudSim学习
  5. HDU3465--Life is a Line(树状数组求逆序数,离散化)
  6. sqli-lab(16)
  7. 阿里菜鸟知识储备之二——git工具学习
  8. 【Django】搭建Django administration并登录
  9. Spring Boot 访问到页面返回数据乱码
  10. UNITY ET 框架