1. 程式人生 > >Java socket 實現tomcat伺服器

Java socket 實現tomcat伺服器

一個基於java的web伺服器使用這兩個重要的類:java.net.Socket和java.net.ServerSocket,並通過HTTP訊息進行通訊。在實現Web伺服器之前有必要簡要說明一下超文字傳輸協議(HTTP)。

超文字傳輸協議(HTTP)

http是一種無狀態的請求和相應協議,請大家暫時記住無狀態這一概念,在後續介紹session時將會向大家闡述有狀態和無狀態的區別。在HTTP中,始終由客戶端傳送HTTP請求。web伺服器從不主動聯絡客戶端或對客戶端做回撥連線,伺服器端只根據客戶端發來的請求做出響應。下面將介紹HTTP請求HTTP響應Socket類

HTTP請求

一個HTTP請求包括三個組成部分:

1.方法—統一資源標示符(URI)—協議/版本

2.請求的頭部

3.主體內容

示例如下:

  1. POST /examples/default.jsp HTTP/1.1  
  2. Accept: text/plain; text/html  
  3. Accept-Language: en-gb  
  4. Connection: Keep-Alive  
  5. Host: localhost  
  6. User-Agent: Mozilla/4.0  
  7. Content-Length: 33  
  8. Content-Type: application/x-www-form-urlencoded  
  9. Accept-Encoding: gzip, deflate  
  10. lastName=Franks&firstName=Michael  

HTTP響應

類似於HTTP請求,一個HTTP響應也包括三個組成部分:

1.方法-統一資源標示符(URI)-協議/版本

2.響應的頭部

3.主體內容

下面是一個HTTP響應的例子:

  1. HTTP/1.1 200 OK  
  2. Server: IBM/4.0  
  3. Date: Sat, 6 Nov 2013 13:13:00 GMT  
  4. Content-Type: text/html  
  5. Last-Modified: Sat, 5 Jan 2013 13:13:12 GMT  
  6. Content-Length: 112  
Socket類

套接字是網路連線的一個端點。套接字使得一個應用可以從網路中讀取和寫入資料。放在兩個不同的計算機上的兩個應用可以通過連線傳送和接受位元組流。為了從你的應用傳送一條資訊到另一個應用,你需要指導另一個應用的IP地址和套接字埠。

ServerSocket類

Socket類代表一個客戶端套接字,即任何時候你想連線到一個遠端伺服器應用的時候你構造的套接字。如果是一個伺服器程式依靠Socket類是行不通的。你的伺服器必須隨時待命,因為客戶端何時想你傳送請求是不知道的。

ServerSocket和Socket不同,伺服器套接字的角色是等待來自客戶端的連線請求。一旦伺服器套接字獲得一個連線請求,它建立一個Socket例項來與客戶端進行通訊。

下面我們來看看這三個類:

HttpServer類

  1. <strong>package com.vipshop.test;  
  2. import java.io.File;  
  3. import java.io.IOException;  
  4. import java.io.InputStream;  
  5. import java.io.OutputStream;  
  6. import java.net.InetAddress;  
  7. import java.net.ServerSocket;  
  8. import java.net.Socket;  
  9. import java.net.UnknownHostException;  
  10. import com.vipshop.tomcat.pyrmont.Request;  
  11. import com.vipshop.tomcat.pyrmont.Response;  
  12. publicclass HttpServer {  
  13.     publicstaticfinal String WEB_ROOT = System.getProperty("user.dir")  
  14.             + File.separator + "webroot";  
  15.     privatestaticfinal String SHUTDOWN_COMMAND = "/SHUTDOWN";  
  16.     privateboolean shutdown = false;  
  17.     publicstaticvoid main(String[] args) {  
  18.         HttpServer server = new HttpServer();  
  19.         server.await();  
  20.     }  
  21.     publicvoid await() {  
  22.         ServerSocket serverSocket = null;  
  23.         int port = 8080;  
  24.         try {  
  25.             serverSocket = new ServerSocket(port, 1, InetAddress  
  26.                     .getByName("127.0.0.1"));  
  27.         } catch (UnknownHostException e) {  
  28.             e.printStackTrace();  
  29.         } catch (IOException e) {  
  30.             e.printStackTrace();  
  31.             System.exit(1);  
  32.         }  
  33.         // Loop waiting for a request
  34.         while (!shutdown) {  
  35.             Socket socket = null;  
  36.             InputStream input = null;  
  37.             OutputStream output = null;  
  38.             try {  
  39.                 socket = serverSocket.accept();  
  40.                 input = socket.getInputStream();  
  41.                 output = socket.getOutputStream();  
  42.                 // create Request object and parse
  43.                 Request request = new Request(input);  
  44.                 request.parse();  
  45.                 // create Response object
  46.                 Response response = new Response(output);  
  47.                 response.setRequest(request);  
  48.                 response.sendStaticResource();  
  49.                 // Close the socket;
  50.                 socket.close();  
  51.                 // check if the revious URI is a shutdown command
  52.                 shutdown = request.getUri().equals(SHUTDOWN_COMMAND);  
  53.             } catch (IOException e) {  
  54.                 e.printStackTrace();  
  55.                 continue;  
  56.             }  
  57.         }  
  58.     }  
  59. }  
  60. </strong>  

Request類

  1. package com.vipshop.test;  
  2. import java.io.IOException;  
  3. import java.io.InputStream;  
  4. publicclass Request {  
  5.     private InputStream input;  
  6.     private String uri;  
  7.     public Request(InputStream input) {  
  8.         this.input = input;  
  9.     }  
  10.     publicvoid parse() {  
  11.         // Read a set of characters from the socket
  12.         StringBuffer request = new StringBuffer(2018);  
  13.         int i;        
  14.         byte[] buffer = newbyte[2048];  
  15.         try {  
  16.             i = input.read(buffer);  
  17.         } catch (IOException e) {  
  18.             e.printStackTrace();  
  19.             i = -1;  
  20.         }  
  21.         for (int j = 0; j < i; j ++) {  
  22.             request.append((char)buffer[j]);  
  23.         }  
  24.         System.out.println();  
  25.         System.out.println("request.toString():");  
  26.         System.out.print(request.toString());  
  27.         System.out.println();  
  28.         uri = parseUri(request.toString());  
  29.     }  
  30.