zoukankan      html  css  js  c++  java
  • Jafka源码分析——网络架构

    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进行处理。

查看全文
  • 相关阅读:
    【精品软件】小蔡电脑助手 V2.0
    C++ 数据结构与算法(二)线性表之单链表
    C++ 数据结构与算法:冒泡排序及改进算法
    C++ 数据结构与算法(四)线性表之循环链表
    const int *p、int*const p、和 int const *p 详解
    C++ 指针和引用的区别
    C++ 数据结构与算法(三)线性表之双向链表
    C++ 数据结构与算法(一)线性表之顺序表
    C++数据结构与算法:选择排序
    VC++ 获取文件夹大小
  • 原文地址:https://www.cnblogs.com/ldxsuanfa/p/10962146.html
  • Copyright © 2011-2022 走看看