java使用socket实现一个多线程web服务器的方法

package com.lp.app.webserver;

import java.io.*;

import java.net.*;

//使用 socket 创建一个 web服务器 ，本程序是多线程系统以提高反应速度。

class webserver

{

  public static string webroot = "" ; //默认目录

  public static string defaultpage = "index.htm" ; //默认文件

  public static void main (string [] args) throws ioexception

  {

  system.out.println ( "服务器启动...\n" );

  //使用8080端口提供服务

  serversocket server = new serversocket ( 8080 );

  while ( true )

  {

   //阻塞，直到有客户连接

   socket sk = server.accept ();

   system.out.println ( "accepting connection...\n" );

   //启动服务线程

   new webthread (sk).start ();

  }

  }

}

//使用线程，为多个客户端服务

class webthread extends thread

{

  private socket sk;

  webthread (socket sk)

  {

   this .sk = sk;

  }

  //线程体

  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 ( "关闭连接...\n" );

   //最后释放资源

   try {

    if (in != null )

    in.close ();

    if (out != null )

    out.close ();

    if (sk != null )

    sk.close ();

   }

   catch (ioexception e)

   {

   }

   }

  }

}

package com.lp.app.webserver;

import java.io.*;

import java.net.*;

//获取客户的http请求，分析客户所需要的文件

public class request{

  inputstream in = null ;

  //获得输入流。这是客户的请求数据。

  public request(inputstream input){

  this .in = input;

  }

  //解析客户的请求

  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());

  }

  //获取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 ;

  }

}

package com.lp.app.webserver;

import java.io.*;

import java.net.*;

//获得用户请求后将用户需要的文件读出，添加上http应答头。发送给客户端。

public class response{

  outputstream out = null ;

  //发送请求的文件

  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();

  }

  }

  //获取输出流

  public response(outputstream output) {

  this .out = output;

}

}