手写服务器httpserver_封装分发器_多请求处理_多态_反射JAVA202-204

2024-09-03 14:38
文章标签 java 封装 服务器 请求 处理 反射 多态 手写 httpserver 分发 202 204

本文主要是介绍手写服务器httpserver_封装分发器_多请求处理_多态_反射JAVA202-204，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

来源：http://www.bjsxt.com/
一、S02E202_01手写服务器httpserver_封装分发器

<html><head><title>第一个表单</title></head><body><pre>method：请求方式 get/postget：默认方式，数据量小，安全性不高post：量大，安全性相对高action：请求的服务器路径id：编号，前端（用户的浏览器）区分唯一性，js中使用name：名称，后端（服务器）区分唯一性，获取值只要提交数据给后台，必须存在name</pre><form method="post" action="http://localhost:8888/index.html">用户名：<input type="text" name="uname" id="name"/>密码：<input type="password" name="pwd" id="pass"/>兴趣：<input type="checkbox" name="fav" value="0"/>篮球<input type="checkbox" name="fav" value="1"/>足球<input type="checkbox" name="fav" value="2"/>乒乓球<input type="submit" value="登录"></form></body>
</html>
package com.test.server;public class Servlet {public void service(Request req,Response rep){rep.println("<html><head><title>HTTP响应示例</title>");rep.println("</head><body>");rep.println("欢迎：").println(req.getParameterValue("uname")).println("回来");rep.println("</body></html>");}
}
package com.test.server;import java.io.IOException;
import java.net.Socket;
/*** 一个请求与响应，就一个对象*/
public class Dispatcher implements Runnable{private Socket client;private Request req;private Response rep;private int code = 200;Dispatcher(Socket client){this.client = client;try {req = new Request(client.getInputStream());rep = new Response(client.getOutputStream());} catch (IOException e) {//e.printStackTrace();code = 500;try {rep.pushToClient(code);} catch (IOException e1) {//e1.printStackTrace();}return;}}@Overridepublic void run() {Servlet serv = new Servlet();serv.service(req, rep);try {rep.pushToClient(code);//推送到客户端} catch (IOException e) {//e.printStackTrace();try {rep.pushToClient(500);} catch (IOException e1) {e1.printStackTrace();}}try {client.close();} catch (IOException e) {e.printStackTrace();}}
}
package com.test.server;import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
/*** 创建服务器，并启动* 1、请求* 2、响应*/
public class ServerForResAndReq2 {private ServerSocket server;private boolean isShutDown = false;public static void main(String[] args) {ServerForResAndReq2 server = new ServerForResAndReq2();server.start();}/*** 启动方法*/public void start(){        start(8888);}/*** 指定端口的启动方法*/public void start(int port){        try {server = new ServerSocket(port);this.receive();} catch (IOException e) {//e.printStackTrace();stop();}}/*** 接收客户端*/private void receive(){try {//请求及响应while(!isShutDown){new Thread(new Dispatcher(server.accept())).start();}} catch (IOException e) {//e.printStackTrace();stop();}}/*** 停止服务器*/public void stop(){isShutDown = true;try {server.close();} catch (IOException e) {e.printStackTrace();}}
}

二、S02E203_01手写服务器httpserver_多请求处理_多态

package com.test.server2;import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
/*** 创建服务器，并启动* 1、请求* 2、响应*/
public class Server {private ServerSocket server;private boolean isShutDown = false;public static void main(String[] args) {Server server = new Server();server.start();}/*** 启动方法*/public void start(){        start(8888);}/*** 指定端口的启动方法*/public void start(int port){        try {server = new ServerSocket(port);this.receive();} catch (IOException e) {//e.printStackTrace();stop();}}/*** 接收客户端*/private void receive(){try {//请求及响应while(!isShutDown){new Thread(new Dispatcher(server.accept())).start();}} catch (IOException e) {//e.printStackTrace();stop();}}/*** 停止服务器*/public void stop(){isShutDown = true;try {if(!(null==server)){server.close();}} catch (IOException e) {//e.printStackTrace();}}
}
package com.test.server2;import java.io.IOException;
import java.net.Socket;
/*** 一个请求与响应，就一个对象*/
public class Dispatcher implements Runnable{private Socket client;private Request req;private Response rep;private int code = 200;Dispatcher(Socket client){this.client = client;try {req = new Request(client.getInputStream());rep = new Response(client.getOutputStream());} catch (IOException e) {//e.printStackTrace();code = 500;try {rep.pushToClient(code);} catch (IOException e1) {//e1.printStackTrace();}return;}}@Overridepublic void run() {try {Servlet serv = WebApp.getServlet(req.getUrl());if(null==serv){this.code = 404;//找不到处理}else{serv.service(req, rep);}rep.pushToClient(code);//推送到客户端} catch (Exception e) {//e.printStackTrace();this.code = 500;try {rep.pushToClient(code);} catch (IOException e1) {e1.printStackTrace();}}try {client.close();} catch (IOException e) {//e.printStackTrace();}}
}
package com.test.server2;import java.io.IOException;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.StringTokenizer;
/*** 封装request*/
public class Request {//请求方式private String method;//请求资源private String url;//请求参数private Map<String,List<String>> parameterMapValues;//内部public static final String CRLF = "\r\n";private InputStream is;private String requestInfo;public Request(){method = "";url = "";parameterMapValues = new HashMap<String,List<String>>();requestInfo = "";}public Request(InputStream is){this();this.is = is;try {byte[] data = new byte[204800];int len = is.read(data);requestInfo = new String(data,0,len);} catch (IOException e) {return;}//分析请求信息parseRequestInfo();}public String getUrl() {return url;}public void setUrl(String url) {this.url = url;}/*** 分析请求信息*/private void parseRequestInfo(){if((null==requestInfo) || (requestInfo=requestInfo.trim()).equals("")){return;}/*** ====================================* 从信息的首行分解出：请求方式  请求路径  请求参数（get可能存在）*   如：GET /index.html?uname=intputUname&pwd=inputPassword HTTP/1.1* * 如果为post方式，请求参数可能在最后正文中* ====================================*/String paramString = "";//接收请求参数int positionCRLF = 0;positionCRLF = requestInfo.indexOf(CRLF);if (positionCRLF == -1){return;}//1、获取请求方式String firstLine = requestInfo.substring(0,requestInfo.indexOf(CRLF));int idx = requestInfo.indexOf("/");// /的位置this.method = firstLine.substring(0,idx).trim();String urlStr = firstLine.substring(idx,firstLine.indexOf("HTTP/")).trim();if(this.method.equalsIgnoreCase("post")){//post方式this.url = urlStr;paramString = requestInfo.substring(requestInfo.lastIndexOf(CRLF)).trim();}else if(this.method.equalsIgnoreCase("get")){//get方式if(urlStr.contains("?")){String[] urlArray = urlStr.split("\\?");this.url = urlArray[0];paramString = urlArray[1];//接收请求参数}else{this.url = urlStr;}}//2、将请求参数封装到Map中parseParams(paramString);}/*** 将请求参数封装到Map中* @param paramString*/private void parseParams(String paramString){//分割，将字符串转成数组StringTokenizer token = new StringTokenizer(paramString,"&");while(token.hasMoreTokens()){String keyValue = token.nextToken();String[] keyValues = keyValue.split("=");if(keyValues.length == 1){keyValues = Arrays.copyOf(keyValues, 2);keyValues[1] = null;}String key = keyValues[0].trim();String value = null==keyValues[1]?null:decode(keyValues[1].trim(),"gbk");//分拣，转换成Mapif(!parameterMapValues.containsKey(key)){parameterMapValues.put(key, new ArrayList<String>());}List<String> values = parameterMapValues.get(key);values.add(value);}}/*** 解决中文* @param value* @param code* @return*/private String decode(String value,String code){try {return java.net.URLDecoder.decode(value, code);} catch (UnsupportedEncodingException e) {//e.printStackTrace();}return null;}/*** 根据页面的name获取对应的多个值*/public String[] getParameterValues(String name){List<String> values = null;if( (values=parameterMapValues.get(name))==null ){return null;}else{return values.toArray(new String[0]);}}/*** 根据页面的name获取对应的单个值*/public String getParameterValue(String name){String[] values = getParameterValues(name);if(null==values){return null;}return values[0];}
}
package com.test.server2;import java.io.BufferedWriter;
import java.io.IOException;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.Date;
/*** 封装响应信息*/
public class Response {//两个常量public static final String CRLF = "\r\n";public static final String BLANK = " ";//流private BufferedWriter bw;//正文private StringBuilder content;//存储头信息private StringBuilder headInfo;//存储正文长度private int len = 0;public Response(){headInfo = new StringBuilder();content = new StringBuilder();len = 0;}public Response(OutputStream os){this();bw = new BufferedWriter(new OutputStreamWriter(os));}public Response(Socket client){this();try {bw = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));} catch (IOException e) {headInfo = null;}}/*** 构建正文*/public Response print(String info){content.append(info);len += (info + CRLF).getBytes().length;return this;}/*** 构建正文+回车*/public Response println(String info){content.append(info).append(CRLF);len += (info + CRLF).getBytes().length;return this;}/*** 构建响应头*/private void createHeadInfo(int code){//1)HTTP协议版本、状态代码、描述headInfo.append("HTTP/1.1").append(BLANK).append(code).append(BLANK);switch(code){case 200:headInfo.append("OK");break;case 404:headInfo.append("NOT FOUND");break;case 500:headInfo.append("Server Error");break;}headInfo.append(CRLF);//2)响应头（Response Head）headInfo.append("Server:test Server/0.0.1").append(CRLF);headInfo.append("Date:").append(new Date()).append(CRLF);headInfo.append("Content-type:text/html;charset=GBK").append(CRLF);//正文长度：字节长度headInfo.append("Content-Length:").append(len).append(CRLF);headInfo.append(CRLF);}/*** 推送到客户端* @throws IOException */void pushToClient(int code) throws IOException{if(null==headInfo){code = 500;}createHeadInfo(code);//头信息+分割符bw.append(headInfo.toString());//正文bw.append(content.toString());bw.flush();bw.close();}
}
package com.test.server2;import java.util.Map;public class WebApp {private static ServletContext contxt;static{contxt = new ServletContext();Map<String,String> mapping = contxt.getMapping();mapping.put("/login", "login");mapping.put("/log", "login");mapping.put("/reg", "register");Map<String,Servlet> servlet = contxt.getServlet();servlet.put("login", new LoginServlet());servlet.put("register", new RegisterServlet());     }public static Servlet getServlet(String url){if(null==url || (url=url.trim()).equals("")){return null;}return contxt.getServlet().get(contxt.getMapping().get(url));}
}
package com.test.server2;
/*** 抽象为一个父类*/
public abstract class Servlet {public void service(Request req,Response rep) throws Exception{this.doGet(req,rep);this.doPost(req,rep);}public abstract void doGet(Request req,Response rep) throws Exception;public abstract void doPost(Request req,Response rep) throws Exception;
}
package com.test.server2;import java.util.HashMap;
import java.util.Map;
/*** 上下文*/
public class ServletContext {//为每一个servlet取别名// login-->LoginServletprivate Map<String,Servlet> servlet;// url-->login//  /log-->login//  /login-->loginprivate Map<String,String> mapping;public ServletContext() { servlet = new HashMap<String,Servlet>();mapping = new HashMap<String,String>();}public Map<String, Servlet> getServlet() {return servlet;}public void setServlet(Map<String, Servlet> servlet) {this.servlet = servlet;}public Map<String, String> getMapping() {return mapping;}public void setMapping(Map<String, String> mapping) {this.mapping = mapping;}
}
package com.test.server2;public class LoginServlet extends Servlet{@Overridepublic void doGet(Request req,Response rep) throws Exception {String name = req.getParameterValue("uname");String pwd = req.getParameterValue("pwd");if(login(name, pwd)){rep.println("登录成功");}else{rep.println("登录失败");}}public boolean login(String name,String pwd){return name.equals("test") && pwd.equals("12346");}@Overridepublic void doPost(Request req,Response rep) throws Exception {}
}
package com.test.server2;public class RegisterServlet extends Servlet{@Overridepublic void doGet(Request req, Response rep) throws Exception {}@Overridepublic void doPost(Request req, Response rep) throws Exception {rep.println("<html><head><title>返回注册</title>");rep.println("</head><body>");rep.println("你的用户名为：" + req.getParameterValue("uname"));rep.println("</body></html>");}
}

三、S02E204_01手写服务器httpserver_多请求处理_反射
反射

**以下代码关键性修改：**
Map<String,Servlet>改为Map<String,String>
package com.test.server2;import java.util.HashMap;
import java.util.Map;
/*** 上下文*/
public class ServletContext {//为每一个servlet取别名// login-->com.test.server2.LoginServletprivate Map<String,String> servlet;// url-->login//  /log-->login//  /login-->loginprivate Map<String,String> mapping;public ServletContext() { servlet = new HashMap<String,String>();mapping = new HashMap<String,String>();}public Map<String, String> getServlet() {return servlet;}public void setServlet(Map<String, String> servlet) {this.servlet = servlet;}public Map<String, String> getMapping() {return mapping;}public void setMapping(Map<String, String> mapping) {this.mapping = mapping;}
}
**以下代码关键性修改：**
//return contxt.getServlet().get(contxt.getMapping().get(url));
//根据字符串（完整路径）创建对象
String name = contxt.getServlet().get(contxt.getMapping().get(url));
return (Servlet)Class.forName(name).newInstance();//确保空构造存在
package com.test.server2;import java.util.Map;public class WebApp {private static ServletContext contxt;static{contxt = new ServletContext();Map<String,String> mapping = contxt.getMapping();mapping.put("/login", "login");mapping.put("/log", "login");mapping.put("/reg", "register");Map<String,String> servlet = contxt.getServlet();servlet.put("login", "com.test.server2.LoginServlet");servlet.put("register", "com.test.server2.RegisterServlet");        }public static Servlet getServlet(String url) throws InstantiationException, IllegalAccessException, ClassNotFoundException{if(null==url || (url=url.trim()).equals("")){return null;}//return contxt.getServlet().get(contxt.getMapping().get(url));//根据字符串（完整路径）创建对象String name = contxt.getServlet().get(contxt.getMapping().get(url));return (Servlet)Class.forName(name).newInstance();//确保空构造存在}
}

这篇关于手写服务器httpserver_封装分发器_多请求处理_多态_反射JAVA202-204的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1133240。

相关文章

Java实现字节字符转bcd编码

Java实现字节字符转bcd编码

《Java实现字节字符转bcd编码》BCD是一种将十进制数字编码为二进制的表示方式,常用于数字显示和存储,本文将介绍如何在Java中实现字节字符转BCD码的过程,需要的小伙伴可以了解下... 目录前言BCD码是什么Java实现字节转bcd编码方法补充总结前言BCD码（Binary-Coded Decima
阅读更多...
SpringBoot全局域名替换的实现

SpringBoot全局域名替换的实现

《SpringBoot全局域名替换的实现》本文主要介绍了SpringBoot全局域名替换的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一... 目录 项目结构⚙️ 配置文件application.yml️ 配置类AppProperties.Ja
阅读更多...
Java使用Javassist动态生成HelloWorld类

Java使用Javassist动态生成HelloWorld类

《Java使用Javassist动态生成HelloWorld类》Javassist是一个非常强大的字节码操作和定义库,它允许开发者在运行时创建新的类或者修改现有的类,本文将简单介绍如何使用Javass... 目录1. Javassist简介2. 环境准备3. 动态生成HelloWorld类3.1 创建CtC
阅读更多...
JavaScript中的高级调试方法全攻略指南

JavaScript中的高级调试方法全攻略指南

《JavaScript中的高级调试方法全攻略指南》什么是高级JavaScript调试技巧,它比console.log有何优势,如何使用断点调试定位问题,通过本文,我们将深入解答这些问题,带您从理论到实... 目录观点与案例结合观点1观点2观点3观点4观点5高级调试技巧详解实战案例断点调试：定位变量错误性能分
阅读更多...
Python实现批量CSV转Excel的高性能处理方案

Python实现批量CSV转Excel的高性能处理方案

《Python实现批量CSV转Excel的高性能处理方案》在日常办公中,我们经常需要将CSV格式的数据转换为Excel文件,本文将介绍一个基于Python的高性能解决方案,感兴趣的小伙伴可以跟随小编一... 目录一、场景需求二、技术方案三、核心代码四、批量处理方案五、性能优化六、使用示例完整代码七、小结一、
阅读更多...
Python中 try / except / else / finally 异常处理方法详解

Python中 try / except / else / finally 异常处理方法详解

《Python中try/except/else/finally异常处理方法详解》：本文主要介绍Python中try/except/else/finally异常处理方法的相关资料,涵... 目录1. 基本结构2. 各部分的作用tryexceptelsefinally3. 执行流程总结4. 常见用法（1）多个e
阅读更多...
Java实现将HTML文件与字符串转换为图片

Java实现将HTML文件与字符串转换为图片

《Java实现将HTML文件与字符串转换为图片》在Java开发中,我们经常会遇到将HTML内容转换为图片的需求,本文小编就来和大家详细讲讲如何使用FreeSpire.DocforJava库来实现这一功... 目录前言核心实现：html 转图片完整代码场景 1：转换本地 HTML 文件为图片场景 2：转换 H
阅读更多...
Java使用jar命令配置服务器端口的完整指南

Java使用jar命令配置服务器端口的完整指南

《Java使用jar命令配置服务器端口的完整指南》本文将详细介绍如何使用java-jar命令启动应用,并重点讲解如何配置服务器端口,同时提供一个实用的Web工具来简化这一过程,希望对大家有所帮助... 目录1. Java Jar文件简介1.1 什么是Jar文件1.2 创建可执行Jar文件2. 使用java
阅读更多...
PHP应用中处理限流和API节流的最佳实践

PHP应用中处理限流和API节流的最佳实践

《PHP应用中处理限流和API节流的最佳实践》限流和API节流对于确保Web应用程序的可靠性、安全性和可扩展性至关重要,本文将详细介绍PHP应用中处理限流和API节流的最佳实践,下面就来和小编一起学习... 目录限流的重要性在 php 中实施限流的最佳实践使用集中式存储进行状态管理（如 Redis）采用滑动
阅读更多...
SpringBoot实现不同接口指定上传文件大小的具体步骤

SpringBoot实现不同接口指定上传文件大小的具体步骤

《SpringBoot实现不同接口指定上传文件大小的具体步骤》：本文主要介绍在SpringBoot中通过自定义注解、AOP拦截和配置文件实现不同接口上传文件大小限制的方法,强调需设置全局阈值远大于... 目录一  springboot实现不同接口指定文件大小1.1 思路说明1.2 工程启动说明二 具体实施2
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2