how tomcat works- implemention of a simple Server

搜ijsio

1. 服务器类
建立ServerSoke，作为request和response的中枢

• package ex01.pyrmont;   
  
•   
  
• import java.net.Socket;   
  
• import java.net.ServerSocket;   
  
• import java.net.InetAddress;   
  
• import java.io.InputStream;   
  
• import java.io.OutputStream;   
  
• import java.io.IOException;   
  
• import java.io.File;   
  
•   
  
• public class HttpServer {   
  
•   
  
•   /** WEB_ROOT is the directory where our HTML and other files reside.  
  
•    *  For this package, WEB_ROOT is the "webroot" directory under the working  
  
•    *  directory.  
  
•    *  The working directory is the location in the file system  
  
•    *  from where the java command was invoked.  
  
•    */  
  
•   public static final String WEB_ROOT =   
  
•     System.getProperty("user.dir") + File.separator  + "webroot";   
  
•   
  
•   // shutdown command   
  
•   private static final String SHUTDOWN_COMMAND = "/SHUTDOWN";   
  
•   
  
•   // the shutdown command received   
  
•   private boolean shutdown = false;   
  
•   
  
•   public static void main(String[] args) {   
  
•     HttpServer server = new HttpServer();   
  
•     server.await();   
  
•   }   
  
•   
  
•   public void await() {   
  
•     ServerSocket serverSocket = null;   
  
•     int port = 8080;   
  
•     try {   
  
•       serverSocket =  new ServerSocket(port, 1, InetAddress.getByName("127.0.0.1"));   
  
•     }   
  
•     catch (IOException e) {   
  
•       e.printStackTrace();   
  
•       System.exit(1);   
  
•     }   
  
•   
  
•     // Loop waiting for a request   
  
•     while (!shutdown) {   
  
•       Socket socket = null;   
  
•       InputStream input = null;   
  
•       OutputStream output = null;   
  
•       try {   
  
•         socket = serverSocket.accept();   
  
•         input = socket.getInputStream();   
  
•         output = socket.getOutputStream();   
  
•   
  
•         // create Request object and parse   
  
•         Request request = new Request(input);   
  
•         request.parse();   
  
•   
  
•         // create Response object   
  
•         Response response = new Response(output);   
  
•         response.setRequest(request);   
  
•         response.sendStaticResource();   
  
•   
  
•         // Close the socket   
  
•         socket.close();   
  
•   
  
•         //check if the previous URI is a shutdown command   
  
•         shutdown = request.getUri().equals(SHUTDOWN_COMMAND);   
  
•       }   
  
•       catch (Exception e) {   
  
•         e.printStackTrace();   
  
•         continue;   
  
•       }   
  
•     }   
  
•   }   
  
• }   
  

2. 处理请求的类

• package ex01.pyrmont;   
  
•   
  
• import java.io.InputStream;   
  
• import java.io.IOException;   
  
•   
  
• public class Request {   
  
•   
  
•   private InputStream input;   
  
•   private String uri;   
  
•   
  
•   public Request(InputStream input) {   
  
•     this.input = input;   
  
•   }   
  
•   
  
•   public void parse() {   
  
•     // Read a set of characters from the socket   
  
•     StringBuffer request = new StringBuffer(2048);   
  
•     int i;   
  
•     byte[] buffer = new byte[2048];   
  
•     try {   
  
•       i = input.read(buffer);//把输入流中的信息读入字节数组中....   
  
•     }   
  
•     catch (IOException e) {   
  
•       e.printStackTrace();   
  
•       i = -1;   
  
•     }   
  
•     for (int j=0; j<i; j++) {   
  
•       request.append((char) buffer[j]);   
  
•     }   
  
•     System.out.print(request.toString());   
  
•     uri = parseUri(request.toString());   
  
•   }   
  
•   
  
•   private String parseUri(String requestString) {   
  
•     int index1, index2;   
  
•     index1 = requestString.indexOf(' ');//获得出现第一个空格的索引值   
  
•     if (index1 != -1) {   
  
•       index2 = requestString.indexOf(' ', index1 + 1);//获得指定索引后第一个出现空格的索引   
  
•       if (index2 > index1)   
  
•         return requestString.substring(index1 + 1, index2);//返回空格之间的值   
  
•     }   
  
•     return null;   
  
•   }   
  
•   
  
•   public String getUri() {   
  
•     return uri;   
  
•   }   
  
•   
  
• }  
  

3. 处理响应的类

• package ex01.pyrmont;   
  
•   
  
• import java.io.OutputStream;   
  
• import java.io.IOException;   
  
• import java.io.FileInputStream;   
  
• import java.io.File;   
  
•   
  
• /*  
  
•   HTTP Response = Status-Line  
  
•     *(( general-header | response-header | entity-header ) CRLF)  
  
•     CRLF  
  
•     [ message-body ]  
  
•     Status-Line = HTTP-Version SP Status-Code SP Reason-Phrase CRLF  
  
• */  
  
•   
  
• public class Response {   
  
•   
  
•   private static final int BUFFER_SIZE = 1024;   
  
•   Request request;   
  
•   OutputStream output;   
  
•   
  
•   public Response(OutputStream output) {   
  
•     this.output = output;   
  
•   }   
  
•   
  
•   public void setRequest(Request request) {   
  
•     this.request = request;   
  
•   }   
  
•   
  
•   public void sendStaticResource() throws IOException {   
  
•     byte[] bytes = new byte[BUFFER_SIZE];   
  
•     FileInputStream fis = null;   
  
•     try {   
  
•       File file = new File(HttpServer.WEB_ROOT, request.getUri());   
  
•       //System.out.print("+++++++++++++++"+request.getUri());   
  
•       String tt=request.getUri();   
  
•      byte[] xx=new byte[30];   
  
•       xx=tt.getBytes();   
  
•      output.write(xx,0,xx.length);   
  
•       if (file.exists()) {   
  
•         fis = new FileInputStream(file);   
  
•         int ch = fis.read(bytes, 0, BUFFER_SIZE);   
  
•         while (ch!=-1) {   
  
•           output.write(bytes, 0, ch);   
  
•              
  
•           ch = fis.read(bytes, 0, BUFFER_SIZE);   
  
•         }   
  
•       }   
  
•       else {   
  
•         // file not found   
  
•         String errorMessage = "HTTP/1.1 404 File Not Found\r\n" +   
  
•           "Content-Type: text/html\r\n" +   
  
•           "Content-Length: 23\r\n" +   
  
•           "\r\n" +   
  
•           "<h1>File Not Foundererewrwerwer</h1>";   
  
•         output.write(errorMessage.getBytes());   
  
•       }   
  
•     }   
  
•     catch (Exception e) {   
  
•       // thrown if cannot instantiate a File object   
  
•       System.out.println(e.toString() );   
  
•     }   
  
•     finally {   
  
•       if (fis!=null)   
  
•         fis.close();   
  
•     }   
  
•   }   
  
• }  
  

4. 输出结果
访问地址：http://localhost:8080/index.html

• GET /index.html HTTP/1.1   
  
• Accept: */*   
  
• Accept-Language: zh-cn   
  
• UA-CPU: x86   
  
• Accept-Encoding: gzip, deflate   
  
• User-Agent: Mozilla/4.0 (compatible; MSIE 7.0; Windows NT 5.1; TencentTraveler ; .NET CLR 2.0.50727)   
  
• Host: localhost:8080   
  
• Connection: Keep-Alive  
  

5. 总结
这样我们就实现了一个简单的服务器，不过这里智能处理静态页面，动态页面的处理待续。。。。