码迷,mamicode.com
首页 > Web开发 > 详细

自定义简单的(tomcat)web服务器

时间:2015-08-05 18:29:31      阅读:231      评论:0      收藏:0      [点我收藏+]

标签:服务器

           自从JSP发布之后,推出了各式各样的JSP引擎。Apache Group在完成GNUJSP1.0的开发以后,开始考虑在SUN的JSWDK基础上开发一个可以直接提供Web服务的JSP服务器,当然同时也支持Servlet, 这样Tomcat就诞生了。Tomcat是jakarta项目中的一个重要的子项目,其被JavaWorld杂志的编辑选为2001年度最具创新的java产品,同时它又是sun公司官方推荐的servlet和jsp容器,因此其越来越多的受到软件公司和开发人员的喜爱。servlet和jsp的最新规范都可以在tomcat的新版本中得到实现。其次,Tomcat是完全免费的软件,任何人都可以从互联网上自由地下载。Tomcat与Apache的组合相当完美。

      当然这次我自定义的tomcat是很简单的,只解析出普通的html页面进行响应然后回送的是字符串到浏览器,其他的css什么的自然是不不支持的,一个基于Java的web服务器用到的两个重要类:java.net.Socket和java.net.ServerSock,当然通信用的是http协议。

      好的,首先我们先新建一个tomcatServer入口类,这个类自然就是用serverSocket进行对socket的连接进行监听,然后再在线程中操作与浏览器的请求和响应:

<span style="font-size:18px;">import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public class TomcatServer {
	/**
	 * @param args
	 * 
	 * tomcatserver一有客户端上来就监听
	 * @throws IOException 
	 */
	public static void main(String[] args)  {
		int port=Integer.parseInt((String)WebProperties.getInstance().get("port"));
		ServerSocket ss=null;
		try {
			ss = new ServerSocket(port);
		} catch (IOException e) {
		
			Utils.printException(e);
		}
		System.out.println(Utils.formatDate()+"\t服务器启动,监听"+ss.getLocalPort()+"端口");
		while(true){
			Socket s=null;
			try {
				s=ss.accept();
			} catch (IOException e) {
				// TODO Auto-generated catch block
				Utils.printException(e);
			}
			System.out.println("客户端"+s.getRemoteSocketAddress()+"登陆上了服务器");
			//这是一个连接会话任务类,实现Runnable接口,网络操作需要启用线程
			//在会话任务类中
			HttpSessionTask hst=new HttpSessionTask(s);
			new Thread(hst).start();
		}
		
	}
}</span>

      浏览器此时是客户端,我们监听了一个端口,然后只要有客户端连接上来我们就要在HttpSession中对浏览器的请求做处理了,在这里我们要建一个配置文件用来定义资源文件的位置和端口号,这样就可以容易修改这些配置项了:

path:c:\defaultpage=index.html
port=10000
此时配置项我们只需要加载一次,解析这个文件并要做成单例的:

import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;

//要求单例
public class WebProperties extends Properties {
private static WebProperties myProperties;
	
	private WebProperties() {
		//在这里完成读取db.properties文件
			InputStream iis=WebProperties.class.getClassLoader().getResourceAsStream( "web.properties");
			try {
				this.load(   iis );
			} catch (IOException e) {
				
				e.printStackTrace();
			}
	}
	//多个客户端上来时,防止多线程
	public synchronized static WebProperties getInstance() {
		if( myProperties==null){
			 myProperties=new WebProperties();
		}
		return myProperties;
	}
}
在HttpSession这个会话类中,需要完成接收请求和回送响应两个操作,在我们的java的web服务器中,HttpServletRequest是用来发送请求的,HttpServletResponse是用来回送响应的,我们也模仿java的这个机制,用这两个类对请求和响应做处理

HttpServletRequest类要做的是解析浏览器发来的http协议拿到请求头里的资源地址,然后HttpServletResponse得到资源地址后解析资源进行拼接协议响应头回送给客户端,这样一次请求到响应浏览器就可以显示出资源地址的内容了。

自定义的HttpServletRequest类:

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.HashMap;
import java.util.Map;
/**
 * 这个请求类对浏览器发送的协议进行解析,得到资源地址(这里只考虑get方法,参数拚在请求头中,这里解析出来后不做处理)
 * @author Administrator
 *
 */
