Go语言视频零基础入门到精通

javalearner

这是服务器部分
import java.net.*;
import java.io.*;
import java.util.*;

public class HTTPServer  
{
String serverName;
   String Version;
   int serverPort;

   // 构造一个server，并运行
   public static void main(String args[])
   {
    HTTPServer server = new HTTPServer("HTTPServer", "1.0", 80);
    server.run();
   }  
  
   
   
   

   
  
   // 定义server的名字、版本号、端口
   public HTTPServer(String name, String version, int port)  
   {
    this.serverName = name;
    this.Version = version;
    this.serverPort = port;
   }
   
   public void run()  
   {
    // 显示名字和版本号
                 System.out.println(serverName+" version ");
    try  
    {
     // 得到服务监听端口
     ServerSocket server = getServerSocket();
     
     do  
     {
      // 等待连接请求
      Socket client = server.accept();
      // 为连接请求分配一个线程
      (new HTTPServerThread(client)).start();
     }while(true);
    }  
    catch(Exception e)  
    {
     e.printStackTrace();
     System.exit(1);
    }
   }
   
   //服务器的构造方法，
   //我们可以对其构造方法进行扩展，
   //参考JSSE技术一章中的SSL扩展
   ServerSocket getServerSocket() throws Exception  
   {
    return new ServerSocket(serverPort);
   }
}




class HTTPServerThread extends Thread  
{
   Socket client;

   public HTTPServerThread(Socket client)  
   {
    this.client = client;
   }

   public void run()  
   {
    try  
    {
     describeConnectionInfo(client);

     BufferedOutputStream outStream = new  
BufferedOutputStream(client.getOutputStream());
//HTTPInputStream是自定义的过滤流
     HTTPInputStream inStream = new HTTPInputStream(client.getInputStream());

     //得到请求头
     HTTPRequest request = inStream.getRequest();
     //显示头信息
     request.log();
     //只处理GET请求
     if(request.isGetRequest())
      processGetRequest(request,outStream);
     System.out.println("Request completed. Closing connection.");
     //非持久性
     client.close();
    }
    catch(IOException e)  
    {
     System.out.println("IOException occurred .");
     e.printStackTrace();
    }
   
   
}
   
   // Display info about the connection
void describeConnectionInfo(Socket client)  
{
    //服务端主机名
    String destName = client.getInetAddress().getHostName();
    //服务端IP地址
    String destAddr = client.getInetAddress().getHostAddress();
    //服务端端口
    int destPort = client.getPort();
    //打印信息
    System.out.println("Accepted connection to "+destName+" ("+destAddr+")"+" on port "+destPort+".");
   }
   
