挖坑挖了这么长时间也该继续填坑了,上文书讲到从零开始写一个Tomcat(贰)--建立动态服务器,讲了如何让服务器解析请求,分离servlet请求和静态资源请求,读取静态资源文件输出或是通过URLClassLoader找到我们请求的servlet,反射生成对应的实例,调用其service方法,传递初级解析的request和response,完成请求.
这很tomcat,but too simple
阅读本文,你将了解
- 连接器(connector),处理器(processor)逻辑分离
- 如何高效的解析请求中的header,parameters
- 生成更加完善的ServletRequest和ServletResponse
- Tomcat经典的facade模式
本章的代码部分是自己写的,更多的是从Tomcat源码上扒下来的
HttpConnector / HttpProcessor
之前的AsServer的主类中实现了所有接收请求,解析request,生成response,调用ServletProcessor的方法.我们首先将逻辑分离.
HttpConnector只负责接收请求,将SocketServer调用accept方法获得的socket传递给processor实例,本次请求中HttpConnector的工作结束,接下来的任务由HttpProcessor继续
HttpProcessor总体的逻辑和之前没有大的变化,基本上就是创建Request,创建Response,解析request,解析header,判断请求的是静态资源还是动态资源,并交给相应的处理器处理.
public void process(Socket socket){
SocketInputStream is;
OutputStream os;
try{
is=new SocketInputStream(socket.getInputStream(),2048);
os=socket.getOutputStream();
request = new HttpRequest(is);
response = new HttpResponse(os);
response.setRequest(request);
response.setHeader("Server", "Container");
parseRequest(is, os);
parseHeaders(is);
if (request.getRequestURI().startsWith("/servlet/")) {
ServletProcessor processor = new ServletProcessor();
processor.process(request, response);
}
else {
response.getWriter().write("no servlet");
((HttpResponse) response).finishResponse();
}
socket.close();
}catch (Exception e){
e.printStackTrace();
}
}
新加入SocketInputStream类,SocketInputStream中主要有2个方法
public void readRequestLine(HttpRequestLine requestLine) throws IOException public void readHeader(HttpHeader header) throws IOException
readRequestLine负责读取request的第一行,分别得到method,path和protocol
之前的方法也能解析出这些信息,为什么还要额外去解析呢,因为效率.
之前的方法是读取出全部流的字节码,转换成字符串,再用indexOf和substring等方法解析,而SocketInputStream并不会去把得到的字节码装换成字符串而是保持字节码的形态,逐位的读取字节码,转化成char,填充到method,path和protocol对应的数组中,最后从method,path和protocol对应的数组中得到其对应的字符串.readHeader中也是相似的方法.节省了字符串的"繁重"的操作.
解析得到各项信息之后开始填充ServletRequest接口中的各种方法,为了加快速度,对于请求的各种参数,并不是在生成request的过程中,而是发生在第一次调用时
public String getParameter(String name) {
parseParameters();
String values[] = (String[]) parameters.get(name);
if (values != null)
return (values[0]);
else
return (null);
}
然后生成response,填充了部分新的方法,就不一一列举了,值得一提的是,为了保证response.getWriter().write/print/println能正确的写出,创建了一个ResponseWriter,对于PrintWriter的写的方法之前全加上了一层flush(),就像这样,并且在最后调用finishResponse()保证全部刷出以及关闭writer
public void print(char c) {
super.print(c);
super.flush();
}
public void print(char ca[]) {
super.print(ca);
super.flush();
}
public void print(double d) {
super.print(d);
super.flush();
}
现在得到生成的HttpRequest和HttpResponse,但是并不能直接的将这个传递给servlet,里面有属于Tomcat自身的方法,tomcat并不希望开发者去调用这些方法,因此使用了外观模式,
新建HttpRequestFacade和HttpResponseFacade,实现ServletRequest和ServletRespons接口,将HttpRequest和HttpResponse传递进来,仅实现HttpRequest和HttpResponse中属于ServletRequest和ServletRespons接口的方法,这样servlet就只能调用这些方法了.
源码地址:https://github.com/Asens/AsServer/tree/master/AsServerV1.1
附上测试:
public void service(ServletRequest req, ServletResponse res) throws ServletException, IOException {
String aa=req.getParameter("username");
System.out.println(aa);
res.getWriter().write(aa);
}
本来准备把多线程也写进来的,但是多线程这个概念相对独立,与之前的内容关系不大,就下一章再写吧,demo已经写好了,有兴趣的同学可以先看一下
https://github.com/Asens/AsServer/tree/master/AsServerThreadDemo
下集预告:引入线程池和容器的基础概念,服务器能够同时处理多个请求