[JAVA100例]050、一个简单的Web服务器[Java编程]

import java.io.*;
import java.net.*;
/**
* <p>Title: 发现HTTP内容和文件内容</p>
* <p>Description: 得到用户恳求后将用户需求的文件读出,增添上HTTP应答头.发送给客户端.</p>
* <p>Copyright: Copyright (c) 2003</p>
* <p>Filename: Response.java</p>
* @version 1.0
*/
public class Response{
　OutputStream out = null;
/**
*<br>办法阐明:发送信息
*<br>输入参数:String ref 恳求的文件名
*<br>返回范例:
*/
　public void Send(String ref) throws IOException {
　　byte[] bytes = new byte[2048];
　　FileInputStream fis = null;
　　try {
　　　　//构造文件
　　　　File file　= new File(WebServer.WEBROOT, ref);
　　　　if (file.exists()) {
　　　　　　//构造输入文件流
　　　　　　fis = new FileInputStream(file);
　　　　　　int ch = fis.read(bytes, 0, 2048);
　　　　　　//读取文件
　　　　　　String sBody = new String(bytes,0);
　　　　　　//构造输出信息
　　　　　　String sendMessage = "HTTP/1.1 200 OK\r\n" +
　　　　　　　　"Content-Type: text/html\r\n" +
　　　　　　　　"Content-Length: "+ch+"\r\n" +
　　　　　　　　"\r\n" +sBody;
　　　　　　//输出文件
　　　　　　out.write(sendMessage.getBytes());
　　　　}else {
　　　　　　// 找不到文件
　　　　　　String errorMessage = "HTTP/1.1 404 File Not Found\r\n" +
　　　　　　　　"Content-Type: text/html\r\n" +
　　　　　　　　"Content-Length: 23\r\n" +
　　　　　　　　"\r\n" +
　　　　　　　　"<h1>File Not Found</h1>";
　　　　　　out.write(errorMessage.getBytes());
　　　　}
　　
　　}
　　catch (Exception e) {
　　　　// 如不能实例化File对象,抛出非常.
　　　　System.out.println(e.toString() );
　　}
　　finally {
　　　　if (fis != null)
　　　　　　fis.close();
　　}
}
/**
*<br>办法阐明:构造器,获得输出流
*<br>输入参数:
*<br>返回范例:
*/
public Response(OutputStream output) {
　　this.out = output;
}
}
import java.io.*;
import java.net.*;
/**
* <p>Title: 客户恳求解析</p>
* <p>Description: 获得客户的HTTP恳求,解析客户所需求的文件</p>
* <p>Copyright: Copyright (c) 2003</p>
* <p>Filename: Request.java</p>
* @version 1.0
*/
public class Request{
　InputStream in = null;
/**
*<br>办法阐明:构造器,得到输入流.这时客户的恳求数据.
*<br>输入参数:
*<br>返回范例:
*/
　public Request(InputStream input){
　　this.in = input;
　}
/**
*<br>办法阐明:解析客户的恳求
*<br>输入参数:
*<br>返回范例:String 恳求文件字符
*/
　public String parse() {
　　//从Socket读取一组数据
　　StringBuffer requestStr = new StringBuffer(2048);
　　int i;
　　byte[] buffer = new byte[2048];
　　try {
　　　　i = in.read(buffer);
　　}
　　catch (IOException e) {
　　　　e.printStackTrace();
　　　　i = -1;
　　}
　　for (int j=0; j<i; j++) {
　　　　requestStr.append((char) buffer[j]);
　　}
　　System.out.print(requestStr.toString());
　　return getUri(requestStr.toString());
　}
/**
*<br>办法阐明:获得URI字符
*<br>输入参数:String requestString 恳求字符
*<br>返回范例:String URI信息字符
*/
　private String getUri(String requestString) {
　　int index1, index2;
　　index1 = requestString.indexOf(´ ´);
　　if (index1 != -1) {
　　　　index2 = requestString.indexOf(´ ´, index1 + 1);
　　　　if (index2 > index1)
　　　　　 return requestString.substring(index1 + 1, index2);
　　}
　　return null;
　}
}
import java.io.*;
import java.net.*;
import java.util.*;
/**
* <p>Title: WEB服务器</p>
* <p>Description: 利用Socket成立一个WEB服务器,本程序是多线程系统以提高反映速度.</p>
* <p>Copyright: Copyright (c) 2003</p>
* <p>Filename: WebServer.java</p>
* @version 1.0
*/
class WebServer
{
public static String WEBROOT = "";//默许目录
public static String defaultPage = "index.htm";//默许文件
public static void main (String [] args) throws IOException
{//利用输入的方法告诉服务默许目录位置,可用./root表示.
　 if(args.length!=1){
　　 System.out.println("USE: java WebServer ./rootdir");
　　 return;
　 }else{
　　 WEBROOT = args[0];
　 }
　 System.out.println ("Server starting...\n");
　 //利用8000端口供应服务
　 ServerSocket server = new ServerSocket (8000);
　 while (true)
　 {
　　//阻塞,直到有客户衔接
　　 Socket sk = server.accept ();
　　 System.out.println ("Accepting Connection...\n");
　　 //启动服务线程
　　 new WebThread (sk).start ();
　 }
}
}
/**
* <p>Title: 服务子线程</p>
* <p>Description: 利用线程,为多个客户端服务</p>
* <p>Copyright: Copyright (c) 2003</p>
* <p>Filename: </p>
* @author 杜江
* @version 1.0
*/
class WebThread extends Thread
{
private Socket sk;
WebThread (Socket sk)
{
　this.sk = sk;
}
/**
*<br>办法阐明:线程体
*<br>输入参数:
*<br>返回范例:
*/
public void run ()
{
　InputStream in = null;
　OutputStream out = null;
　try{
　　in = sk.getInputStream();
　　out = sk.getOutputStream();
　　　//接纳来自客户端的恳求.
　　　Request rq = new Request(in);
　　　//解析客户恳求
　　　String sURL = rq.parse();
　　　System.out.println("sURL="+sURL);
　　　if(sURL.equals("/")) sURL = WebServer.defaultPage;
　　　Response rp = new Response(out);
　　　rp.Send(sURL);
　　}catch (IOException e)
　　{
　　　 System.out.println (e.toString ());
　　}
　　finally
　　{
　　　System.out.println ("Closing Connection...\n");
　　　//最后释放资源
　　　try{
　　　 if (in != null)
　　　　 in.close ();
　　　 if (out != null)
　　　　 out.close ();
　　　　if (sk != null)
　　　　　sk.close ();
　　　}
　　　catch (IOException e)
　　　{
　　　}
　　}
}
}