【仿写tomcat】五、响应静态资源（访问html页面）、路由支持以及多线程改进

访问html页面

如果我们想访问html页面其实就是将本地的html文件以流的方式响应给前端即可，下面我们对HttpResponseServlet这个类做一些改造

package com.tomcatServer.domain;import com.tomcatServer.utils.ScanUtil;import java.io.IOException;
import java.io.PrintWriter;
import java.nio.charset.StandardCharsets;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;/*** http servlet响应** @author ez4sterben* @date 2023/08/15*/
public class HttpServletResponse {private final PrintWriter out;private static final String response;private static final String htmlResponse;public HttpServletResponse(PrintWriter out) {this.out = out;}static {response = "HTTP/1.1 200 OK\r\n" +"Content-Type: text/plain\r\n" +"\r\n";htmlResponse = "HTTP/1.1 200 OK\r\n" +"Content-Type: text/html\r\n" +"\r\n";}/*** 写** @param content 内容*/public void write(String content) {out.println(response + content);}/*** 编写html** @param htmlFileName html文件名字* @throws IOException ioexception*/public void writeHtml(String htmlFileName) throws IOException {Path path = Paths.get(ScanUtil.WEB_APP_PATH + "\\" + htmlFileName);byte[] bytes = Files.readAllBytes(path);out.println(htmlResponse + new String(bytes, StandardCharsets.UTF_8));}
}

writeHtml这个方法将会读取webApp下面的html文件，注意只读取下面一级文件中的html文件，然后将这个文件以二进制流的形式转换成字符串拼接到上面定义的html格式的响应头。

处理静态资源请求

当我们有了解析html文件的方法后，下面要做的就是处理静态资源，也就是判断一下请求路径中是否有.html这个字符串，有的话就把这次请求当做静态资源请求处理，没有的话再交给GET或者POST请求。这个逻辑将添加在SocketStore中，下面展示更改玩的SocketStore代码

package com.tomcatServer.socket;import com.tomcatServer.domain.HttpServletRequest;
import com.tomcatServer.domain.HttpServletResponse;
import com.tomcatServer.utils.ScanUtil;
import com.tomcatServer.utils.ServletUtil;import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Map;/*** 套接字存储** @author ez4sterben* @date 2023/08/15*/
public class SocketStore {private static ServerSocket socket;public static void connect(Integer port) throws IOException {socket = new ServerSocket(port);}public static void close() throws IOException {socket.close();}public static ServerSocket getSocket() {return socket;}/*** 处理请求** @throws IOException ioexception*/public static void handleRequest(Socket accept) throws IOException {// 获取输入输出流BufferedReader in = new BufferedReader(new InputStreamReader(accept.getInputStream()));PrintWriter out = new PrintWriter(accept.getOutputStream(), true);// 定义字符串接收Http协议内容String inputLine;StringBuilder requestData = new StringBuilder();// 读取数据while ((inputLine = in.readLine()) != null && !inputLine.isEmpty()) {requestData.append(inputLine).append("\r\n");}// 解析request paramString url = requestData.toString().split(" ")[1];// 处理静态资源if(url.contains(".html")){String staticSourceName = (url.split(".html")[0] + ".html").substring(1);HttpServletResponse response = new HttpServletResponse(out);response.writeHtml(staticSourceName);}else {// 处理GET与POST请求if (!requestData.toString().trim().equals("")){handleGetAndPostReuqest(in, out, String.valueOf(requestData));}}// 关闭资源accept.close();}/*** 处理post请求** @param in          在* @param requestData 请求数据* @throws IOException ioexception*/private static void handleGetAndPostReuqest(BufferedReader in,PrintWriter out, String requestData) throws IOException {// 解析request paramString url = requestData.split(" ")[1];String[] urlContent = url.split("\\?");String requestPath = urlContent[0];String params = urlContent[1];String[] paramsKeyValue = params.split("=");// 设置请求参数HttpServletRequest request = new HttpServletRequest();Map<String, String> paramsMap = request.getParams();for (int i = 0; i < paramsKeyValue.length; i += 2) {paramsMap.put(paramsKeyValue[i],paramsKeyValue[i+1]);}if (requestData.contains("POST")) {// 解析request bodyint contentLength = Integer.parseInt(requestData.split("Content-Length: ")[1].split("\r\n")[0]);StringBuilder requestBody = new StringBuilder();for (int i = 0; i < contentLength; i++) {requestBody.append((char) in.read());}// 设置request bodyrequest.setRequestBody(String.valueOf(requestBody));// 设置响应内容HttpServletResponse response = new HttpServletResponse(out);ServletUtil.invokePost(requestPath,request,response);}if (requestData.contains("GET")){// 设置响应内容HttpServletResponse response = new HttpServletResponse(out);ServletUtil.invokeGet(requestPath,request,response);}}}

访问测试

接下来我们在index.html里面写点东西并访问一下试试
在这里插入图片描述
http://localhost:8080/index.html
在这里插入图片描述

路由支持

其实刚才完成这个功能的时候就会发现，如何访问子目录里面的html呢？
这里其实就要写一个小方法来支持路由重定向了，下面编写一个HttpUtil

package com.tomcatServer.utils;import com.tomcatServer.domain.HttpServletRequest;
import com.tomcatServer.domain.HttpServletResponse;import java.io.IOException;public class HttpUtil {private final String redirectPath;public HttpUtil(String redirectPath) {this.redirectPath = redirectPath;}public void forward(HttpServletRequest request, HttpServletResponse response) throws IOException {response.writeHtml(redirectPath);}
}

对HttpServletRequest做一些改进，提供一个加载静态资源的方法。