   // 处理GET请求
   void processGetRequest(HTTPRequest request,BufferedOutputStream outStream)
     throws IOException  
     {
    String fileName = request.getFileName();
    File file = new File(fileName);
    // Give them the requested file
    if(file.exists()) sendFile(outStream,file);
    else System.out.println("File "+file.getCanonicalPath()+" does not exist.");
   }
   //  HTTP 1.0 回应
   void sendFile(BufferedOutputStream out,File file)  
   {
    try  
    {
     DataInputStream in = new DataInputStream(new FileInputStream(file));
     int len = (int) file.length();
     byte buffer[] = new byte[len];
     in.readFully(buffer);
     in.close();
     out.write("HTTP/1.0 200 OK
".getBytes());
     out.write(("Content-Length: " + buffer.length + "
").getBytes());
     out.write("Content-Type: text/HTML

".getBytes());
     out.write(buffer);
     out.flush();
     out.close();
     System.out.println("File sent: "+file.getCanonicalPath());
     System.out.println("Number of bytes: "+len);
    }
    catch(Exception e)
    {
     try  
     {
      out.write(("HTTP/1.0 400 " + "No can do" + "
").getBytes());
      out.write("Content-Type: text/HTML

".getBytes());
     }
     catch(IOException ioe)  
     {
     }
     System.out.println("Error retrieving "+file);
    }
   }
}


// 实现读客户端请求的帮助类
class HTTPInputStream extends FilterInputStream  
{
public HTTPInputStream(InputStream in)  
{
    super(in);
   }
   // 读一行
   public String readLine() throws IOException  
   {
    StringBuffer result=new StringBuffer();
    boolean finished = false;
    //回车符
    boolean cr = false;
    do  
    {
     int ch = -1;
     ch = read();
     if(ch==-1) return result.toString();
     result.append((char) ch);
     //去掉最后的"
"
     if(cr && ch==10)
     {
      result.setLength(result.length()-2);
      return result.toString();
     }
     //读到回车符，设置标识
     if(ch==13) cr = true;
     else cr=false;
    } while (!finished);
    return result.toString();
   }
   // 得到所有的请求
   public HTTPRequest getRequest() throws IOException  
   {
    HTTPRequest request = new HTTPRequest();
    String line;
    do  
    {
     line = readLine();
     //将请求填入容器
     if(line.length()>0) request.addLine(line);
     else break;
    }while(true);
    return request;
   }
}

// 客户端请求的封装类
class HTTPRequest  
{
Vector lines = new Vector();

   public HTTPRequest()  
   {
   }
   public void addLine(String line)  
   {
    lines.addElement(line);
   }
   // 判断是否是Get请求
  boolean isGetRequest()  
  {
    if(lines.size() > 0)  
    {
     String firstLine = (String) lines.elementAt(0);
     if(firstLine.length() > 0)
      if(firstLine.substring(0,3).equalsIgnoreCase("GET"))
       return true;
    }
    return false;
   }
   // 从请求中解析到文件名
   String getFileName()  
   {
    if(lines.size()>0)  
    {
     //得到vector中第一个元素
     String firstLine = (String) lines.elementAt(0);
     //得到文件名
     //根据http消息格式
     String fileName = firstLine.substring(firstLine.indexOf(" ")+1);
     int n = fileName.indexOf(" ");
     //URL在两个空格之间
     if(n!=-1) fileName = fileName.substring(0,n);
     
     //去掉第一个"/"
     try  
     {
      if(fileName.charAt(0) == "/") fileName = fileName.substring(1);
     }  
     catch(StringIndexOutOfBoundsException ex) {}
     
     //默认首页
     //类似于"http://localhost:80"的情况
     if(fileName.equals("")) fileName = "index.htm";
     //类似于"http://localhost:80//"的情况
     if(fileName.charAt(fileName.length()-1)=="/")
      fileName+="index.htm";
     return fileName;
    }else return "";
   }
   // 显示请求信息
   void log()  
   {
    System.out.println("Received the following request:");
    for(int i=0;i<lines.size();++i)
     System.out.println((String) lines.elementAt(i));
   }
}

运行：

C:java>java  HTTPServer
HTTPServer version
Accepted connection to 127.0.0.1 (127.0.0.1) on port 1057.
Received the following request:
GET /index.htm HTTP/1.1
User-Agent: Java/1.4.2_03
Host: 127.0.0.1
Accept: text/html, image/gif, image/jpeg, *; q=.2, */*; q=.2
Connection: keep-alive
File sent: C:javaindex.htm
Number of bytes: 47
Request completed. Closing connection.    这是客户端部分
import java.io.*;
import java.net.*;
public class Browser  
{
//网址URL
String urlString;
    public static void main(String[] args) throws Exception  
    {
       if(args.length != 1)  
       {
        System.out.println("Usage: Java Browser url");
        System.exit(1);
       }
       Browser browser = new Browser(args[0]);
       browser.run();
    }
    public Browser(String urlString)  
    {
       this.urlString = urlString;
    }
    public void run() throws Exception  
    {
       //生成一个URL对象
       URL url = new URL(urlString);
       //得到输入流
       HttpURLConnection urlc = (HttpURLConnection) url.openConnection();
       //打印头信息
       System.out.println("THE HEADERS");
       System.out.println("-----------");
       for(int i=1;;++i)  
       {
         String key;
         String value;
         if((key = urlc.getHeaderFieldKey(i)) == null) break;
         if((value = urlc.getHeaderField(i)) == null) break;
         System.out.print(key);
         System.out.println(" is: " + value);
       }
       //得到输入流
       BufferedReader reader = new BufferedReader(
       new InputStreamReader(urlc.getInputStream()));
       String line;
       System.out.println("-----CONTENT------");
       while((line = reader.readLine()) != null) System.out.println(line);
    }
}


运行结果：

C:java>java   Browser  http://127.0.0.1:80/index.htm
THE HEADERS
-----------
Content-Length is: 47
Content-Type is: text/HTML
-----CONTENT------
<html>
<body>
How do you do
</body>
</html>  

  
  
   
   

     
   

   
   
  
  

源码下载：http://file.javaxxz.com/2014/11/1/000104671.zip