手写服务器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对异常的认识与异常的处理小结

Java对异常的认识与异常的处理小结

《Java对异常的认识与异常的处理小结》Java程序在运行时可能出现的错误或非正常情况称为异常,下面给大家介绍Java对异常的认识与异常的处理,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参... 目录一、认识异常与异常类型。二、异常的处理三、总结 一、认识异常与异常类型。（1）简单定义-什么是
阅读更多...
SpringBoot项目配置logback-spring.xml屏蔽特定路径的日志

SpringBoot项目配置logback-spring.xml屏蔽特定路径的日志

《SpringBoot项目配置logback-spring.xml屏蔽特定路径的日志》在SpringBoot项目中,使用logback-spring.xml配置屏蔽特定路径的日志有两种常用方式,文中的... 目录方案一：基础配置（直接关闭目标路径日志）方案二：结合 Spring Profile 按环境屏蔽关
阅读更多...
Java使用HttpClient实现图片下载与本地保存功能

Java使用HttpClient实现图片下载与本地保存功能

《Java使用HttpClient实现图片下载与本地保存功能》在当今数字化时代,网络资源的获取与处理已成为软件开发中的常见需求,其中,图片作为网络上最常见的资源之一,其下载与保存功能在许多应用场景中都... 目录引言一、Apache HttpClient简介二、技术栈与环境准备三、实现图片下载与保存功能1.
阅读更多...
SpringBoot排查和解决JSON解析错误(400 Bad Request)的方法

SpringBoot排查和解决JSON解析错误(400 Bad Request)的方法

《SpringBoot排查和解决JSON解析错误(400BadRequest)的方法》在开发SpringBootRESTfulAPI时,客户端与服务端的数据交互通常使用JSON格式,然而,JSON... 目录问题背景1. 问题描述2. 错误分析解决方案1. 手动重新输入jsON2. 使用工具清理JSON3.
阅读更多...
java中long的一些常见用法

java中long的一些常见用法

《java中long的一些常见用法》在Java中,long是一种基本数据类型,用于表示长整型数值,接下来通过本文给大家介绍java中long的一些常见用法,感兴趣的朋友一起看看吧... 在Java中，long是一种基本数据类型，用于表示长整型数值。它的取值范围比int更大，从-922337203685477
阅读更多...
java Long 与long之间的转换流程

java Long 与long之间的转换流程

《javaLong与long之间的转换流程》Long类提供了一些方法,用于在long和其他数据类型（如String）之间进行转换,本文将详细介绍如何在Java中实现Long和long之间的转换,感... 目录概述流程步骤1：将long转换为Long对象步骤2：将Longhttp://www.cppcns.c
阅读更多...
SpringBoot集成LiteFlow实现轻量级工作流引擎的详细过程

SpringBoot集成LiteFlow实现轻量级工作流引擎的详细过程

《SpringBoot集成LiteFlow实现轻量级工作流引擎的详细过程》LiteFlow是一款专注于逻辑驱动流程编排的轻量级框架,它以组件化方式快速构建和执行业务流程,有效解耦复杂业务逻辑,下面给大... 目录一、基础概念1.1 组件（Component）1.2 规则（Rule）1.3 上下文（Conte
阅读更多...
SpringBoot服务获取Pod当前IP的两种方案

SpringBoot服务获取Pod当前IP的两种方案

《SpringBoot服务获取Pod当前IP的两种方案》在Kubernetes集群中,SpringBoot服务获取Pod当前IP的方案主要有两种,通过环境变量注入或通过Java代码动态获取网络接口IP... 目录方案一：通过 Kubernetes Downward API 注入环境变量原理步骤方案二：通过
阅读更多...
Springboot整合Redis主从实践

Springboot整合Redis主从实践

《Springboot整合Redis主从实践》：本文主要介绍Springboot整合Redis主从的实例,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录前言原配置现配置测试LettuceConnectionFactory.setShareNativeConnect
阅读更多...
Java中Map.Entry()含义及方法使用代码

Java中Map.Entry()含义及方法使用代码

《Java中Map.Entry()含义及方法使用代码》：本文主要介绍Java中Map.Entry()含义及方法使用的相关资料,Map.Entry是Java中Map的静态内部接口,用于表示键值对,其... 目录前言 Map.Entry作用核心方法常见使用场景1. 遍历 Map 的所有键值对2. 直接修改 Ma
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2