OceanBase的网络框架
OceanBase的网络框架代码如下: class ObSingleServer { public: //设置工作线程个数 int set_thread_count(const int thread_count); //设置网络I/O线程个数 int set_io_thread_count(const int io_thread_count); //设置监听端口 int set_listen_port(const int listen_port); public: //处理接收到的网络包,默认的处理逻辑是将网络包加入到全局任务队列中 virtual int handlePacket(ObPacket* packet); // 工作线程每次从全局任务中抽取一个网络包并调用该函数进行处理 virtual do_request(ObPacket* packet); }; OceanBase服务端接收客户端发送的网络包(ObPacket),并交给handlePacket处理函数进行处理。默认情况下,handlePacket会将网络包加入到全局任务队列中。接着,工作线程会从全局任务队列中不断获取...