java简单的单文件服务器

　　该服务器的功能：无论接受到何种请求，都始终发送同一个文件。这个服务器命名为SingleFileHTTPServer，文件名、本地端口和内容编码方式从命令行读取。如果缺省端口，则假定端口号为80。如果缺省编码方式，则假定为ASCII。

代码为：

  1. import java.io.*;  
  2. import java.net.ServerSocket;  
  3. import java.net.Socket;  
  4.  
  5.  
  6. public class SingleFileHTTPServer extends Thread {  
  7.       
  8.     private byte[] content;  
  9.     private byte[] header;  
  10.     private int port=80;  
  11.       
  12.     private SingleFileHTTPServer(String data, String encoding,  
  13.                 String MIMEType, int port) throws UnsupportedEncodingException {  
  14.         this(data.getBytes(encoding), encoding, MIMEType, port);  
  15.     }  
  16.       
  17.     public SingleFileHTTPServer(byte[] data, String encoding, String MIMEType, int port)throws UnsupportedEncodingException {  
  18.         this.content=data;  
  19.         this.port=port;  
  20.         String header="HTTP/1.0 200 OK\r\n"+  
  21.             "Server: OneFile 1.0\r\n"+  
  22.             "Content-length: "+this.content.length+"\r\n"+  
  23.             "Content-type: "+MIMEType+"\r\n\r\n";  
  24.         this.header=header.getBytes("ASCII");  
  25.     }  
  26.       
  27.     public void run() {  
  28.         try {  
  29.             ServerSocket server=new ServerSocket(this.port);  
  30.             System.out.println("Accepting connections on port "+server.getLocalPort());  
  31.             System.out.println("Data to be sent:");  
  32.             System.out.write(this.content);  
  33.               
  34.             while (true) {  
  35.                 Socket connection=null;  
  36.                 try {  
  37.                     connection=server.accept();  
  38.                     OutputStream out=new BufferedOutputStream(connection.getOutputStream());  
  39.                     InputStream in=new BufferedInputStream(connection.getInputStream());  
  40.                       
  41.                     StringBuffer request=new StringBuffer();  
  42.                     while (true) {  
  43.                         int c=in.read();  
  44.                         if (c=='\r'||c=='\n'||c==-1) {  
  45.                             break;  
  46.                         }  
  47.                         request.append((char)c);  
  48.                           
  49.                     }  
  50.                           
  51.                         //如果检测到是HTTP/1.0及以后的协议，按照规范，需要发送一个MIME首部  
  52.                         if (request.toString().indexOf("HTTP/")!=-1) {  
  53.                             out.write(this.header);  
  54.                         }  
  55.                           
  56.                         out.write(this.content);  
  57.                         out.flush();  
  58.                       
  59.                 } catch (IOException e) {  
  60.                     // TODO: handle exception  
  61.                 }finally{  
  62.                     if (connection!=null) {  
  63.                         connection.close();  
  64.                     }  
  65.                 }  
  66.             }  
  67.               
  68.         } catch (IOException e) {  
  69.             System.err.println("Could not start server. Port Occupied");  
  70.         }  
  71.     }  
  72.       
  73.     public static void main(String[] args) {  
  74.         try {  
  75.             String contentType="text/plain";  
  76.             if (args[0].endsWith(".html")||args[0].endsWith(".htm")) {  
  77.                 contentType="text/html";  
  78.             }  
  79.               
  80.             InputStream in=new FileInputStream(args[0]);  
  81.             ByteArrayOutputStream out=new ByteArrayOutputStream();  
  82.             int b;  
  83.             while ((b=in.read())!=-1) {  
  84.                 out.write(b);  
  85.             }  
  86.             byte[] data=out.toByteArray();  
  87.               
  88.             //设置监听端口  
  89.             int port;  
  90.             try {  
  91.                 port=Integer.parseInt(args[1]);  
  92.                 if (port<1||port>65535) {  
  93.                     port=80;  
  94.                 }  
  95.             } catch (Exception e) {  
  96.                 port=80;  
  97.             }  
  98.               
  99.             String encoding="ASCII";  
  100.             if (args.length>2) {  
  101.                 encoding=args[2];  
  102.             }  
  103.               
  105.             Thread t=new SingleFileHTTPServer(data, encoding, contentType, port);  
  106.             t.start();  
  107.               
  108.         } catch (ArrayIndexOutOfBoundsException e) {  
  109.              System.out.println("Usage:java SingleFileHTTPServer filename port encoding");  
  110.         }catch (Exception e) {  
  111.             System.err.println(e);// TODO: handle exception  
  112.         }  
  113.     }  
  114. }

SingleFileHTTPServer类本身是Thread的子类。它的run()方法处理入站连接。此服务器可能只是提供小文件，而且只支持 低吞吐量的web网站。由于服务器对每个连接所需完成的所有工作就是检查客户端是否支持HTTP/1.0，并为连接生成一两个较小的字节数组，因此这可能 已经足够了。另一方面，如果你发现客户端被拒绝，则可以使用多线程。许多事情取决于所提供文件的大小，每分钟所期望连接的峰值数和主机上Java的线程模 型。对弈这个程序复杂写的服务器，使用多线程将会有明显的收益。

Run()方法在指定端口创建一个ServerSocket。然后它进入无限循环，不断地接受连接并处理连接。当接受一个socket时，就会由一 个InputStream从客户端读取请求。它查看第一行是否包含字符串HTTP。如果包含此字符串，服务器就假定客户端理解HTTP/1.0或以后的版 本，因此为该文件发送一个MIME首部；然后发送数据。如果客户端请求不包含字符串HTTP，服务器就忽略首部，直接发送数据。最后服务器关闭连接，尝试 接受下一个连接。

而main()方法只是从命令行读取参数。从第一个命令行参数读取要提供的文件名。如果没有指定文件或者文件无法打开，就显示一条错误信息，程序退 出。如果文件能够读取，其内容就读入byte数组data.关于文件的内容类型，将进行合理的猜测，结果存储在contentType变量中。接下来，从 第二个命令行参数读取端口号。如果没有指定端口或第二个参数不是0到65535之间的整数，就使用端口80。从第三个命令行参数读取编码方式（前提是提供 了）。否则，编码方式就假定为ASCII。然后使用这些值构造一个SingleFileHTTPServer对象，开始运行。这是唯一可能的接口。

【推广】 免费学中医，健康全家人
原文地址：https://www.cnblogs.com/wxmarr/p/4534164.html