tomcat请求处理分析(五) 请求到响应流

1.1.1.1  请求到响应界面流

请求处理的过程主要是将所有的东西解析成流,转化成对应的http报文,所以在这里我先不关注servlet因为它最终也就是解析成流里面的数据

processKey里面最终执行的是processSocket,它是线从缓存中获取对应的线程池,没有的话就创建一个,然后进行执行

protected boolean processSocket(KeyAttachmentattachment, SocketStatus status, boolean dispatch) { try { if (attachment== null) { return false; }         SocketProcessor sc = processorCache.pop();         if ( sc == null ) sc = new SocketProcessor(attachment, status);         else sc.reset(attachment, status); Executor executor =getExecutor();         if (dispatch &&executor != null) {             executor.execute(sc); } else {             sc.run(); }     } catch (RejectedExecutionExceptionree) { log.warn(sm.getString("endpoint.executor.fail", attachment.getSocket()), ree);         return false; } catch (Throwablet) {         ExceptionUtils.handleThrowable(t); // This means we got anOOM or similar creating a thread, or that         // the pool and its queue arefull log.error(sm.getString("endpoint.process.fail"), t);         return false; } return true;

}     在上面描述的线程中,响应到页面主要是先构建对应的缓冲流,然后将缓冲流中的数据写入到sockt通道,这样就实现到了页面,具体操作逻辑如下:(自下向上执行)

   下面我将与流相关的几步,进行一下讲述:

process:,AbstractProtocol$AbstractConnectionHandler (org.apache.coyote)

if (processor == null) {     processor = createProcessor();

}

protected Http11Processor createProcessor() {     Http11Processor processor = new Http11Processor( proto.getMaxHttpHeaderSize(), (JIoEndpoint)proto.endpoint, proto.getMaxTrailerSize(), proto.getAllowedTrailerHeadersAsSet(), proto.getMaxExtensionSize(), proto.getMaxSwallowSize()); proto.configureProcessor(processor); // BIO specificconfiguration processor.setDisableKeepAlivePercentage(proto.getDisableKeepAlivePercentage()); register(processor);     return processor; }

public Http11Processor(int headerBufferSize, JIoEndpointendpoint, int maxTrailerSize, Set<String>allowedTrailerHeaders, int maxExtensionSize, int maxSwallowSize){ super(endpoint); inputBuffer = new InternalInputBuffer(request, headerBufferSize); request.setInputBuffer(inputBuffer); outputBuffer = new InternalOutputBuffer(response, headerBufferSize); response.setOutputBuffer(outputBuffer); initializeFilters(maxTrailerSize, allowedTrailerHeaders, maxExtensionSize, maxSwallowSize);

}

这里不难看出构建了的outputBuffer这InternalOutputBuffer实例并与response进行关联,所以后面通过response进行一些相关属性操作就可以直接到缓冲流

process:,AbstractHttp11Processor(org.apache.coyote.http11)

getOutputBuffer().init(socketWrapper, endpoint);

/**  * 给当前实例 outputBuffer即response封装的对象  *  * 给其成员变量NioChannel socket 以及pool进行赋值  *  * */ @Override publicvoid init(SocketWrapper<NioChannel> socketWrapper, AbstractEndpoint<NioChannel>endpoint) throws IOException { socket =socketWrapper.getSocket(); pool =((NioEndpoint)endpoint).getSelectorPool();

}

这一步进行的操作主要是将outputBuffer这个实例关联对应的socket通道,为最后将缓冲流的数据放入到sockt做铺垫

public void close() throws IOException{ if (closed) { return; } if (suspended) { return; } //将缓冲去的字符刷新给页面 if (cb.getLength()> 0) { cb.flushBuffer(); } 。。。。。。

}

 最终是将cb给刷新到了然后将数据返回到页面,看一下cb是怎么来的,由下不难看出将OutputBuffer给注入其通道

public OutputBuffer(int size) { bb = new ByteChunk(size); bb.setLimit(size); bb.setByteOutputChannel(this); cb = new CharChunk(size); cb.setLimit(size); cb.setOptimizedWrite(false); cb.setCharOutputChannel(this);

}

   这样做最后怎么获取数据呢?由下面可以看出其一层一层不断的拆解最后还是到InternalOutputBuffer缓冲实例,所以解析的流数据最终还是经过这个进行处理

addToBB:,InternalNioOutputBuffer(org.apache.coyote.http11)

那最终它又是怎么到流中去,得看一下addToBB方法,由两步比较和核心,第一步就是将buf即InternalNioOutputBuffer实例中的数据拷贝到niochannel总去,第二步将niochannel通道中的数据写入到socket通道

private synchronized void addToBB(byte[] buf, int offset, int length) throws IOException{ if (length == 0) return; //首先尝试先将数据发送出去 boolean dataLeft = flushBuffer(isBlocking());     //这里只有在缓冲区里面已经没有数据了才继续发送 while (!dataLeft&& length > 0) { //首先将要发送的数据copy到niochanel的发送buffer里面去   int thisTime =transfer(buf,offset,length,socket.getBufHandler().getWriteBuffer()); //计算还剩下多少字节没有写到niochannel的buffer里面,其实这里也就当做将数据转移到了niochannel的buffer就算是写出去了 length = length -thisTime; //这里用于调整偏移量 offset = offset +thisTime; //调用writeToSocket方法将niochannel的buffer的里面的数据通过socket写出去 int written =writeToSocket(socket.getBufHandler().getWriteBuffer(),                 isBlocking(), true); //如果在tomcat的response里面有writelistener的话,可以异步的写 if (written == 0) {             dataLeft = true; } else {             dataLeft =flushBuffer(isBlocking()); }     }     NioEndpoint.KeyAttachment ka =(NioEndpoint.KeyAttachment)socket.getAttachment();     if (ka != null)ka.access();//prevent timeouts for just doing client writes if (!isBlocking()&& length > 0) { //在非阻塞的发送中,如果实在发送不出去,需要保存在额外的buffer里面 addToBuffers(buf, offset, length); }

}

下面在看一下具体怎么写到通道里面去

private synchronized int writeToSocket(ByteBufferbytebuffer, boolean block, boolean flip) throws IOException{ if ( flip ) {         bytebuffer.flip(); flipped = true; } int written = 0; NioEndpoint.KeyAttachmentatt = (NioEndpoint.KeyAttachment)socket.getAttachment();     if ( att == null ) throw new IOException("Keymust be cancelled");     long writeTimeout =att.getWriteTimeout(); Selector selector = null;     try {         selector = pool.get(); } catch (IOException x ) { } try {  written = pool.write(bytebuffer, socket,selector, writeTimeout, block); do { if (socket.flush(true,selector,writeTimeout))break; }while ( true ); } finally { if ( selector!= null)pool.put(selector); } if ( block ||bytebuffer.remaining()==0) { bytebuffer.clear(); flipped = false; } return written;

}

   pool实例,即NioBlockingSelector,可以看出其有阻塞和非组合两种写入方式,但最后都是通过socket.write(buf)写入socket通道就返回到页面,至于为什么写入到socket通道就能响应到页面可以看一下基于NIO的httpserver实现,主要SocketChannelImpl这个类,这里又一个简易的httpserver的实现,参考链接:

http://www.cnblogs.com/a294098789/p/5676566.html

public int write(ByteBuffer buf, NioChannelsocket, Selector selector,                  long writeTimeout, boolean block) throws IOException{ if ( SHARED &&block ) { return blockingSelector.write(buf,socket,writeTimeout); }     SelectionKey key = null;     int written = 0;     boolean timedout = false;     int keycount = 1; //assume we canwrite long time =System.currentTimeMillis(); //start the timeout timer try { while ((!timedout) && buf.hasRemaining() ) { int cnt = 0;             if ( keycount > 0 ) { //only write ifwe were registered for a write cnt = socket.write(buf);//write thedata if (cnt == -1) throw new EOFException(); written += cnt;                 if (cnt > 0) {                     time = System.currentTimeMillis(); //reset ourtimeout timer continue; //wesuccessfully wrote, try again without a selector } if (cnt==0 &&(!block)) break; //don't block } if ( selector!= null){ //register OP_WRITE to theselector if (key==null) key =socket.getIOChannel().register(selector, SelectionKey.OP_WRITE);                 else key.interestOps(SelectionKey.OP_WRITE);                 if (writeTimeout==0) {                     timedout =buf.hasRemaining(); } else if (writeTimeout<0) {                     keycount =selector.select(); } else {                     keycount =selector.select(writeTimeout); }             } if (writeTimeout> 0 && (selector == null || keycount== 0) ) timedout= (System.currentTimeMillis()-time)>=writeTimeout; }//while if ( timedout )thrownew SocketTimeoutException(); } finally { if (key != null) {             key.cancel();             if (selector != null)selector.selectNow();//removes the key from this selector }     } return written;

}

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏哲学驱动设计

性能优化总结(五):CSLA服务端如何使用多线程的解决方案

    前篇说到了使用异步线程来实现数据的预加载,以提高系统性能。     这样的操作一般是在客户端执行,用以减少用户的等待时间。客户端发送多次异步请求,到达服...

2538
来自专栏沃趣科技

配置详解 | performance_schema全方位介绍

在上一篇 《初相识 | performance_schema全方位介绍》 中粗略介绍了如何配置与使用performance_schema,相信大家对perfor...

6747
来自专栏Albert陈凯

2018-10-09 lombok 生产环境报错SEVERE: Unable to process Jar entry [module-info.class] from Jar [jar:fil...

老师您好,课程里面用的lombok,感觉很方便,我就在我写的一个测试项目里面也用的这个。在idea里面用tomcat是可以正常运行的。但是打好包以后,放到服务器...

3082
来自专栏屈定‘s Blog

Java--为什么需要主动关闭文件?

在Java编程中,对于一些文件的使用往往需要主动释放,比如InputStream,OutputStream,SocketChannel等等,那么有没有想过为什么...

1799
来自专栏Android机动车

从源码角度看广播

几乎每个安卓应用都无可避免的使用到广播。例如监听WIFI的开启状态、时间的获取,甚至是我们最常用的闹钟功能,都是结合着AlarmManager与广播来实现的。理...

874
来自专栏源哥的专栏

给你的系统增加对物理地址的验证

我们开发出一个系统之后,经常有很多方法来保护我们的系统不受别人非法使用,比如说采用注册码,根据IP地址进行限制等。这些都存在一个问题就是容易给人通过拷贝注册码等...

752
来自专栏蓝天

UNIX和Linux信号

1 ~ 31的信号为传统UNIX支持的信号,是不可靠信号(非实时的),编号为32 ~ 63的信号是后来扩充的,称做可靠信号(实时信号)。不可靠信号和可靠信号的区...

1074
来自专栏xingoo, 一个梦想做发明家的程序员

日志那点事儿——slf4j源码剖析

前言: 说到日志,大多人都没空去研究,顶多知道用logger.info或者warn打打消息。那么commons-logging,slf4j,logback...

2085
来自专栏飞雪无情的博客

Go语言实战笔记(十六)| Go 并发示例-Pool

这篇文章演示使用有缓冲的通道实现一个资源池,这个资源池可以管理在任意多个goroutine之间共享的资源,比如网络连接、数据库连接等,我们在数据库操作的时候,比...

802
来自专栏王磊的博客

RabbitMQ交换器Exchange介绍与实践

有了Rabbit的基础知识之后(基础知识详见:深入解读RabbitMQ工作原理及简单使用),本章我们重点学习一下Rabbit里面的exchange(交换器)的知...

561

扫码关注云+社区