Java实践：一个简易的http server和client的java源码学习和总结。

一、基本思路：

1、服务器端通过socket(), 监听在TCP 8080端口，等待客户端来连接。

2、服务器端解析客户端的HTTP请求中的URI值，把本地的目录下指定文件通过java的读取文件的方式getResourceAsStream()发送给客户端。

3、客户端把应用程序的第一个参数作为目标文件，传到HTTP请求中。

 

二、总结：

1、服务器端终究是通过解析HTTP请求中的内容，取到目标文件，并且服务器端的字节码文件，必须和root目录放一起。

2、java有现成的类的方法，获得socket中的内容，服务器端的成功返回，也是服务器自行构造的。

 

三、源码

1、服务器端代码：

package server;
import java.io.*;
import java.net.*;

public class HTTPServer{
  public static void main(String args[]) {
    int port;
    ServerSocket serverSocket;
      
    try { 
       port = Integer.parseInt(args[0]);
     }catch (Exception e) {
       System.out.println("port = 8080 (默认)");
       port = 8080; //默认端口为8080
     }

     try{
       serverSocket = new ServerSocket(port); 
       System.out.println("服务器正在监听端口：" + serverSocket.getLocalPort());
        
       while(true) { //服务器在一个无限循环中不断接收来自客户的TCP连接请求
         try{
           //等待客户的TCP连接请求
           final Socket socket = serverSocket.accept(); 
           System.out.println("建立了与客户的一个新的TCP连接，该客户的地址为："+
                socket.getInetAddress()+":" + socket.getPort());
          
           service(socket);  //响应客户请求
        }catch(Exception e){e.printStackTrace();} 
      } //#while
    }catch (Exception e) {e.printStackTrace();}
  }

  /** 响应客户的HTTP请求 */
  public static void service(Socket socket)throws Exception{
    
    /*读取HTTP请求信息*/
    InputStream socketIn=socket.getInputStream(); //获得输入流
    Thread.sleep(500);  //睡眠500毫秒，等待HTTP请求  
    int size=socketIn.available();
    byte[] requestBuffer=new byte[size];
    socketIn.read(requestBuffer);
    String request=new String(requestBuffer);
    System.out.println(request); //打印HTTP请求数据
     
    /*解析HTTP请求*/
    //获得HTTP请求的第一行
    String firstLineOfRequest=request.substring(0,request.indexOf("\r\n"));
    //解析HTTP请求的第一行 
    String[] parts=firstLineOfRequest.split(" ");
    String getMethod = "GET";
    if(true != parts[0].equals("GET"))
    {
        System.out.println("client Bad request:" + parts[0] + " method length=" + parts[0].length() ); //打印错误的请求
        System.out.println("correct request is:" + getMethod ); 
    }
    
    String uri=parts[1]; //获得HTTP请求中的uri
    
    /*决定HTTP响应正文的类型*/
    String contentType;
    if(uri.indexOf("html")!=-1 || uri.indexOf("htm")!=-1)
      contentType="text/html";
    else if(uri.indexOf("jpg")!=-1 || uri.indexOf("jpeg")!=-1)
      contentType="image/jpeg";
    else if(uri.indexOf("gif")!=-1) 
      contentType="image/gif";
    else
      contentType="application/octet-stream"; 
    
    
    /*创建HTTP响应结果 */
    //HTTP响应的第一行
    String responseFirstLine="HTTP/1.1 200 OK\r\n";
    //HTTP响应头
    String responseHeader="Content-Type:"+contentType+"\r\n\r\n";
    //获得读取响应正文数据的输入流
    InputStream in=HTTPServer.class.getResourceAsStream("root/"+uri);
    
    /*发送HTTP响应结果 */
    OutputStream socketOut=socket.getOutputStream(); //获得输出流
    //发送HTTP响应的第一行
    socketOut.write(responseFirstLine.getBytes());
    //发送HTTP响应的头
    socketOut.write(responseHeader.getBytes());
    //发送HTTP响应的正文
    int len=0;
    byte[] buffer=new byte[128];
    while((len=in.read(buffer))!=-1)
    socketOut.write(buffer,0,len);  
    
    Thread.sleep(1000);  //睡眠1秒，等待客户接收HTTP响应结果        
    socket.close(); //关闭TCP连接  
    
  }
}




/****************************************************
 * 作者：孙卫琴                                     *
 * 来源：<<Tomcat与Java Web开发技术详解>>           *
 * 技术支持网址：www.javathinker.org                *
 ***************************************************/

 

客户端代码：

package client;
import java.net.*;
import java.io.*;
import java.util.*;

public class HTTPClient {
  public static void main(String args[]){
    //确定HTTP请求的uri
    String uri="index.htm";
    if(args.length !=0)uri=args[0]; 
    
    doGet("localhost",8080,uri); //按照GET请求方式访问HTTPServer 
  }
  
  /** 按照GET请求方式访问HTTPServer */
  public static void doGet(String host,int port,String uri){
    Socket socket=null;
    
    try{
      socket=new Socket(host,port); //与HTTPServer建立FTP连接
    }catch(Exception e){e.printStackTrace();}
  
    try{
      /*创建HTTP请求 */
      StringBuffer sb=new StringBuffer("GET1 "+uri+" HTTP/1.1\r\n");
      sb.append("Accept: */*\r\n");
      sb.append("Accept-Language: zh-cn\r\n");
      sb.append("Accept-Encoding: gzip, deflate\r\n");
      sb.append("User-Agent: HTTPClient\r\n");
      sb.append("Host: localhost:8080\r\n");
      sb.append("Connection: Keep-Alive\r\n\r\n");
    
      /*发送HTTP请求*/
      OutputStream socketOut=socket.getOutputStream(); //获得输出流  
      socketOut.write(sb.toString().getBytes());
    
      Thread.sleep(2000); //睡眠2秒，等待响应结果
    
      /*接收响应结果*/
      InputStream socketIn=socket.getInputStream(); //获得输入流
      int size=socketIn.available();
      byte[] buffer=new byte[size];
      socketIn.read(buffer);
      System.out.println(new String(buffer)); //打印响应结果
      
    }catch(Exception e){ 
      e.printStackTrace();
    }finally{
      try{
        socket.close();  
      }catch(Exception e){e.printStackTrace();}
    }
  } //#doGet()
}




/****************************************************
 * 作者：孙卫琴                                     *
 * 来源：<<Tomcat与Java Web开发技术详解>>           *
 * 技术支持网址：www.javathinker.org                *
 ***************************************************/

 

四、运行方法：

1、先运行服务器端，以便等待客户端的连接：

     

 2、再启动客户端，发送http 请求：

       

3、观察服务器端的输出：

    

    特别说明，在本程序中，已经判断出客户端写错了GET请求，写成了GET1，但是，这里判断不严格，只是捕获出来了，但是不影响程序继续运行。