    public HttpUtil getStaticSource(String path){return new HttpUtil(path);}

其实这样我们的功能就完成了，写一个servlet以及html来测试一下

package tomcatProject.com.ez4sterben.servlet;import com.tomcatServer.annotation.WebServlet;
import com.tomcatServer.domain.HttpServlet;
import com.tomcatServer.domain.HttpServletRequest;
import com.tomcatServer.domain.HttpServletResponse;import java.io.IOException;@WebServlet("/router")
public class RouterServlet extends HttpServlet {@Overridepublic void doGet(HttpServletRequest request, HttpServletResponse response) throws IOException {request.getStaticSource("WEB-INF/page/"+request.getParam("path")+".html").forward(request, response);}@Overridepublic void doPost(HttpServletRequest request, HttpServletResponse response) throws IOException {doGet(request, response);}
}

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

多线程改进

为什么要在这里谈多线程改进呢，其实是因为我们最近本的接收请求，响应请求，响应页面以及完成了，接下来要考虑的就是如何支持并发处理请求，如何配置并发数，如何配置端口等优化问题。

如果想实现并发处理请求的话，实际上只需要预先定义一个线程池即可，把处理请求的方法交给一个任务类并且实现Runnable接口，当然我们后面会再优化这种方案。

package com.tomcatServer.task;import com.tomcatServer.socket.SocketStore;import java.io.IOException;
import java.net.Socket;public class RequestTask implements Runnable{private final Socket accept;public RequestTask(Socket accept) {this.accept = accept;}@Overridepublic void run() {try {SocketStore.handleRequest(accept);} catch (IOException e) {throw new RuntimeException(e);}}
}
        ...public static ExecutorService threadPool;...// 5.初始化线程池threadPool = Executors.newFixedThreadPool(10);// 6.处理http请求try {SocketStore.connect(PORT);while (true){Socket accept = SocketStore.getSocket().accept();if (accept != null){threadPool.submit(new RequestTask(accept));}}} catch (IOException e) {throw new RuntimeException(e);}finally {SocketStore.close();}

【仿写tomcat】六、解析xml文件配置端口、线程池核心参数

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/76754.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

马哈鱼数据血缘工具背后的项目: gsp_demo_java 项目简单介绍与使用

马哈鱼数据血缘工具背后的项目: gsp_demo_java 项目简单介绍与使用

0.背景 马哈鱼数据血缘工具(https://www.sqlflow.cn/)是SQLflow工具的中文译名,实际就是sqlflow. 对于SQL flow来说,底层调用的是General SQL Parser(GSP https://sqlparser.com) 的库. 这个gsp有开源的java demo项目:https://github.com/sqlparser/gsp_demo_java 1.快速使用…
阅读更多...
4G电力摄像机如何通过AT指令对接到国网平台呢？

4G电力摄像机如何通过AT指令对接到国网平台呢？

对于针对电网安全运行的迫切需求&#xff0c;”输电线路智能可视化监测系统”被研发并应用&#xff0c;通过视频监控和AI智能分析技术&#xff0c;实现了对输电线路远程视频在线监测、外力破坏智能分析&#xff0c;可实现对输电线路的全天候实时监测和预警&#xff0c;有效保障…
阅读更多...
阿里云ECS服务器企业级和共享型介绍_企业级常见问题解答FAQ

阿里云ECS服务器企业级和共享型介绍_企业级常见问题解答FAQ

阿里云企业级服务器是什么&#xff1f;企业级和共享型有什么区别&#xff1f;企业级服务器具有独享且稳定的计算、存储、网络资源&#xff0c;如ECS计算型c6、通用型g8等都是企业级实例&#xff0c;阿里云百科分享什么是企业级云服务器、企业级实例的优势、企业级和共享型云服务…
阅读更多...
vue3跳转页面后 海康监控实例不销毁

vue3跳转页面后 海康监控实例不销毁

第一个页面是这样的 跳转到新的页面 只有海康的监控没有消失 使用控制台审查元素也审查不到 解决方法&#xff1a;在vue3的销毁周期把海康的监控销毁掉 import { reactive, onDeactivated} from "vue"; const state reactive({oWebControl: null as any, //监控绑…
阅读更多...
kafka晋升之路-理论+场景

kafka晋升之路-理论+场景

kafka晋升之路 一&#xff1a;故事背景二&#xff1a;核心概念2.1 系统架构2.2 生产者&#xff08;Producer&#xff09;2.2.1 生产者分区2.2.2 生产者分区策略 2.3 经纪人&#xff08;Broker&#xff09;2.3.1 主题&#xff08;Topic&#xff09;2.3.2 分区&#xff08;Partit…
阅读更多...
攻防世界-warmup

攻防世界-warmup

原题解题思路 只有一张图片&#xff0c;就查看源代码&#xff0c;有一个source.php。 查看source.php&#xff0c;白名单中还有一个hint.php。 hint.php告诉我们flag的位置ffffllllaaaagggg 但是直接跳转是没用的&#xff0c;构造payload。 http://61.147.171.105:55725/sourc…
阅读更多...
linux部署kafka3.5.1(单机)

linux部署kafka3.5.1(单机)

一、下载jdk17 kafka3.x版本需要jdk11以上版本才能更好的兼容&#xff0c;jdk11、jdk17都是LTS长期维护版本&#xff0c;而且jdk17支持springboot3.x,所以我选择了openjdk17。 下载地址: Archived OpenJDK GA Releaseshttps://jdk.java.net/archive/ 二、上传jdk安装包解压 …
阅读更多...
Netty为什么高效，为什么这么受欢迎？

Netty为什么高效，为什么这么受欢迎？

文章目录 前言Netty 解决的问题简化网络编程粘包和拆包 高性能的设计多线程调度零拷贝 总结 前言 上篇文章通过 Java NIO 的处理流程与 Netty 的总体流程比较&#xff0c;并结合 Netty 的源码&#xff0c;可以更加清晰地理解Netty。本文将结合源码详细解析Netty的高效和强大功…
阅读更多...
spring源码分析bean的生命周期（下）

spring源码分析bean的生命周期（下）

doGetBean()执行过程 createBean()执行过程 一、DependsOn注解 spring创建对象之前会判断类上是否加了DependsOn注解&#xff0c;加了会遍历然后会添加到一个map中&#xff0c;spring会先创建DependsOn注解指定的类 二、spring类加载器 在合并BeanDefinition&#xff0c;确定…
阅读更多...
【校招VIP】java语言类和对象之map、set集合

【校招VIP】java语言类和对象之map、set集合

考点介绍&#xff1a; map、set集合相关内容是校招面试的高频考点之一。 map和set是一种专门用来进行搜索的容器或者数据结构&#xff0c;其搜索效率与其具体的实例化子类有关系。 『java语言类和对象之map、set集合』相关题目及解析内容可点击文章末尾链接查看&#xff01; …
阅读更多...
网络通信原理传输层TCP三次建立连接（第四十八课）

网络通信原理传输层TCP三次建立连接（第四十八课）

ACK :确认号 。 是期望收到对方的下一个报文段的数据的第1个字节的序号，即上次已成功接收到的数据字节序号加1。只有ACK标识为1，此字段有效。确认号X+1SEQ：序号字段。 TCP链接中传输的数据流中每个字节都编上一个序号。序号字段的值指的是本报文段所发送的数据的第一个字节的…
阅读更多...
20W IP网络吸顶喇叭 POE供电吸顶喇叭

20W IP网络吸顶喇叭 POE供电吸顶喇叭

SV-29852T 20W IP网络吸顶喇叭产品简介 产品用途&#xff1a; ◆室内豪华型吸顶喇叭一体化网络音频解码扬声器&#xff0c;用于广播分区音频解码、声音还原作用 ◆应用场地如火车站、地铁、教堂、工厂、仓库、公园停车场等&#xff1b;室内使用效果均佳。 产品特点&#xff…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023