public class HttpServletRequest {
	private String uri;
	private String method;
	private String protocolVersion;
	private Map<String,String> parameter=new HashMap<String,String>();
	private InputStream iis;
	//这个构造函数的iis是从socket中得到的输入流
	public HttpServletRequest( InputStream iis) throws IOException{
		this.iis=iis;
		parse();
	}
	//解析协议的方法   GET /company/index.html HTTP/1.1
	private void parse() throws IOException {
		BufferedReader br=new BufferedReader(new InputStreamReader(iis));
		String line=null;
		int i=0;
		if((line=br.readLine())!=null){
			if(i==0){	
				parseCommandLine(line);
			}
			i++;
		}
	}
	private void parseCommandLine(String line) {
		if(line!=null&&!"".equals(line)){
			String [] strs=line.split(" ");
			method=strs[0];
			protocolVersion=strs[2];
			if("GET".equals(method)){
				doGet(strs[1]);
			}
		}
	}
	private void doGet(String str) {
		//解析是否有参数
		if(str.contains("?")){
			String[] strs=str.split("?");
			uri=strs[0];
			String[] ps=strs[1].split("&");
			for(String s:ps){
				String[] pp=s.split("=");
				parameter.put(pp[0], pp[1]);
			}
		}else{
			uri=str;
		}
		
	}
	//get方法参数的类
	public String getParameter(String key) {
		String value=parameter.get(key);
		if(!value.equals("")||!(value==null)){
			return value;
		}else{
			return null;
		}
		
	}
	public String getUri() {
		return uri;
	}
	public String getMethod() {
		return method;
	}
	public String getProtocolVersion() {
		return protocolVersion;
	}
	
}
自定义的HttpServletResponse类:

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.OutputStream;

/**
 * 服务器响应类,这个类得到资源地址后对文件进行解析(这里只当字符全部输出),
 * 然后拼接响应头给浏览器浏览器接收后显示信息
 * @author Administrator
 *
 */
public class HttpServletResponse {
	private OutputStream oos;
	public HttpServletResponse(OutputStream oos){
		this.oos=oos;
	}
	public void redirect(String pageUrl){
		//输出流到客户端
		byte[] bs=new byte[1024];
		FileInputStream fis=null;
		File f=new File(pageUrl);
		if(!f.exists()){
			out404();
			return;
		}
		try {
			fis=new FileInputStream(f);
			StringBuffer sb=new StringBuffer();
			int length=-1;
			while((length=fis.read(bs,0,bs.length))!=-1){
				sb.append(new String(bs,0,length,"gbk"));
			}
			//正常的时候响应的协议
			String responseHead="HTTP/1.1 200 OK\r\nContent-Type: text/html;charset=gbk\r\nContent-Length: "+sb.toString().getBytes().length+"\r\n\r\n";
			out(responseHead,sb.toString());
		} catch (Exception e) {
			// TODO Auto-generated catch block
			Utils.printException(e);
		} 
	}
	private void out404() {
		String responseBody="<h1>没有页面</h1>";
		//TODO:
		String responseHead="HTTP/1.1 404 Not Found\r\nContent-Type: text/html;charset=utf-8\r\nContent=Length: "
			+responseBody.getBytes().length+"\r\n\r\n";
		try{
			out(responseBody,responseHead);
			
		}catch(Exception e){
			Utils.printException(e);
		}
		
	}
	private void out(String responseHead,String responseBody) throws IOException{
		oos.write(responseHead.getBytes());
		oos.write(responseBody.getBytes());
		oos.flush();
	}
}
最后一个就是我们的会话类了,这个类进行集中处理整个流程的操作:

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

/**
 * 
 * @author Administrator
 *获取输入流,得到客户端传来的协议
 *将协议解析一个HttpServerletRequest对象(http://localhost/compay/index.html)
 *协议 GET /company/index.html HTTP/1.1
 */
public class HttpSessionTask implements Runnable {
	private Socket s;
	private InputStream iis;
	private OutputStream oos;
	private boolean flag=true;
	public HttpSessionTask(Socket s){
		this.s=s;
		try {
			iis=s.getInputStream();
			oos=s.getOutputStream();
		} catch (IOException e) {
			Utils.printException(e);
			flag=false;
		}
		
	}
	//因为http协议是一个无状态的,请求完后回应一次断开
	public void run() {
		if(flag==false){
			return;
		}
		
		try {
			//创建requset对象解析http协议的请求部分   GET /company/index.html HTTP/1.1
			//得到资源地址 /kaw/index.html
			//通过配置文件找到path c:\kaw\index.html
			//再创建response对象,调用redirect(path);
			HttpServletRequest request=new HttpServletRequest(iis);
			String uri=request.getUri();
			String filepath=WebProperties.getInstance().getProperty("path")+uri;
			HttpServletResponse response=new HttpServletResponse(oos);
			response.redirect(filepath);
		} catch (IOException e) {
			// TODO Auto-generated catch block
			Utils.printException(e);
			out500(e);
		}finally{
			if(this.s!=null){
				try {
					s.close();
				} catch (IOException e) {
					
					e.printStackTrace();
				}
			}
		}	
	}
	private void out500(Exception e) {
		//拼接协议输出错误信息
		//略
		
	}

}
好的,我们只需要在c盘放一个普通的html文件,启动tomcatserver类。

技术分享

用浏览器访问地址:

技术分享

网页就被读取出来了,当然这是个很简单的服务器,也只能操作普通文本,后续的学习希望可以深入服务器的学习,多多交流!



      

版权声明:本文为博主原创文章,未经博主允许不得转载。

自定义简单的(tomcat)web服务器

标签:服务器

原文地址:http://blog.csdn.net/u010214269/article/details/47297285

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!