1 import java.io.DataInputStream;
 2 import java.io.PrintStream;
 3 import java.net.ServerSocket;
 4 import java.net.Socket;
 5 public class WebServer {
 6
 7     /**
 8      * @param args
 9      */
10     public static void main(String[] args) {
11         // TODO Auto-generated method stub
12         //i对线程标记，port为监听的机器端口号
13         int i=1,port=80;
14         ServerSocket serverSocket=null;
15         Socket socket=null;
16         try {
17             //新建一个服务器监听对象
18             serverSocket=new ServerSocket(port);
19             System.out.println("listening!!");
20             //连续监听客户端请求
21             while (true) {
22                 socket=serverSocket.accept();//这里会等待客户端的请求
23                 new ConnectionThread(socket, i).start();//一旦接受到客户端请求，便开启请求事务处理线程对请求进行异步处理
24                 i++;
25             }
26         } catch (Exception e) {
27             // TODO: handle exception
28         }
29     }
30 }
31 //事务处理线程
32 class ConnectionThread extends Thread{
33     Socket socket=null;
34     int count;
35     public ConnectionThread(Socket s,int i) {
36         // TODO Auto-generated constructor stub
37         socket=s;
38         count=i;
39     }
40     public void run() {
41         try {
42             String ip=socket.getInetAddress().toString();//获取ip
43             int destport=socket.getPort();//获取端口
44             System.out.println("Client:"+ip+":"+destport);
45             PrintStream outStream=new PrintStream(socket.getOutputStream());//获取输出流
46             DataInputStream inStream=new DataInputStream(socket.getInputStream());//获取输入流
47             StringBuilder inString=new StringBuilder();
48             String temp;
49             //打印接收到的请求
50             while (!(temp=inStream.readLine()).equals("")) {
51                 inString.append(temp+"\n");
52             }
53             System.out.println("Request:\n"+inString.toString());
54             //向客户端返回特定的响应首部
55             outStream.println("HTTP/1.0 200 OK");
56             outStream.println("Content-Type:text/html");
57             outStream.println("Content-Length:"+"This is a test!!".length());
58             outStream.println("");
59             outStream.println("This is a test!!");
60             outStream.flush();
61         } catch (Exception e) {
62             // TODO: handle exception
63         }
64     }
65 }