自己如何实现简单的http服务器
2003-04-30 16:10
941 查看
文件名：MyHttpServerTest.java
import java.io.* ;
import java.net.* ;
import java.util.* ;
/**
* main
*/
public class MyHttpServerTest{
String m_szServerName;//server name
String m_szVersion;//server version
int m_nServerPort;//port
public MyHttpServerTest(String szServerName,String szVersion,int nServerPort){
this.m_szServerName =szServerName;
this.m_szVersion =szVersion;
this.m_nServerPort=nServerPort;
}
/**
* show version information
*/
public void showServerInformation(){
System.out.println("欢迎使用Newman的HTTP服务器！");
System.out.println("Server Name : "+this.m_szServerName);
System.out.println("Server Version: "+this.m_szVersion );
}
public void start (){
this.showServerInformation();
try{
ServerSocket server=new ServerSocket(this.m_nServerPort );
while(true){
Socket client=server.accept();
(new HttpClientThread(client)).run();
}
}
catch(Exception e){
e.printStackTrace();
System.exit(1);
}
}
public static void main(String args[]){
MyHttpServerTest server=new MyHttpServerTest("MyHttpServerTest","1.0",80);
server.start();
}
}
class HttpClientThread implements Runnable {
Socket m_sClient;
HTTPRequest m_Request;
HttpClientThread(Socket sClient)throws IOException{
this.m_sClient =sClient;
this.m_Request =new HTTPRequest(this.m_sClient );
}
public void run(){
try{
System.out.println(this.getConnectInfo());
BufferedOutputStream out=new BufferedOutputStream(this.m_sClient .getOutputStream ());
System.out.println( this.m_Request.getLog());
if(this.m_Request.isGetRequest())
this.processGetRequest(this.m_Request,out);
System.out.println("Request completed. Closing connection.");
this.m_sClient .close ();
}
catch(IOException e){
System.out.println("IOException occurred .");
e.printStackTrace();
}
}
/**
* get Connect Info
*/
public String getConnectInfo(){
String szClientHostName=this.m_sClient .getInetAddress().getHostName ();
String szClientAddress=this.m_sClient .getInetAddress ().getHostAddress();
int ClientPort=this.m_sClient .getPort ();
String szRet="";
szRet="Accepted connection from "+szClientHostName+"("+szClientAddress+") "+"on port "+ClientPort+".";
return szRet;
}
void processGetRequest(HTTPRequest request,BufferedOutputStream out)throws IOException {
String szFileName=request.getFileName ();
File file=new File (szFileName);
if(file.exists ())
this.sendFile (out,file);
else{//文件不存在时
System.out.println ("File "+file.getCanonicalPath()+" does not exist.");
String notfound="<html><head><title>Not Found</title></head><body><h1>"+
"Error 404-file not found</h1><p>"+
"File Name: "+file+" not found"+"<br>"+
"<a href=index.htm>Return Index</a>"+
"</body></html>";
file://out.write(new String("HTTP/1.0 404 no found").getBytes ());
out.write (new String ("HTTP/1.0 200 OK/r/n").getBytes ());
out.write(new String("Content_Length:"+notfound.length()+2).getBytes());
out.write(new String("Content_Type:text/html/r/n/r/n").getBytes ());
out.write(new String(" ").getBytes());
out.write(notfound.getBytes ());
out.flush();
}
}
void sendFile(BufferedOutputStream out,File file){
try{
DataInputStream din=new DataInputStream (new FileInputStream (file ));
int len=(int)file.length();
byte buffer[]=new byte [len];
din.readFully (buffer);
din.close();
out.write (new String ("HTTP/1.0 200 OK/r/n").getBytes ());
out.write (new String ("Content-Length: "+buffer.length +"/r/n").getBytes ());
out.write (new String ("Content-Type: text/html/r/n/r/n").getBytes ());
out.write (buffer);
out.flush ();
out.close ();
System.out.println("File sent: "+file.getCanonicalPath());
System.out.println("Number of bytes: "+len);
}
catch(Exception e){
try{
out.write(("HTTP/1.0 400 " + "No can do" + "/r/n").getBytes());
out.write("Content-Type: text/html/r/n/r/n".getBytes());
}
catch(IOException ioe){
System.out.println("Error retrieving "+file);
}
}
}
}
Vector m_vLines=new Vector ();
Socket m_sClient;
HttpInputStream m_In;
HTTPRequest(Socket client)throws IOException{
this.m_sClient =client;
this.m_In =new HttpInputStream(this.m_sClient.getInputStream());
this.getRequest ();
}
public String getLog(){
StringBuffer szRet=new StringBuffer() ;
szRet.append ("Received the following request:"+"/n");
Enumeration enum=m_vLines.elements ();
String szstr1="";
while(enum.hasMoreElements()){
szstr1=(String)enum.nextElement();
szRet.append (szstr1+"/n");
}
return szstr1.toString();
}
boolean isGetRequest() {
if(this.m_vLines .size ()>0){
String firstline=(String)this.m_vLines.elementAt (0);
if(firstline.length ()>0)
if(firstline.substring(0,3).equalsIgnoreCase ("GET"))
return true;
}
return false;
}
String getFileName() {
if(this.m_vLines .size ()>0){
String firstline=(String)this.m_vLines.elementAt (0);
String filename=firstline.substring (firstline.indexOf (" ")+1);
int n=filename.indexOf (" ");
if(n!=-1)
filename=filename.substring (0,n);
try{
if(filename.charAt(0)=='/' )
filename=filename.substring (1);
}
catch(StringIndexOutOfBoundsException ex){
}
if(filename.equals (""))
filename="index.htm";
if(filename.charAt (filename.length ()-1)=='/')
filename+="index.htm";//not understand
return filename;
}
else
return "";
}
public HttpInputStream getInputStream(){
return this.m_In ;
}
public HTTPRequest getRequest() throws IOException {
String line;
while(true){
line=this.m_In.readLine ();
if(line.length ()>0)
this.m_In.addLine(line);
else
break;
}
return this;
}
/**
* only use to recognize methed "get"
*/
class HttpInputStream extends FilterInputStream {
HttpInputStream(InputStream in){
super(in);
}
public void addLine(String line) {
m_vLines .addElement(line);
}
public String readLine() throws IOException {
StringBuffer result=new StringBuffer ();
boolean finished=false;
boolean isenter=false;
while(!finished){
int ch=-1;
ch=read();
if((isenter)&&(ch==10)){// if it is "/n/r"
result.setLength(result.length()-1);//had added "/n",remove it
return result.toString ();
}
if(ch==13)//if enter pressed
isenter=true;
else
isenter=false;
if(ch==-1)//end
return result.toString ();
else
result.append ((char)ch);
}
return result.toString ();
}
}
}
请多指教
import java.io.* ;
import java.net.* ;
import java.util.* ;
/**
* main
*/
public class MyHttpServerTest{
String m_szServerName;//server name
String m_szVersion;//server version
int m_nServerPort;//port
public MyHttpServerTest(String szServerName,String szVersion,int nServerPort){
this.m_szServerName =szServerName;
this.m_szVersion =szVersion;
this.m_nServerPort=nServerPort;
}
/**
* show version information
*/
public void showServerInformation(){
System.out.println("欢迎使用Newman的HTTP服务器！");
System.out.println("Server Name : "+this.m_szServerName);
System.out.println("Server Version: "+this.m_szVersion );
}
public void start (){
this.showServerInformation();
try{
ServerSocket server=new ServerSocket(this.m_nServerPort );
while(true){
Socket client=server.accept();
(new HttpClientThread(client)).run();
}
}
catch(Exception e){
e.printStackTrace();
System.exit(1);
}
}
public static void main(String args[]){
MyHttpServerTest server=new MyHttpServerTest("MyHttpServerTest","1.0",80);
server.start();
}
}
class HttpClientThread implements Runnable {
Socket m_sClient;
HTTPRequest m_Request;
HttpClientThread(Socket sClient)throws IOException{
this.m_sClient =sClient;
this.m_Request =new HTTPRequest(this.m_sClient );
}
public void run(){
try{
System.out.println(this.getConnectInfo());
BufferedOutputStream out=new BufferedOutputStream(this.m_sClient .getOutputStream ());
System.out.println( this.m_Request.getLog());
if(this.m_Request.isGetRequest())
this.processGetRequest(this.m_Request,out);
System.out.println("Request completed. Closing connection.");
this.m_sClient .close ();
}
catch(IOException e){
System.out.println("IOException occurred .");
e.printStackTrace();
}
}
/**
* get Connect Info
*/
public String getConnectInfo(){
String szClientHostName=this.m_sClient .getInetAddress().getHostName ();
String szClientAddress=this.m_sClient .getInetAddress ().getHostAddress();
int ClientPort=this.m_sClient .getPort ();
String szRet="";
szRet="Accepted connection from "+szClientHostName+"("+szClientAddress+") "+"on port "+ClientPort+".";
return szRet;
}
void processGetRequest(HTTPRequest request,BufferedOutputStream out)throws IOException {
String szFileName=request.getFileName ();
File file=new File (szFileName);
if(file.exists ())
this.sendFile (out,file);
else{//文件不存在时
System.out.println ("File "+file.getCanonicalPath()+" does not exist.");
String notfound="<html><head><title>Not Found</title></head><body><h1>"+
"Error 404-file not found</h1><p>"+
"File Name: "+file+" not found"+"<br>"+
"<a href=index.htm>Return Index</a>"+
"</body></html>";
file://out.write(new String("HTTP/1.0 404 no found").getBytes ());
out.write (new String ("HTTP/1.0 200 OK/r/n").getBytes ());
out.write(new String("Content_Length:"+notfound.length()+2).getBytes());
out.write(new String("Content_Type:text/html/r/n/r/n").getBytes ());
out.write(new String(" ").getBytes());
out.write(notfound.getBytes ());
out.flush();
}
}
void sendFile(BufferedOutputStream out,File file){
try{
DataInputStream din=new DataInputStream (new FileInputStream (file ));
int len=(int)file.length();
byte buffer[]=new byte [len];
din.readFully (buffer);
din.close();
out.write (new String ("HTTP/1.0 200 OK/r/n").getBytes ());
out.write (new String ("Content-Length: "+buffer.length +"/r/n").getBytes ());
out.write (new String ("Content-Type: text/html/r/n/r/n").getBytes ());
out.write (buffer);
out.flush ();
out.close ();
System.out.println("File sent: "+file.getCanonicalPath());
System.out.println("Number of bytes: "+len);
}
catch(Exception e){
try{
out.write(("HTTP/1.0 400 " + "No can do" + "/r/n").getBytes());
out.write("Content-Type: text/html/r/n/r/n".getBytes());
}
catch(IOException ioe){
System.out.println("Error retrieving "+file);
}
}
}
}
Vector m_vLines=new Vector ();
Socket m_sClient;
HttpInputStream m_In;
HTTPRequest(Socket client)throws IOException{
this.m_sClient =client;
this.m_In =new HttpInputStream(this.m_sClient.getInputStream());
this.getRequest ();
}
public String getLog(){
StringBuffer szRet=new StringBuffer() ;
szRet.append ("Received the following request:"+"/n");
Enumeration enum=m_vLines.elements ();
String szstr1="";
while(enum.hasMoreElements()){
szstr1=(String)enum.nextElement();
szRet.append (szstr1+"/n");
}
return szstr1.toString();
}
boolean isGetRequest() {
if(this.m_vLines .size ()>0){
String firstline=(String)this.m_vLines.elementAt (0);
if(firstline.length ()>0)
if(firstline.substring(0,3).equalsIgnoreCase ("GET"))
return true;
}
return false;
}
String getFileName() {
if(this.m_vLines .size ()>0){
String firstline=(String)this.m_vLines.elementAt (0);
String filename=firstline.substring (firstline.indexOf (" ")+1);
int n=filename.indexOf (" ");
if(n!=-1)
filename=filename.substring (0,n);
try{
if(filename.charAt(0)=='/' )
filename=filename.substring (1);
}
catch(StringIndexOutOfBoundsException ex){
}
if(filename.equals (""))
filename="index.htm";
if(filename.charAt (filename.length ()-1)=='/')
filename+="index.htm";//not understand
return filename;
}
else
return "";
}
public HttpInputStream getInputStream(){
return this.m_In ;
}
public HTTPRequest getRequest() throws IOException {
String line;
while(true){
line=this.m_In.readLine ();
if(line.length ()>0)
this.m_In.addLine(line);
else
break;
}
return this;
}
/**
* only use to recognize methed "get"
*/
class HttpInputStream extends FilterInputStream {
HttpInputStream(InputStream in){
super(in);
}
public void addLine(String line) {
m_vLines .addElement(line);
}
public String readLine() throws IOException {
StringBuffer result=new StringBuffer ();
boolean finished=false;
boolean isenter=false;
while(!finished){
int ch=-1;
ch=read();
if((isenter)&&(ch==10)){// if it is "/n/r"
result.setLength(result.length()-1);//had added "/n",remove it
return result.toString ();
}
if(ch==13)//if enter pressed
isenter=true;
else
isenter=false;
if(ch==-1)//end
return result.toString ();
else
result.append ((char)ch);
}
return result.toString ();
}
}
}
请多指教
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- 自己如何实现简单的http服务器
- 如何自己实现模板类（简单案例——顺序表）
- mfc学习笔记之如何自己动手实现最简单的mfc程序
- 基于tcp自己实现简单的HTTP服务器
- [转]如何实现按键精灵的简单路点行走
- 自己写的实现数据库事务的简单方法ExecuteSqlTran()
- 自己写一个strcpy（char*dest，char*src），如何在函数内部实现防御性溢出？
- 如何用C#在winform中实现简单的查找功能
- 简单HTTP服务器实现
- 如何才能实现自己的梦想
- 如何实现用单网卡共享上网(超简单)
- 如何简单实现论坛实时在线用户统计
- 如何自己实现IEnumerable和IEnumerator接口以支持foreach语句
- 如何实现一个简单的工作流审批引擎——请看
- 如何在自己网页上实现加入google groups功能
- js正则实现的密码框简单制作,还可以替换成自己想用得符号
- Windows 2000下如何在自己的程序中实现关机!
- 如何实现一个简单的remoteing实例
- 如何简单实现office文档的打开、编辑和上传？
- 如何用自己的方法实现修改盘符