java网络编程实现web服务器

befairy

浏览: 37402 次
性别:
来自: 杭州

最近访客更多访客>>

gongnaixiao

bawanglb

lgh1992314

linwenhui0

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

编程 Java Web 浏览器 Socket

package number;

import java.io.BufferedReader;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.lang.Thread;

import java.util.StringTokenizer;

public class TCPServer {

	public static void main(String[] args) {
		int port;
		ServerSocket ss;
		try{
		   port=Integer.parseInt(args[0]);
		}catch(Exception e){
			port=8080;
		}
        
		try{
			//监听服务器端口，等待连接请求
            ss=new ServerSocket(port);
            System.out.println("TCPServer running on port:"+ss.getLocalPort());
          //显示启动信息
            while(true){
            	Socket socket=ss.accept();
            	System.out.println("New connection accepted"+socket.getInetAddress()+":"+socket.getPort());
            	//创建分线程
                 try{
                	 httpRequestHandle request=new httpRequestHandle(socket);
                	 Thread thread = new Thread(request);
                	 //启动线程
                	 thread.start();
                 }catch(Exception e){
                	 System.out.println(e);
                 }
                 
            }
		}catch(Exception e){
			System.out.println(e);
		}
	}

}

 class httpRequestHandle implements Runnable {

	final static String CRLF="\r\n";
	Socket socket;
	InputStream input;
	OutputStream output;
	BufferedReader br;
	//构造方法
	public httpRequestHandle(Socket socket)throws Exception{
		this.socket=socket;
		this.input=socket.getInputStream();
		this.output=socket.getOutputStream();
		this.br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
	}
	//实现Runnale接口的run()方法
	public void run() {
		try{
			processRequest();
		}catch(Exception e){
			 System.out.println(e);
		}
	}
	
	private void processRequest() throws Exception{
		while(true){
			//读取并显示web浏览器提交的请求信息
			String headerLine=br.readLine();
			System.out.println("The client request is"+headerLine);
			if(headerLine.equals(CRLF)||headerLine.equals("")){
				break;
			}
			StringTokenizer s=new StringTokenizer(headerLine);
			String temp=s.nextToken();
			if(temp.equals("GET")){
				String fileName=s.nextToken();
				fileName="."+fileName;
				//打开所有请求的文件
				FileInputStream fis=null;
				boolean fileExists=true;
				try{
					fis=new FileInputStream(fileName);
				}catch(FileNotFoundException e){
					fileExists=false;
				}
				//完成回应消息
				String serverLine = "Server: a simple java httpServer";
				String statusLine = null;
				String contentTypeLine = null;
				String entityBody = null;
				String contentLengthLine = "error";
				if ( fileExists )
			    {
				statusLine = "HTTP/1.0 200 OK" + CRLF ;
				contentTypeLine = "Content-type: " +
				    contentType( fileName ) + CRLF ;
				contentLengthLine = "Content-Length: "
				    + (new Integer(fis.available())).toString()
				    + CRLF;
			    }
			else
			    {
				statusLine = "HTTP/1.0 404 Not Found" + CRLF ;
				contentTypeLine = "text/html" ;
				entityBody = "<HTML>" +
				    "<HEAD><TITLE>404 Not Found</TITLE></HEAD>" +
				    "<BODY>404 Not Found"
				    +"<br>usage:http://yourHostName:port/"
				    +"fileName.html</BODY></HTML>" ;
			    }
				// 发送到服务器信息
				output.write(statusLine.getBytes());
				output.write(serverLine.getBytes());
				output.write(contentTypeLine.getBytes());
				output.write(contentLengthLine.getBytes());
		        output.write(CRLF.getBytes());
				// 发送信息内容
				if (fileExists)
				    {
					sendBytes(fis, output) ;
					fis.close();
				    }
				else
				    {
					output.write(entityBody.getBytes());
				    }

			}
		}
		//关闭套接字和流
		try {
		    output.close();
		    br.close();
		    socket.close();
		}
		catch(Exception e) {
			System.out.println(e);
		}

	}
	private static void sendBytes(FileInputStream fis, OutputStream os)
	throws Exception
    {
	// 创建一个 1K buffer
	byte[] buffer = new byte[1024] ;
	int bytes = 0 ;
	// 将文件输出到套接字输出流中
	while ((bytes = fis.read(buffer)) != -1 )
	    {
		os.write(buffer, 0, bytes);
	    }
    }
    private static String contentType(String fileName)
    {
	if (fileName.endsWith(".htm") || fileName.endsWith(".html"))
	    {
		return "text/html";
	    }

	return "fileName";
    }


}

分享到：