3.3连接器.ppt

连接器,贝毅君浙江大学软件学院,连接器,引入连接器优化Servlet容器HttpRequest优化套接字输入流优化请求行解析请求头解析Cookie获取参数HttpResponse,错误消息日志能够帮助管理员或程序员快速的定位错误点。Tomcat处理消息的方法是将错误消息存储在一个properties文件中。每个包下面包含一个properties文件，该文件包含该包中任何类可能抛出来的异常。每个StringManager对象被包内所有对象重用,StringManager错误消息定位,单例模式是设计模式当中最常用的模式。它只有一个私有的构造函数,只能在建立的时候实例化，调用者只能通过公共静态方法来获取实例。具体实例见src/org/apache/naming/StringManager.java,StringManager单例模式,privatestaticHashtablemanagers=newHashtable();publicsynchronizedstaticStringManagergetManager(StringpackageName)StringManagermgr=(StringManager)managers.get(packageName);if(mgr=null)mgr=newStringManager(packageName);managers.put(packageName,mgr);returnmgr;,声明,StringManager使用案例,调用,protectedStringManagersm=StringManager.getManager(ex03.pyrmont.connector.http);,thrownewServletException(sm.getString(httpConnector.alreadyInitalized=);,httpConnector.alreadyInitalized=HTTPconnectorhasalreadybeeninitialized,文件,引入连接器的Servlet容器,HttpServer类分成HttpConnector和HttpProcessor两个类HttpConnector负责等待HTTP请求，HttpProcessor负责创建Request和Response对象Request类和Response类分别被HttpRequest类和HttpResponse类代替HttpProcessor使用其parse()方法填充HttpRequest对象。连接器只解析service用到的HTTP信息HttpRequest自己负责解析请求体或查询字符串的参数。,引入连接器的Servlet容器,本Servlet容器通过BootStrap类负责启动。,Bootstrap,publicfinalclassBootstrappublicstaticvoidmain(Stringargs)HttpConnectorconnector=newHttpConnector();connector.start();/HttpConnector是个Runnable对象，内部封装线程启动,核心未捕获异常代码:,HttpConnector,publicvoidrun()ServerSocketserverSocket=null;While(!stopped)serverSocket=newServerSocket(8080,1,InetAddress.getByName(“”);Socketsocket=serverSocket.accept();HttpProcessorprocessor=newHttpProcessor(this);cessor(socket);,转化处理功能由HttpProcessor完成，HttpConnector和HttpProcessor功能分离,简单servlet容器实现:,HttpProcessorprocess(),input=socket.getInputStream();request=newHttpRequest(input);reponse.setRequest(request);,改造后实现,input=newSocketInputStream(sock.getInputStream(),2048);request=newHttpRequest(input);reponse.setRequest(request);/新增部分response.setHeader(“Server”,“PyrmontServletContainer”);parseRequest(input,output);parseHeaders(input);/TODO尾部去处shutdown参数赋值,SocketInputStream实例是java.io.InputStream实例的包装类,可以通过getInputStream()方法获得实例提供了2个重要方法readRequestLine()和readHeader()readRequestLine()会返回一个HTTP请求第一行的内容(包含URL、请求方法和协议版本信息)readHeader()会返回头信息的键值对。每次调用只会返回一对，所以该方法会被重复调用。readRequestLine()方法必须在readHead()方法之前调用。,SocketInputStream,HttpRequest类实现了javax.servlet.http.HttpServeltRequest接口使用RequestStream实例作为输入流对象RequestSream类是java.io.InputStream类的直接子类HttpRequest自身负责解析Http请求HttpRequest已经引入了Http请求头、Cookie和请求参数等信息,HttpRequest,前面搭建简单web服务器和简单servlet容器的时候调用java.io.InputStream的read()方法来读取字节流。字节流解析交给SocketInputStream来完成了，该类内部封装了read()方法来解析流信息。引入SocketInputStream的目的是为了能够调用其readRequestLine()方法和readHeader()方法,解析Http请求-读取套接字的输入流,解析Http请求解析请求行,解析请求行在HttpProcessor中的parseRequest()中实现parseRequest()实现7部分功能利用input.readRequestLine(requestionLine)获取请求行信息并分别存储在变量中验证请求行信息有效性根据?读取请求参数并通过HttpRequest的setQueryString方法存储到parameterMap类中检查URI是否是绝对路径并作相应转换转化请求中会话标示符并调用HttpRequest的setRequestedSessionid方法存储到HttpRequest对象中对非正常的URI行进修正最后设置HttpRequest对象的属性,请求头被封装在HttpHeader类里面解析请求头在HttpProcessor里的parseHeader()方法中调用,解析Http请求解析请求头,While(true)HttpHeaderheader=newHttpHeader();input.readHeader(header);if(End=0)if(header.valueEnd=0)return;elsethrownewServletException(sm.getString(httpProcessor.parseHeaders.colon);,读取下一个Header信息,检查是否已经读取到尾部，是则返回,nameEnd和valueEnd代表当前name和value参数的长度值,Stringname=newString(,0,End);Stringvalue=newString(header.value,0,header.valueEnd);request.addHeader(name,value);if(name.equals(“cookies”)/TODO解析cookieelseif(name.equals(“content-length”)intn=-1;tryn=Integer.parseInt(value);catch(Exceptione)thrownewServletException(sm.getString(httpProcessor.parseHeaders.contentLength);request.setContentLength(n);elseif(name.equals(“content-type”)request.setContentType(value);,Cookie解析是通过RequestUtil.parseCookieHeader()方法实现的。parseCookieHeader()方法接受Cookie请求头转化后返回一个Cookie类型的数组。,解析Http请求解析Cookie,if(name.equals(cookie)/通过RequetUtil转化CookieCookiecookies=RequestUtil.parseCookieHeader(value);for(inti=0;i=0)contentType=contentType.substring(0,semicolon).trim();elsecontentType=contentType.trim();if(POST.equals(getMethod(),下述代码负责解析请求体,while(lenmax)intnext=is.read(buf,len,max-len);if(next0)break;len+=next;is.close();if(lenmax)thrownewRuntimeException(Contentlengthmismatch);RequestUtil.parseParameters(results,buf,encoding);catch(UnsupportedEncodingExceptionue);catch(IOExceptione)thrownewRuntimeException(Contentreadfail);,HttpResponse类实现了javax.servlet.http.HttpServletResponse接口HttpResponse返回自实现的ResponseWriter,该Writer重写了所有的print()方法和println()方法，自动刷新信息到客户端。使用自实现ResponseStream替换Java.io.OutputStream对象利用java.io.OutPutStreamWriter对象作为ResponseWriter对象和ResponseStream对象之间的桥梁。通过OutPutStream类传入的字符会被转化成使用指定字符集的字节数组。,HttpResponse,Servlet中，可以使用PrintWriter对象向输出流中写字符，但是向浏览器发送字符的时候，实际上都是字节流。这里使用ResponseWriter类来替代PrintWriter类向客户端发送信息。ResponseWriter重写了所有的print()和println()方法，实现自动将信息发送到客户端。使用OutputStreamWriter作为ResponseWriter和ResponseStream对象之间的桥梁。OutputStreamWriter可以将传入的字符转换成指定字符集的字节数组。字节数组缓冲区大小固定。,HttpResponseWriter,publicPrintWritergetWriter()throwsIOExceptionResponseStreamnewStream=newResponseStream(this);OutputStreamWriterosr=newOutputStreamWriter(newStream,getCharacterEncoding();writer=newResponseWriter(osr);returnwriter;,HttpResponsegetWriter(),ServletProcessor中process()方法接受的实例替换成HttpRequest和HttpResponseServletProcessor中process()方法中对应外观类发生变化ServletProcessor中process()方法调用servlet.service()方法后，还会调用HttpResponse类的finishResponse方法,ServletProcessor,servlet=(Servlet)myClass.newInstance();HttpRequestFacaderequestFacade=newHttpRequestFacade(request);HttpResponseFacaderesponseFacade=newHttpResponseFacade(response);servlet.service(requestFacade,responseFacade);(HttpResponse)response).finishResponse();,测试Servlet-ModernServlet,publicclassModernServletextendsHttpServletpublicvoidinit(ServletConfigconfig)System.out.println(ModernServle