tomcat 7 源码分析-9 tomcat对ServerSocket的封装和使用
tomcat 7 源码分析-9 tomcat对ServerSocket的封装和使用
?
tomcat中ServerSocket线程监听是否有socket连接，如果有就转而处理。这个过程类似于你向tomcat发送一个URL请求，实质这个请求转换成http协议，通过socket发出来。
先看ServerSocket的封装主要为
public abstract class ServerSocketFactory implements Cloneable?class DefaultServerSocketFactory extends ServerSocketFactory { DefaultServerSocketFactory () { /* NOTHING */ } @Override public ServerSocket createSocket (int port) throws IOException { return new ServerSocket (port); } @Override public ServerSocket createSocket (int port, int backlog) throws IOException { return new ServerSocket (port, backlog); } @Override public ServerSocket createSocket (int port, int backlog, InetAddress ifAddress) throws IOException { return new ServerSocket (port, backlog, ifAddress); } @Override public Socket acceptSocket(ServerSocket socket) throws IOException { return socket.accept(); } @Override public void handshake(Socket sock) throws IOException { // NOOP } }?做了个小例子，模拟8080端口，可以通过浏览器想serversocket发消息。
package com.test.socket;import java.io.*;import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;import org.apache.tomcat.util.net.*;public class testendpoint {protected volatile boolean running = false;/** * Server socket acceptor thread. */protected ServerSocket serverSocket = null;protected ServerSocketFactory serverSocketFactory = null;public void start() throws Exception {running = true;//获得serverSocketFactoryserverSocketFactory = ServerSocketFactory.getDefault();//获得serverSocket，监听8080端口serverSocket = serverSocketFactory.createSocket(8080);//建立监听线程Thread acceptorThread = new Thread(new Acceptor(),"-Acceptor-");acceptorThread.start();}//处理socketprotected boolean processSocket(Socket socket) throws IOException {BufferedReader in = new BufferedReader(new InputStreamReader( socket.getInputStream()));String inputLine;while ((inputLine = in.readLine()) != null) { System.out.println(inputLine);}return true;}//监听类，不断循环 protected class Acceptor implements Runnable { /** * The background thread that listens for incoming TCP/IP connections and * hands them off to an appropriate processor. */ public void run() { // Loop until we receive a shutdown command while (running) { // Loop if endpoint is paused // Accept the next incoming connection from the server socket try { Socket socket = serverSocketFactory.acceptSocket(serverSocket); serverSocketFactory.initSocket(socket); // Hand this socket off to an appropriate processor if (!processSocket(socket)) { // Close socket right away try { socket.close(); } catch (IOException e) { // Ignore } } }catch ( IOException x ) { } catch (Throwable t) { } // The processor will recycle itself when it finishes } } }}?package com.test.socket;import org.apache.tomcat.util.net.*;public class Servertest {/** * @param args */public static void main(String[] args) {// TODO Auto-generated method stubtestendpoint ts = new testendpoint();try {System.out.println("Server start");ts.start();} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}}}?测试，在你的浏览器上输入：http://localhost:8080/
可以看见发过来的request的整个消息
Server start
GET / HTTP/1.1
Host: localhost:8080
User-Agent: Mozilla/5.0 (Windows; U; Windows NT 5.1; en-US; rv:1.9.2.7) Gecko/20100713 Firefox/3.6.7
Accept: text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8
Accept-Language: en-us,en;q=0.5
Accept-Encoding: gzip,deflate
Accept-Charset: ISO-8859-1,utf-8;q=0.7,*;q=0.7
Keep-Alive: 115
Connection: keep-alive
当然也可以写个客户端，向服务器端发数据。
