如何仿写简易tomcat 实现思路+代码详细讲解
仿写之前,我们要搞清楚都要用到哪些技术
- 自定义注解,比如Tomcat使用的是@Servlet,我们可以定义一个自己的@MyServlet
- 构造请求体和返回体,比如tomcat使用HttpRequest,我们可以自己定义myHttpRequest
- java去遍历一个指定目录,然后获取到.java文件,再获取到带有@MyServlet注解的类
- 然后将这个注解里的path和这个类本身映射成map
- 通过反射去调用该类的方法(doGet、doPost)
- 还需要用到socket来监听消息,并且对监听到的消息进行处理
第一步:自定义注解
@Target(ElementType.TYPE)
@Documented
@Retention(RetentionPolicy.RUNTIME)
public @interface MyServlet {String path() default "";
}
第二步:定义HttpRequest以及HttpResponse、
public class MyHttpRequest {//定义一个map,用来存放请求体中的参数,key是参数名称,value是参数值public Map<String,String> map = new HashMap<>();public String getParameter(String key){return map.get(key);}
}
public class MyHttpResponse {public OutputStream outputStream;public static final String responsebody = "HTTP/1.1 200+\r\n" + "Content-Type:text/html+\r\n"+ "\r\n";public MyHttpResponse(OutputStream outputStream) {this.outputStream = outputStream;}
}
第三步:遍历整个目录,把Java文件放入list中
private static void func(File file){File[] files = file.listFiles();String s;for (File file1 : files) {if (file1.isDirectory()){func(file1);}if (file1.isFile()){//取src之后的名字s = file1.toString().split("src")[1];//去掉src后边的第一个\,得到全类名s = s.substring(1);//判断是不是以.java结尾的文件if (s.length() >=5 && s.substring(s.length() - 5).equals(".java")){//把全类名中的\替换成.s = s.replace('\\','.');//去掉后缀名.javas = s.substring(0,s.length()-5);//把类名加入到list中javaclasses.add(s);}}}}
第四步:找出带有Servlet注解的Java文件,并把注解中的path,类对象放入到map中
public static void getServlet() throws ClassNotFoundException {for (int i = 0; i < javaclasses.size(); i++) {String path = javaclasses.get(i);Class<?> cl = Class.forName(path);if (cl.isAnnotationPresent(MyServlet.class)){servletMap.put(cl.getAnnotation(MyServlet.class).path(),cl);}}}
第五步:创建socket连接
InetAddress localHost = InetAddress.getLocalHost();System.out.println("localhost" + localHost);ServerSocket serverSocket = new ServerSocket(8080, 10, localHost);System.out.println("等待建立连接");Socket server = serverSocket.accept();System.out.println("连接已建立");
第六步:定义线程接收报文
HttpAcceptThread httpAcceptThread = new HttpAcceptThread(server);Thread accept = new Thread(httpAcceptThread);accept.start();accept.join();
HttpAcceptThread类内容如下:
class HttpAcceptThread implements Runnable{private Socket socket;ArrayList<String> strings = new ArrayList<>();public HttpAcceptThread(Socket socket) {this.socket = socket;}@Overridepublic void run() {System.out.println("开始接收http");try {BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));String s;while ((s = reader.readLine()).length() != 0){try {strings.add(s);System.out.println(s);} catch (Exception e){System.out.println("接收Http进程结束");break;}}System.out.println("接收http进程结束");} catch (IOException e) {e.printStackTrace();}}
}
第七步:处理httprequest,也就是通过反射去调用doGet和doPost方法
这一步有些复杂,尤其是对url切割时,但我给每一步都加了注释,方便理解
GET /address1?a=111&b=222
private static void requestHttp(Socket socket,String http) throws IOException, NoSuchMethodException, InstantiationException, IllegalAccessException, InvocationTargetException {//GET /address1?a=111&b=222(拿获取到的这个url举例)//先通过空格判断是GET还是POSTString requestStyle = http.split(" ")[0];if (requestStyle.equals("GET")){//如果是GET,取空格后面部分,即/address1?a=111&b=222String httpPathAndParameter = http.split(" ")[1];//定义httpPathString httpPath;//创建httpRequest对象MyHttpRequest myHttpRequest = new MyHttpRequest();//通过索引位置判断url里边有没有带?if (httpPathAndParameter.indexOf("?") != -1){//如果有,由于有个/,因此我们要先拿到address1?a=111&b=222这部分httpPath = httpPathAndParameter.substring(1);//获取问号前面部分,即address1,\\作为转义字符使用httpPath = httpPath.split("\\?")[0];System.out.println(httpPath);//获取问号后面部分的所有参数String parameterString = httpPathAndParameter.split("\\?")[1];//使用&分开String[] parameters = parameterString.split("&");for (int i = 0; i < parameters.length; i++) {//把参数及其值仿佛request的map中myHttpRequest.map.put(parameters[i].split("=")[0],parameters[i].split("=")[1]);}} else {//如果不存在?,也就说明不存在参数,我们只需要获取httpPathhttpPath = httpPathAndParameter.substring(1);System.out.println(httpPath);}//创建HttpResponse对象OutputStream outputStream = socket.getOutputStream();MyHttpResponse myHttpResponse = new MyHttpResponse(outputStream);//反射调用doGetClass servletClass = servletMap.get(httpPath);Method doGet = servletClass.getMethod("doGet", MyHttpRequest.class, MyHttpResponse.class);doGet.invoke(servletClass.newInstance(),myHttpRequest,myHttpResponse);} else {//如果不是Get请求,也按照同样的步骤,先取出/address1String httpPath = http.split(" ")[1];//去掉/,只留下address1httpPath = httpPath.substring(1);System.out.println(httpPath);MyHttpRequest myHttpRequest = new MyHttpRequest();OutputStream outputStream = socket.getOutputStream();MyHttpResponse myHttpResponse = new MyHttpResponse(outputStream);//根据httpPath取出类信息Class servletClass = servletMap.get(httpPath);//获取doPost方法Method doPost = servletClass.getMethod("doPost", MyHttpRequest.class, MyHttpResponse.class);//调用doPost方法doPost.invoke(servletClass.newInstance(),myHttpRequest,myHttpResponse);}}
最后一步:把上面这些方法整合起来,在主方法中调用,同时定义好全局变量
public class MyTomcat {//用于存放Java类的全类名public static ArrayList<String> javaclasses = new ArrayList<>();//用于存放Servlet的类对象,其中key是Servlet的url,value是servlet的类对象public static HashMap<String,Class> servletMap = new HashMap<>();public static void main(String[] args) throws ClassNotFoundException, IOException, InterruptedException, InvocationTargetException, NoSuchMethodException, InstantiationException, IllegalAccessException {String inputPath = "D:\\JavaProject\\practice\\src\\tomcat";File file = new File(inputPath);//获取.java后缀文件,并获取全类名func(file);System.out.println(javaclasses);//获取带有servlet注解的类对象,并放到map中。getServlet();System.out.println(servletMap);InetAddress localHost = InetAddress.getLocalHost();System.out.println("localhost" + localHost);ServerSocket serverSocket = new ServerSocket(8080, 10, localHost);System.out.println("等待建立连接");Socket server = serverSocket.accept();System.out.println("连接已建立");//定义线程接收http报文HttpAcceptThread httpAcceptThread = new HttpAcceptThread(server);Thread accept = new Thread(httpAcceptThread);accept.start();accept.join();//处理请求requestHttp(server,httpAcceptThread.strings.get(0));}
然后就可以进行测试了,在测试类上方加上我们已经定义好的@MyServlet注解
@MyServlet(path = "address1")
public class Servlet1 {public void doGet(MyHttpRequest request, MyHttpResponse response) throws IOException {System.out.println("address1 GET响应:");System.out.println("a=" + request.getParameter("a"));System.out.println("\n响应的http如下:");String resp = MyHttpResponse.responsebody + "<!DOCTYPE html>\n" +"<html>\n" +"<head>\n" +" <meta charset=\"utf-8\" />\n" +"</head>\n" +"<body>\n" +" \n" +" <form name=\"my_form\" method=\"POST\">\n" +" <input type=\"button\" value=\"按下\" onclick=\"alert('你按下了按钮')\">\n" +" </form>\n" +" \n" +"</body>\n" +"</html>";System.out.println(resp);response.outputStream.write(resp.getBytes());response.outputStream.flush();response.outputStream.close();}public void doPost(MyHttpRequest request, MyHttpResponse response) throws IOException {System.out.println("\n响应的http如下:");String resp = MyHttpResponse.responsebody +"{\"sorry\":\"we only respond to method GET now\"},\r\n" +"";System.out.println(resp);response.outputStream.write(resp.getBytes());response.outputStream.flush();response.outputStream.close();}
}
然后启动项目

可以看到本机ip地址,然后通过浏览器地址栏访问

这样就实现了一个简单的tomcat
相关文章:
如何仿写简易tomcat 实现思路+代码详细讲解
仿写之前,我们要搞清楚都要用到哪些技术 自定义注解,比如Tomcat使用的是Servlet,我们可以定义一个自己的MyServlet构造请求体和返回体,比如tomcat使用HttpRequest,我们可以自己定义myHttpRequestjava去遍历一个指定目…...
如何提高深度学习性能
可用于 对抗过度拟合并获得更好泛化能力的20 个提示、技巧和技术 如何从深度学习模型中获得更好的性能? 这是我最常被问到的问题之一。 可能会被问为: 如何提高准确率? ……或者可以反过来说: 如果我的神经网络表现不佳该怎么办? 我经常回答说:“我不太清楚,但我有很…...
ECMAScript版本对比:从ES1到ES2021
引言 ECMAScript(简称ES)是一种用于编写Web前端JavaScript的标准化语言。自1997年发布第一版(ES1)以来,ECMAScript已经经历了多个版本的更新和演进。每个版本都引入了新的语法和功能,为开发人员提供了更强…...
设计HTML5表格
在网页设计中,表格主要用于显示包含行、列结构的二维数据,如财务表格、调查数据、日历表、时刻表、节目表等。在大多数情况下,这类信息都由列标题或行标题及数据构成。本章将详细介绍表格在网页设计中的应用,包括设计符合标准化的…...
神经网络基础-神经网络补充概念-60-卷积步长
概念 在深度学习中,卷积步长(convolution stride)是指在卷积操作中滑动卷积核的步幅。卷积操作是神经网络中常用的操作之一,用于从输入数据中提取特征。步长决定了卷积核在输入数据上的滑动间隔,从而影响输出特征图的…...
怎么开通Tik Tok海外娱乐公会呢?
TikTok作为全球知名的社交媒体平台,吸引了数亿用户的关注和参与。许多公司和个人渴望通过开通TikTok直播公会进入这一领域,以展示自己的创造力和吸引更多粉丝。然而,成为TikTok直播公会并非易事,需要满足一定的门槛和申请找cmxyci…...
Java接口压力测试—如何应对并优化Java接口的压力测试
导言 在如今的互联网时代,Java接口压力测试是评估系统性能和可靠性的关键一环。一旦接口不能承受高并发量,用户体验将受到严重影响,甚至可能导致系统崩溃。因此,了解如何进行有效的Java接口压力测试以及如何优化接口性能至关重要…...
Coremail参与编制|《信创安全发展蓝皮书——系统安全分册(2023年)》
信创安全发展蓝皮书 近日,Coremail参与编制的《信创安全发展蓝皮书—系统安全分册(2023年)》重磅发布。 此次信创安全发展蓝皮书由工业和信息化部电子第五研究所联合大数据协同安全技术国家工程研究中心重磅共同发布。 本次蓝皮书涵盖信创系…...
分布式 - 消息队列Kafka:Kafka 消费者消息消费与参数配置
文章目录 1. Kafka 消费者消费消息01. 创建消费者02. 订阅主题03. 轮询拉取数据 2. Kafka 消费者参数配置01. fetch.min.bytes02. fetch.max.wait.ms03. fetch.max.bytes04. max.poll.records05. max.partition.fetch.bytes06. session.timeout.ms 和 heartbeat.interval.ms07.…...
批量爬虫采集大数据的技巧和策略分享
作为一名专业的爬虫程序员,今天主要要和大家分享一些技巧和策略,帮助你在批量爬虫采集大数据时更高效、更顺利。批量爬虫采集大数据可能会遇到一些挑战,但只要我们掌握一些技巧,制定一些有效的策略,我们就能在数据采集…...
Springboot 实践(7)springboot添加html页面,实现数据库数据的访问
前文讲解,项目已经实现了数据库Dao数据接口,并通过spring security数据实现了对系统资源的保护。本文重点讲解Dao数据接口页面的实现,其中涉及页面导航栏、菜单栏及页面信息栏3各部分。 1、创建html页面 前文讲解中,资源目录已经…...
Go中带标签的break/continue以及goto的差别
带标签的 continue: 直接跳到标签所标记的最外层循环的下一个迭代,忽略当前迭代剩余的代码。 带标签的 break: 直接跳出标签所标记的最外层循环,继续执行该循环之后的代码。 goto 关键字 goto 可以无条件地跳转到程序中指定的标…...
SaaS当然是一门好生意了啊
(1)SaaS关键特征 1、应用架构:多租户 2、部署:公有IaaS部署 3、商业模式:年度订阅续费 (2)用户云注册、用户在线付费 用户云注册、用户在线付费,站在中国乙方利益视角,多…...
ZooKeeper单机服务器启动
ZooKeeper服务器的启动,大体可以分为以下五个主要步骤:配置文件解析、初始化数据管理器、初始化网络I/O管理器、数据恢复和对外服务。下图所示是单机版ZooKeeper服务器的启动流程图。 预启动 预启动的步骤如下。 (1)统一由QuorumPeerMain作为启动类。 …...
Jenkins自动发送飞书消息
前言 公司办公软件用的是飞书套壳,本文主要介绍如何通过飞书机器人发送Jenkins构建的进度和消息。 方法 前置条件 创建一个飞书机器人搭建好Jenkins创建好构建任务 过程 根据飞书开发者平台的接口文档,用shell脚本封装一套调用飞书机器人发送消息接…...
Centos 7 出现 write error (disk full?)
问题 mysql 导入任务时,由于导出的 sql 文件是在很大 (30G),利用 SQLDumpSpliter 切割工具 切成几个 1G 大小的 sql 文件 结果在导入大半天,突然报错 (另一个服务器上更惨,都导入两天快完成的…...
音视频实时通话解决方案
1、问题提出 想要实现音视频通话,对于大部分人可能会觉得很难,但是实际上,有些事情并没有大家想的那样困难,只要功夫深,铁杵磨成针。 机缘巧合下,在业务中,我也遇到了一个业务场景需要实现音视频通话,我们不可能自己从零开始干,我本次用到的核心是WebRTC。 2、WebRT…...
WPF的范围控件Slider
WPF的范围控件Slider Slider 名称说明Orientation在竖直滑动条和水平滑动条之间切换TickPlacement决定刻度显示的位置,默认情况下,TickPlacement被设置为None,并且不显示刻度标记,如果是水平滑动条,可在上面放置刻度…...
前端框架Vue
Vue 学习路线 学习HTML、CSS和JavaScript基础知识:Vue是基于JavaScript的框架,所以首先需要掌握HTML、CSS和JavaScript的基础知识,包括DOM操作、事件处理、变量和函数等。 学习Vue的基本概念:了解Vue的核心概念,如Vu…...
基于Servlet实现的管理系统(包含服务器源码+数据库)
资料下载链接 介绍 基于Servlet框架的管理系统 简洁版 ; 实现 登录 、 注册 、 增 、 删 、 改 、 查 ; 可继续完善增加前端、校验、其他功能等; 可作为 Servlet项目 开发练习基础模型; 课程设计 、 毕业设计 开发基础&…...
利用最小二乘法找圆心和半径
#include <iostream> #include <vector> #include <cmath> #include <Eigen/Dense> // 需安装Eigen库用于矩阵运算 // 定义点结构 struct Point { double x, y; Point(double x_, double y_) : x(x_), y(y_) {} }; // 最小二乘法求圆心和半径 …...
手游刚开服就被攻击怎么办?如何防御DDoS?
开服初期是手游最脆弱的阶段,极易成为DDoS攻击的目标。一旦遭遇攻击,可能导致服务器瘫痪、玩家流失,甚至造成巨大经济损失。本文为开发者提供一套简洁有效的应急与防御方案,帮助快速应对并构建长期防护体系。 一、遭遇攻击的紧急应…...
Vue记事本应用实现教程
文章目录 1. 项目介绍2. 开发环境准备3. 设计应用界面4. 创建Vue实例和数据模型5. 实现记事本功能5.1 添加新记事项5.2 删除记事项5.3 清空所有记事 6. 添加样式7. 功能扩展:显示创建时间8. 功能扩展:记事项搜索9. 完整代码10. Vue知识点解析10.1 数据绑…...
PHP和Node.js哪个更爽?
先说结论,rust完胜。 php:laravel,swoole,webman,最开始在苏宁的时候写了几年php,当时觉得php真的是世界上最好的语言,因为当初活在舒适圈里,不愿意跳出来,就好比当初活在…...
Qt Widget类解析与代码注释
#include "widget.h" #include "ui_widget.h"Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget) {ui->setupUi(this); }Widget::~Widget() {delete ui; }//解释这串代码,写上注释 当然可以!这段代码是 Qt …...
Java-41 深入浅出 Spring - 声明式事务的支持 事务配置 XML模式 XML+注解模式
点一下关注吧!!!非常感谢!!持续更新!!! 🚀 AI篇持续更新中!(长期更新) 目前2025年06月05日更新到: AI炼丹日志-28 - Aud…...
现代密码学 | 椭圆曲线密码学—附py代码
Elliptic Curve Cryptography 椭圆曲线密码学(ECC)是一种基于有限域上椭圆曲线数学特性的公钥加密技术。其核心原理涉及椭圆曲线的代数性质、离散对数问题以及有限域上的运算。 椭圆曲线密码学是多种数字签名算法的基础,例如椭圆曲线数字签…...
[Java恶补day16] 238.除自身以外数组的乘积
给你一个整数数组 nums,返回 数组 answer ,其中 answer[i] 等于 nums 中除 nums[i] 之外其余各元素的乘积 。 题目数据 保证 数组 nums之中任意元素的全部前缀元素和后缀的乘积都在 32 位 整数范围内。 请 不要使用除法,且在 O(n) 时间复杂度…...
如何在最短时间内提升打ctf(web)的水平?
刚刚刷完2遍 bugku 的 web 题,前来答题。 每个人对刷题理解是不同,有的人是看了writeup就等于刷了,有的人是收藏了writeup就等于刷了,有的人是跟着writeup做了一遍就等于刷了,还有的人是独立思考做了一遍就等于刷了。…...
Unity | AmplifyShaderEditor插件基础(第七集:平面波动shader)
目录 一、👋🏻前言 二、😈sinx波动的基本原理 三、😈波动起来 1.sinx节点介绍 2.vertexPosition 3.集成Vector3 a.节点Append b.连起来 4.波动起来 a.波动的原理 b.时间节点 c.sinx的处理 四、🌊波动优化…...
