手写服务器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中pdf模版填充表单踩坑实战记录(itextPdf、openPdf、pdfbox)

java中pdf模版填充表单踩坑实战记录(itextPdf、openPdf、pdfbox)

《java中pdf模版填充表单踩坑实战记录(itextPdf、openPdf、pdfbox)》：本文主要介绍java中pdf模版填充表单踩坑的相关资料,OpenPDF、iText、PDFBox是三... 目录准备Pdf模版方法1：itextpdf7填充表单（1）加入依赖（2）代码（3）遇到的问题方法2：pd
阅读更多...
Java Stream流之GroupBy的用法及应用场景

Java Stream流之GroupBy的用法及应用场景

《JavaStream流之GroupBy的用法及应用场景》本教程将详细介绍如何在Java中使用Stream流的groupby方法,包括基本用法和一些常见的实际应用场景,感兴趣的朋友一起看看吧... 目录Java Stream流之GroupBy的用法1. 前言2. 基础概念什么是 GroupBy？Stream
阅读更多...
python运用requests模拟浏览器发送请求过程

python运用requests模拟浏览器发送请求过程

《python运用requests模拟浏览器发送请求过程》模拟浏览器请求可选用requests处理静态内容,selenium应对动态页面,playwright支持高级自动化,设置代理和超时参数,根据需... 目录使用requests库模拟浏览器请求使用selenium自动化浏览器操作使用playwright
阅读更多...
Python极速搭建局域网文件共享服务器完整指南

Python极速搭建局域网文件共享服务器完整指南

《Python极速搭建局域网文件共享服务器完整指南》在办公室或家庭局域网中快速共享文件时,许多人会选择第三方工具或云存储服务,但这些方案往往存在隐私泄露风险或需要复杂配置,下面我们就来看看如何使用Py... 目录一、android基础版：HTTP文件共享的魔法命令1. 一行代码启动HTTP服务器2. 关键参
阅读更多...
SpringBoot监控API请求耗时的6中解决解决方案

SpringBoot监控API请求耗时的6中解决解决方案

《SpringBoot监控API请求耗时的6中解决解决方案》本文介绍SpringBoot中记录API请求耗时的6种方案,包括手动埋点、AOP切面、拦截器、Filter、事件监听、Micrometer+... 目录1. 简介2.实战案例2.1 手动记录2.2 自定义AOP记录2.3 拦截器技术2.4 使用Fi
阅读更多...
最新Spring Security的基于内存用户认证方式

最新Spring Security的基于内存用户认证方式

《最新SpringSecurity的基于内存用户认证方式》本文讲解SpringSecurity内存认证配置,适用于开发、测试等场景,通过代码创建用户及权限管理,支持密码加密,虽简单但不持久化,生产环... 目录1. 前言2. 因何选择内存认证？3. 基础配置实战❶ 创建Spring Security配置文件
阅读更多...
Spring Security 单点登录与自动登录机制的实现原理

Spring Security 单点登录与自动登录机制的实现原理

《SpringSecurity单点登录与自动登录机制的实现原理》本文探讨SpringSecurity实现单点登录（SSO）与自动登录机制,涵盖JWT跨系统认证、RememberMe持久化Token... 目录一、核心概念解析1.1 单点登录（SSO）1.2 自动登录（Remember Me）二、代码分析三、
阅读更多...
springboot自定义注解RateLimiter限流注解技术文档详解

springboot自定义注解RateLimiter限流注解技术文档详解

《springboot自定义注解RateLimiter限流注解技术文档详解》文章介绍了限流技术的概念、作用及实现方式,通过SpringAOP拦截方法、缓存存储计数器,结合注解、枚举、异常类等核心组件,... 目录什么是限流系统架构核心组件详解1. 限流注解 (@RateLimiter)2. 限流类型枚举 (
阅读更多...
Java Thread中join方法使用举例详解

Java Thread中join方法使用举例详解

《JavaThread中join方法使用举例详解》JavaThread中join()方法主要是让调用改方法的thread完成run方法里面的东西后,在执行join()方法后面的代码,这篇文章主要介绍... 目录前言1.join()方法的定义和作用2.join()方法的三个重载版本3.join()方法的工作原
阅读更多...
Spring AI使用tool Calling和MCP的示例详解

Spring AI使用tool Calling和MCP的示例详解

《SpringAI使用toolCalling和MCP的示例详解》SpringAI1.0.0.M6引入ToolCalling与MCP协议,提升AI与工具交互的扩展性与标准化,支持信息检索、行动执行等... 目录深入探索 Spring AI聊天接口示例Function CallingMCPSTDIOSSE结束语
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2