java实现一个简单的Web服务器实例解析
web服务器也称为超文本传输协议服务器,使用http与其客户端进行通信,基于java的web服务器会使用两个重要的类,
java.net.socket类和java.net.serversocket类,并基于发送http消息进行通信。
这个简单的web服务器会有以下三个类:
*httpserver
*request
*response
应用程序的入口在httpserver类中,main()
方法创建一个httpserver实例,然后调用其await()方法,顾名思义,await()
方法会在指定端口上等待http请求,对其进行处理,然后发送响应信息回客户端,在接收到关闭命令前,它会保持等待状态。
该应用程序仅发送位于指定目录的静态资源的请求,如html文件和图像,它也可以将传入到的http请求字节流显示到控制台,但是,它并不发送任何头信息到浏览器,如日期或者cookies等。
下面为这几个类的源码
request:
package cn.com.server; import java.io.inputstream; public class request { private inputstream input; private string uri; public request(inputstream input){ this.input=input; } public void parse(){ //read a set of characters from the socket stringbuffer request=new stringbuffer(2048); int i; byte[] buffer=new byte[2048]; try { i=input.read(buffer); } catch (exception e) { e.printstacktrace(); i=-1; } for (int j=0;j<i;j++){ request.append((char)buffer[j]); } system.out.print(request.tostring()); uri=parseuri(request.tostring()); } public string parseuri(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; } public string geturi(){ return this.uri; } }
request类表示一个http请求,可以传递inputstream对象来创建request对象,可以调用inputstream对象中的read()
方法来读取http请求的原始数据。
上述源码中的parse()
方法用于解析http请求的原始数据,parse()方法会调用私有方法parseuri()
来解析http请求的uri,除此之外,并没有做太多的工作,parseuri()
方法将uri存储在变量uri中,调用公共方法geturi()
会返回请求的uri。
response:
package cn.com.server; import java.io.file; import java.io.fileinputstream; import java.io.ioexception; import java.io.outputstream; /** * http response = status-line * *(( general-header | response-header | entity-header ) crlf) * crlf * [message-body] * status-line=http-version sp status-code sp reason-phrase crlf * */ public class response { private static final int buffer_size=1024; request request; outputstream output; public response(outputstream output){ this.output=output; } public void setrequest(request request){ this.request=request; } public void sendstaticresource()throws ioexception{ byte[] bytes=new byte[buffer_size]; fileinputstream fis=null; try { file file=new file(httpserver.web_root,request.geturi()); if(file.exists()){ fis=new fileinputstream(file); int ch=fis.read(bytes,0,buffer_size); while(ch!=-1){ output.write(bytes, 0, buffer_size); ch=fis.read(bytes, 0, buffer_size); } } else{ //file not found 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>"; output.write(errormessage.getbytes()); } } catch (exception e) { system.out.println(e.tostring()); } finally{ if(fis!=null){ fis.close(); } } } }
response对象在httpserver类的await()
方法中通过传入套接字中获取的outputstream来创建。
response类有两个公共方法:setrequest()
和sendstaticresource()
,setrequest()
方法会接收一个request对象为参数,sendstaticresource()
方法用于发送一个静态资源到浏览器,如html文件。
httpserver:
package cn.com.server; import java.io.file; import java.io.inputstream; import java.io.outputstream; import java.net.inetaddress; import java.net.serversocket; import java.net.socket; public class httpserver { /** * web_root is the directory where our html and other files reside. * for this package,web_root is the "webroot" directory under the * working directory. * the working directory is the location in the file system * from where the java command was invoke. */ public static final string web_root=system.getproperty("user.dir")+file.separator+"webroot"; private static final string shutdown_command="/shutdown"; private boolean shutdown=false; public static void main(string[] args) { httpserver server=new httpserver(); server.await(); } public void await(){ serversocket serversocket=null; int port=8080; try { serversocket=new serversocket(port,1,inetaddress.getbyname("127.0.0.1")); } catch (exception e) { e.printstacktrace(); system.exit(0); } while(!shutdown){ socket socket=null; inputstream input=null; outputstream output=null; try { socket=serversocket.accept(); input=socket.getinputstream(); output=socket.getoutputstream(); //create request object and parse request request=new request(input); request.parse(); //create response object response response=new response(output); response.setrequest(request); response.sendstaticresource(); } catch (exception e) { e.printstacktrace(); continue; } } } }
这个类表示一个web服务器,这个web服务器可以处理对指定目录的静态资源的请求,该目录包括由公有静态变量final web_root指明的目录及其所有子目录。
现在在webroot中创建一个html页面,命名为index.html,源码如下:
<!doctype html> <html> <head> <meta charset="utf-8"> <title>insert title here</title> </head> <body> <h1>hello world!</h1> </body> </html>
现在启动该web服务器,并请求index.html静态页面。
所对应的控制台的输出:
如此,一个简单的http服务器便完成了。
总结
以上就是本文关于java实现一个简单的web服务器实例解析的全部内容,希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相关专题,如有不足之处,欢迎留言指出。感谢朋友们对本站的支持!
上一篇: FCK在线编辑器上传图片加入水印功能
推荐阅读
-
php实现的一个简单json rpc框架实例,jsonrpc框架实例_PHP教程
-
PHP分页初探 一个最简单的PHP分页代码的简单实现_php实例
-
Nodejs实现的一个静态服务器实例_node.js
-
使用JSP技术实现一个简单的在线测试系统的实例详解
-
使用Servlet和JSP实现一个简单的Web聊天室系统
-
php实现的一个简单json rpc框架实例_PHP
-
求一个简单的纯CSS3的实现_html/css_WEB-ITnose
-
Nodejs实现的一个静态服务器实例_node.js
-
一个简单的php实现的MySQL数据浏览器_php实例
-
java利用jsch实现sftp上传一个目录下的所有文件到Linux服务器