Socket接收器——Acceptor

Acceptor是JIoEndpoint的内部类,主要的职责就是监听是否有客户端套接字连接并接收socket,再将socket交由任务执行者(Executor)执行。不断从系统底层读取socket,接着做尽可能少的处理(最好就是接收到后不做任何处理),最后扔进线程池。为什么强调要做尽可能少的处理?这里关系到系统性能问题,过多的处理会严重影响吞吐量。因为tomcat默认只有一个接收器(一条线程负责套接字接收工作),所以它对每次接收处理的时间长短将很可能对整体性能产生影响。

于是接收器所干的活都是非常少且简单的,仅仅维护了几个状态变量、流量控制闸门的累加操作、serverSocket的接收操作、设置接收到的socket的一些属性、将接收到的socket放入线程池以及一些异常处理。其他需要较长时间处理的逻辑就交给了线程池,例如对socket底层数据的读取,对http协议报文的解析及响应客户端的一些操作等等。很精妙地将事务剥离,远远提升了系统处理响应性能。

图Acceptor

用一个简化的代码表示接收器处理的过程则是

publicclass Acceptor implements Runnable{

public void run(){

while(true){

limitLatch.countUpOrAwait();//流量控制闸门信号量加一

Socket socket =serverSocket.accept();

将接收的socket扔进线程池;

}

}

}

时间: 2024-10-13 22:48:06

Socket接收器——Acceptor的相关文章

75篇关于Tomcat源码和机制的文章

75篇关于Tomcat源码和机制的文章 标签: tomcat源码机制 2016-12-30 16:00 10083人阅读 评论(1) 收藏 举报  分类: tomcat内核(82)  版权声明:本文为博主原创文章,未经博主允许不得转载. 整理下前面写过的75篇关于Tomcat源码和机制的文章 文章列表 如何设计一个Web容器 Web安全认证机制知多少 Tomcat集群实现源码级别剖析 Tomcat集群如何同步会话 从单机到集群会话的管理之集群模式一 从单机到集群会话的管理之集群模式二(更大的集群

mina socket底层主流程源码实现

一,mina的架构 mina 架构可以大致分为三部分,ioService ,ioFilterChain , IoHandler ioService:用于接受服务或者连接服务,例如socket 接收器,连接器. ioFilterChain:对接受的数据或发送的数据进行处理,例如接收到的字节数组转化成字符串,打日志等. ioHandler:业务处理类,我们自己写的业务逻辑,例如对接受到的数据进行怎么样的数据,需要返回什么数据. 二,聊天室代码. 下面看下mina-2.0.9中聊天室例子.聊天室服务器

boost.asio系列——socket编程

asio的主要用途还是用于socket编程,本文就以一个tcp的daytimer服务为例简单的演示一下如何实现同步和异步的tcp socket编程. 客户端 客户端的代码如下: #include <iostream>    #include <boost/array.hpp>    #include <boost/asio.hpp> using boost::asio::ip::tcp; int main(int argc, char* argv[])    {    

Android与Mina集成

简介 Apache MINA(Multipurpose Infrastructure 多功能框架 for Network Applications) 是 Apache 组织一个较新的项目,它为开发高性能和高可用性的网络应用程序提供了非常便利的框架.当前发行的 MINA 版本支持基于 Java NIO 技术的 TCP/UDP 应用程序开发.串口通讯程序,MINA 所支持的功能也在进一步的扩展中. Apache官方网站:http://mina.apache.org Android用jar包等资源 h

套接字工厂——ServerSocketFactory

接收器Acceptor在接收连接的过程中,根据不同的使用场合可能需要不同的安全级别,例如在支付相关的交易就必须对信息加密后再发送,这其中还涉及到密钥协商的过程,而在另外一些普通场合则无需对报文加密.反应到应用层则是使用http与https的问题,具体跟http/https相关的一些知识请到前面相关章节温习. 看一张跟https协议的组成层次图,它在应用层添加了一个TLS\SSL协议,于是组成了https协议.简单讲TLS\SSL协议给每次通信①提供认证服务,认证本次会话实体身份的合法性.②提供加

任务执行器——Executor

上节说到接收器Acceptor在接收到socket后会有一系列简单的处理,其中将socket扔进线程池是最重要的一步,线程池是一个怎样东西?其原理在前面的"线程池原理"章节已经说明过了,这里重点讲tomcat中用于处理客户端请求的线程池--Executor. 为确保整个web服务器的性能,应该在接到请求后以最快的速度转交到其他线程上去处理.在接收到客户端的请求后tomcat将对这些请求交给任务执行器Executor,它是一个拥有最大最小线程数限制的线程池,之所以称之为"任务执

Boost.Asio技术文档

Christopher Kohlhoff Copyright ? 2003-2012 Christopher M. Kohlhoff 以Boost1.0的软件授权进行发布(见附带的LICENSE_1_0.txt文件或从http://www.boost.org/LICENSE_1_0.txt) Boost.Asio是用于网络和低层IO编程的跨平台C++库,为开发者提供了C++环境下稳定的异步模型. 综述 基本原理 应用程序与外界交互的方式有很多,可通过文件,网络,串口或控制台.例如在网络通信中,完

boost::asio译文

Christopher Kohlhoff Copyright © 2003-2012 Christopher M. Kohlhoff 以Boost1.0的软件授权进行发布(见附带的LICENSE_1_0.txt文件或从http://www.boost.org/LICENSE_1_0.txt) Boost.Asio是用于网络和低层IO编程的跨平台C++库,为开发者提供了C++环境下稳定的异步模型. 综述 基本原理 应用程序与外界交互的方式有很多,可通过文件,网络,串口或控制台.例如在网络通信中,完

Boost asio基本概念

asio库基于操作系统提供的异步机制,采用前摄器模式(Proactor)实现可移植的异步(或同步)IO操作,不需要使用多线程和锁,有效避免多线程编程带来的诸多有害副作用(如竞争,死锁). asio封装了操作系统的select.kqueue.poll/epoll.overlapped I/O等机制,实现异步IO模型.在同步模式下,程序发起一个IO操作,向io_service提交请求,io_service把操作转交给操作系统,同步地等待.当IO操作完成时,操作系统通知io_service,然后io_