java使用socket实现一个多线程web服务器的方法
程序员文章站
2024-03-06 17:30:50
除了服务器类,还包括请求类和响应类
请求类:获取客户的http请求,分析客户所需要的文件
响应类:获得用户请求后将用户需要的文件读出,添加上http应答头。发送给客户端...
除了服务器类,还包括请求类和响应类
请求类:获取客户的http请求,分析客户所需要的文件
响应类:获得用户请求后将用户需要的文件读出,添加上http应答头。发送给客户端。
服务器处理类
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; } }
以上这篇java使用socket实现一个多线程web服务器的方法就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。
上一篇: ASP.NET性能优化之局部缓存分析
推荐阅读
-
java使用socket实现一个多线程web服务器的方法
-
java使用socket实现一个多线程web服务器的方法
-
Java基于Socket实现简单的多线程回显服务器功能示例
-
Java基于Socket实现简单的多线程回显服务器功能示例
-
java实现一个简单的Web服务器实例解析
-
php使用socket post数据到其它web服务器的方法
-
php使用socket post数据到其它web服务器的方法
-
Java开发之使用websocket实现web客户端与服务器之间的实时通讯
-
用java实现的一个简单的web服务器
-
php使用socket post数据到其它web服务器的方法,socketpost