博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
java模拟http_java模拟http服务器
阅读量:6470 次
发布时间:2019-06-23

本文共 2981 字,大约阅读时间需要 9 分钟。

最近用java简单实现了http服务器。主要是使用socket在端口监听浏览器的http请求,根据请求信息在服务器端进行路由(读取html页面),然后封装成http格式的响应返回到浏览器。代码如下:

c671c6b9039213730ed75cfb4eca5d27.png

项目大概这样。

HttpServer:

package server;

import java.io.*;

import java.net.*;

import router.SocketHandler;

/**

* http服务器启动类

* @author Administrator

*

*/

public class HttpServer {

static ServerSocket server = null ;

static Socket socket ;

static int PORT = 8888 ;

static String IP = "127.0.0.1";

public static void waiting(){

try {

server = new ServerSocket(PORT , 1,  InetAddress.getByName(IP));

System.out.println("server waiting on " + PORT + " .....");

while(true){

socket = server.accept();

SocketHandler.handle(socket);

}

}catch (IOException e) {

e.printStackTrace();

}

}

public static void main(String[] args) {

waiting();

}

}

socketHandler类:处理链接的socket。

package router;

import java.io.*;

import java.net.*;

/**

* 解析socket

* @author Administrator

*

*/

public class SocketHandler {

static Socket socket ;

static BufferedReader reader = null;

static PrintWriter out = null ;

static String requestUri = null ;

public static void handle(Socket socket){

SocketHandler.socket = socket ;

resoveRequest();

sendResponse();

close();

}

static void close(){

if( out != null)

out.close();

try {

if( reader != null)

reader.close();

if( socket != null)

socket.close();

} catch (IOException e) {

e.printStackTrace();

}

}

/**

* 解析request

*/

public static void resoveRequest(){

try {

reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));

String item = reader.readLine() ;

if( item != null ){

requestUri = item.split(" ")[1];

}

} catch (IOException e) {

e.printStackTrace();

}

}

/**

* 返回response数据

* @param out

*/

public static void sendResponse(){

String html = Router.getPageContent(requestUri);

try {

StringBuffer sb = new StringBuffer();

out = new PrintWriter(socket.getOutputStream());

/**

* response header

*///

//封装http响应

sb.append("HTTP/1.1 200\r\n");

sb.append("Server: EvergreenServer\r\n");

sb.append("Date: Mon, 3 April 2015 13:13:33 GMT\r\n");

sb.append("Content-type:text/html;\r\n");

sb.append("Content-Length: "  + html.length() + "\r\n");

sb.append("\r\n");

/**

* content

*/

sb.append(html);

out.println(sb.toString());

out.flush();

out.close();

} catch (IOException e) {

e.printStackTrace();

}

}

}

Router类:(主要实现对请求url的解析。将html内容返回给响应头。)

package router;

import java.io.*;

/**

* 路由类

* @author Administrator

*

*/

public class Router {

public static String getPageContent(String uri){

File file = new File("web-root" + (uri.lastIndexOf("?") != -1 ? (uri.substring(0, uri.lastIndexOf("?"))) : uri ));

StringBuffer sb = new StringBuffer();

if( file.exists() == false){

sb.append("

404  

Page Not Found

");

}else{

BufferedReader bur = null ;

try {

bur = new BufferedReader(new InputStreamReader(new FileInputStream(file)));

String str = null;

while( (str = bur.readLine()) != null)

sb.append(str);

} catch (Exception e) {

}finally{

if( bur != null)

try {

bur.close();

} catch (IOException e) {

}

}

}

return  sb.toString() ;

}

public static void main(String[] args) {

}

}

facf4baf072115b570948dbd6e26875f.png

转载地址:http://apdko.baihongyu.com/

你可能感兴趣的文章
[转]使用Visual Studio Code开发Asp.Net Core WebApi学习笔记(三)-- Logger
查看>>
POJ 3311 Hie with the Pie(状压DP + Floyd)
查看>>
HDU 1402 A * B Problem Plus FFT
查看>>
[CareerCup] 17.3 Factorial Trailing Zeros 求阶乘末尾零的个数
查看>>
Security updates and resources
查看>>
深入理解JavaScript系列(25):设计模式之单例模式
查看>>
DNS为什么通常都会设置为14.114.114.114
查看>>
给定一个序列,判断该序列是否为二叉树查找树的后序遍历序列
查看>>
Sqoop架构(四)
查看>>
golang copy函数
查看>>
《你有多少问题要请示》精华集粹
查看>>
深度 | 机器学习敲门砖:任何人都能看懂的TensorFlow介绍【转】
查看>>
leveldb学习:DBimpl
查看>>
MySQL存储引擎--MYSIAM和INNODB引擎区别
查看>>
[Recompose] Stream Props to React Children with RxJS
查看>>
打印图片
查看>>
SHOW CREATE DATABASE Syntax
查看>>
rsync常见问题及解决办法
查看>>
AKM项目轶事之GBS同事转入GDC
查看>>
MySQL日期 专题
查看>>