如何用JAVA手写一个Tomcat

news2025/5/23 2:11:46

一、初步理解Tomcat

Tomcat是什么？

Tomcat 是一个开源的 轻量级 Java Web 应用服务器，核心功能是 运行 Servlet/JSP。

Tomcat的核心功能？

Servlet 容器：负责加载、实例化、调用和销毁 Servlet。

HTTP 服务器：监听端口（默认 8080），解析 HTTP 请求，封装 HTTP 响应。

JSP 支持：将 JSP 文件编译为 Servlet 执行。

线程池管理：并发处理多个请求，提高性能。

二、Servlet的原理

Servlet框架 

三、什么是socket 

Socket（套接字）是计算机网络中用于进程间通信的核心技术，它允许不同主机或同一主机上的不同程序通过网络交换数据

 Socket 是什么？

  • 定义：Socket 是操作系统提供的抽象接口，本质上是通信的端点（Endpoint）。它封装了底层网络协议（如TCP/IP或UDP）的复杂性，提供了一组简单的API【API（Application Programming Interface，应用程序编程接口） 是软件系统之间交互的桥梁，定义了如何请求服务、传递数据以及返回结果的规则。】供应用程序使用。

  • 关键要素：

    • IP地址：标识网络中的主机。

    • 端口号：标识主机上的具体服务（如HTTP默认80端口）。

    • 协议：如TCP（可靠连接）或UDP（无连接）。

端口是逻辑抽象概念，并非物理硬件。

端口是操作系统用来区分不同网络服务的数字标识（范围0~65535）。

网卡（硬件）负责收发数据，而端口由操作系统通过协议栈（如TCP/IP）管理。

Socket 是软件技术，不是物理硬件。

Socket的作用

  • 跨网络通信：使不同设备上的进程能够交换数据（例如浏览器与服务器交互）。

  • 支持多种协议：可通过TCP、UDP等协议传输数据。

  • 双向通信：建立连接后，双方可同时发送和接收数据。

  • 灵活性：可用于构建各种网络应用（如Web服务器、聊天软件、文件传输等）。

为什么 Tomcat 需要 Socket？ 

Tomcat 是一个基于Java的Web服务器和Servlet容器，其核心功能依赖Socket实现：

  1. HTTP请求处理：

    • 当用户访问网站时，浏览器通过Socket（TCP连接）向Tomcat发送HTTP请求。

    • Tomcat监听8080端口（默认），通过Socket接收请求数据，解析后交给Servlet处理。

    • 处理完成后，再通过Socket将HTTP响应返回给浏览器。

  2. 连接管理：

    • Tomcat使用ServerSocket监听端口，等待客户端连接。

    • 每收到一个请求，Tomcat会创建一个新的Socket连接（或复用线程池中的连接）处理该请求，实现高并发。

  3. 协议支持：

    • 除了HTTP/1.1（基于TCP Socket），Tomcat还支持HTTP/2、WebSocket等，这些协议最终都依赖Socket实现数据传输。

 Tomcat 中的 Socket 工作流程 

四、Tomcat框架及代码

网卡上需要注册端口号。

 通过searchClassUtil类能获取类的全路径------>>根据全路径名生成类对象（反射）------>>获取类信息

public class HttpServletRequest {
    private String method;
    private String url;
    //............

    public String getMethod() {
        return method;
    }

    public void setMethod(String method) {
        this.method = method;
    }

    public String getUrl() {
        return url;
    }

    public void setUrl(String url) {
        this.url = url;
    }
}

public class HttpServletResponse {

    //输出流
    private OutputStream outputStream;
    public HttpServletResponse(OutputStream outputStream){
        this.outputStream = outputStream;
    }

    /**
     * 返回动态资源
     * @param context
     */
    public void write(String context) throws IOException {
        //System.out.println(context);
        outputStream.write(context.getBytes());
    }

    /**
     * 返回静态资源
     */
    public void writeHtml(String path) throws Exception {
        String resourcesPath = FileUtil.getResoucePath(path);
        File file = new File(resourcesPath);
        if(file.exists()){
            //静态文件存在
            System.out.println("静态文件存在");
            FileUtil.writeFile(file,outputStream);
        }else {
            System.out.println("静态文件不存在");
            write(ResponseUtil.getResponseHeader404());
        }
    }

}

/**
 * tomcat路由
 */
public class TomcatRoute {
    public static HashMap<String, HttpServlet> routes = new HashMap<>();
    static {
        List<String> paths  = SearchClassUtil.searchClass();  //获取全路径名
        //根据全路径名称生成类对象
        for (String path: paths) {
            try {
                Class clazz = Class.forName(path);  //生成类对象
                WDServlet webServlet = (WDServlet) clazz.getDeclaredAnnotation(WDServlet.class);
                routes.put(webServlet.url(), (HttpServlet) clazz.getDeclaredConstructor().newInstance());
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

}

public interface servlet {
    public void service(HttpServletRequest request, HttpServletResponse response) throws IOException;
}

public abstract class HttpServlet implements servlet {
    public void doGet(HttpServletRequest request, HttpServletResponse response) throws IOException {}
    public void doPost(HttpServletRequest request,HttpServletResponse response){}

    @Override
    public void service(HttpServletRequest request, HttpServletResponse response) throws IOException {
         if(request.getMethod().equals("GET")){
             doGet(request,response);
         }else if(request.getMethod().equals("POST")){
             doPost(request,response);
         }
    }
}

@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
public @interface WDServlet {
    String url() default "";
}


@WDServlet(url = "/myServlet")
public class MyFirstServlet extends HttpServlet {
    @Override
    public void doPost(HttpServletRequest request, HttpServletResponse response) {
        super.doPost(request, response);
    }

    @Override
    public void doGet(HttpServletRequest request, HttpServletResponse response) throws IOException {
        System.out.println("Hello World");
        response.write(ResponseUtil.getResponseHeader200("hello world  hhhhh"));
    }
}


@WDServlet(url = "/insert")
public class InsertServlet extends HttpServlet {
    @Override
    public void doGet(HttpServletRequest request, HttpServletResponse response)  throws IOException {
        System.out.println("我是insert......");
    }

    @Override
    public void doPost(HttpServletRequest request, HttpServletResponse response) {
        super.doPost(request, response);
    }
}

@WDServlet(url = "/delete")
public class DeleteServlet extends HttpServlet {
    @Override
    public void doPost(HttpServletRequest request, HttpServletResponse response) {
        super.doPost(request, response);
    }

    @Override
    public void doGet(HttpServletRequest request, HttpServletResponse response) throws IOException {
        super.doGet(request, response);
    }
}

/**
 * tomcat主启动类
 */
public class MyTomcat {

    static HashMap<String, HttpServlet> routes = TomcatRoute.routes; //tomcat路由\


    /**
     * 分发器
     */
    public  void dispatch(HttpServletRequest request ,HttpServletResponse response) throws IOException {
        HttpServlet servlet = routes.get(request.getUrl());  //
        if(servlet!=null){ //说明请求的就是我们的servlet
            servlet.service(request,response);
        }
    }

    /**
     * socket 启动
     * @throws IOException
     */
    public  void start() throws IOException {
        ServerSocket serverSocket = new ServerSocket(4700);  //1.指定监听的端口号
        //2.对端口进行监听
        while (true){
            Socket socket = serverSocket.accept();//阻塞监听
            //3.打开输入流，解析客户端发来的内容
            InputStream inputStream = socket.getInputStream(); //输入流
            HttpServletRequest request = new HttpServletRequest();

            BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));  //将字节流转换成字符流
            String str = reader.readLine();
            request.setMethod(str.split("\\s")[0]);
            request.setUrl(str.split("\\s")[1]);

            //4.打开输出流
            OutputStream outputStream = socket.getOutputStream();
            HttpServletResponse response = new HttpServletResponse(outputStream);
            dispatch(request,response);
        }

    }

    //socket
    public static void main(String[] args) throws IOException {
        MyTomcat myTomcat = new MyTomcat();
        myTomcat.start();
    }
}

 

 五、字节流、字符流

字节流：二进制；

字符流：各种字符

 

 

 

 

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

使用 Qt QGraphicsView/QGraphicsScene 绘制色轮

使用 Qt QGraphicsView/QGraphicsScene 绘制色轮

使用 Qt QGraphicsView/QGraphicsScene 绘制色轮 本文介绍如何在 Qt 中利用 QGraphicsView 和 QGraphicsScene 实现基础圆形绘制&#xff0c;以及进阶的色轮&#xff08;Color Wheel&#xff09;效果。 色轮是色彩选择器的常见控件&#xff0c;广泛应用于图形设计、绘画和 UI …
阅读更多...
使用glsl 来做视频矫正

使用glsl 来做视频矫正

描述、优点 使用glsl来代替opencv的undistort 和 鱼眼矫正，并且最后使用opencv的LUT给glsl 来使用，来达到加速的目的，并且做到和opencv 一模一样的效果，达到实时视频的加速矫正。 优点: 没有cuda，也可以做到实时视频矫正，包含各类板子和amd的cpu，intel核显 矫正的基本作…
阅读更多...
03-Web后端基础(Maven基础)

03-Web后端基础(Maven基础)

1. 初始Maven 1.1 介绍 Maven 是一款用于管理和构建Java项目的工具&#xff0c;是Apache旗下的一个开源项目 。 Apache 软件基金会&#xff0c;成立于1999年7月&#xff0c;是目前世界上最大的最受欢迎的开源软件基金会&#xff0c;也是一个专门为支持开源项目而生的非盈利性…
阅读更多...
蓝桥杯19682 完全背包

蓝桥杯19682 完全背包

问题描述 有 N 件物品和一个体积为 M 的背包。第 i 个物品的体积为 vi​&#xff0c;价值为 wi​。每件物品可以使用无限次。 请问可以通过什么样的方式选择物品&#xff0c;使得物品总体积不超过 M 的情况下总价值最大&#xff0c;输出这个最大价值即可。 输入格式 第一行…
阅读更多...
DeepSeek源码解构：从MoE架构到MLA的工程化实现

DeepSeek源码解构：从MoE架构到MLA的工程化实现

文章目录 **一、代码结构全景&#xff1a;从模型定义到分布式训练****二、MoE架构&#xff1a;动态路由与稀疏激活的工程化实践****1. 专家路由机制&#xff08;带负载均衡&#xff09;****数学原理&#xff1a;负载均衡损失推导** **三、MLA注意力机制&#xff1a;低秩压缩与解…
阅读更多...
【VLNs篇】02：NavGPT-在视觉与语言导航中使用大型语言模型进行显式推理

【VLNs篇】02：NavGPT-在视觉与语言导航中使用大型语言模型进行显式推理

方面 (Aspect)内容总结 (Content Summary)论文标题NavGPT: 在视觉与语言导航中使用大型语言模型进行显式推理 (NavGPT: Explicit Reasoning in Vision-and-Language Navigation with Large Language Models)核心问题探究大型语言模型 (LLM) 在复杂具身场景&#xff08;特别是视…
阅读更多...
(T_T)，不小心删掉RabbitMQ配置文件数据库及如何恢复

(T_T)，不小心删掉RabbitMQ配置文件数据库及如何恢复

一、不小心删除 今天是2025年5月15日&#xff0c;非常沉重的一天&#xff0c;就在今早8点左右的时候我打算继续做我的毕业设计&#xff0c;由于开机的过程十分缓慢&#xff08;之前没有&#xff09;&#xff0c;加上刚开机电脑有卡死的迹象&#xff0c;再加上昨天晚上关电脑前…
阅读更多...
TDengine 安全部署配置建议

TDengine 安全部署配置建议

背景 TDengine 的分布式、多组件特性导致 TDengine 的安全配置是生产系统中比较关注的问题。本文档旨在对 TDengine 各组件及在不同部署方式下的安全问题进行说明&#xff0c;并提供部署和配置建议&#xff0c;为用户的数据安全提供支持。 安全配置涉及组件 TDengine 包含多…
阅读更多...
蓝桥杯框架-LED蜂鸣器继电器

蓝桥杯框架-LED蜂鸣器继电器

蓝桥杯框架-LED蜂鸣器继电器 一&#xff0c;新建工程文件二&#xff0c;配置keil三&#xff0c;完善框架 一&#xff0c;新建工程文件 在桌面上新建一个文件夹&#xff1a;用于存放所有工程文件 在文件夹中再建立一个文件夹DEMO_01&#xff1a;这是我们的第一个工程文件 在第…
阅读更多...
uniapp-商城-64-后台 商品列表（商品修改---页面跳转，深浅copy应用，递归调用等）

uniapp-商城-64-后台 商品列表（商品修改---页面跳转，深浅copy应用，递归调用等）

完成了商品的添加和展示&#xff0c;下面的文字将继续进行商品页面的处理&#xff0c;主要为商品信息的修改的页面以及后天逻辑的处理。 本文主要介绍了商品信息修改页面的实现过程。首先&#xff0c;页面布局包括编辑和删除功能&#xff0c;未来还可添加上架和下架按钮。通过c…
阅读更多...
Dify的大语言模型（LLM） AI 应用开发平台-本地部署

Dify的大语言模型（LLM） AI 应用开发平台-本地部署

前言 今天闲着&#xff0c;捣鼓一下 Dify 这个开源平台&#xff0c;在 mac 系统上&#xff0c;本地部署并运行 Dify 平台&#xff0c;下面记录个人在本地部署Dify 的过程。 Dify是什么&#xff1f; Dify是一个开源的大语言模型&#xff08;LLM&#xff09;应用开发平台&#…
阅读更多...
使用教程：8x16模拟开关阵列可级联XY脚双向导通自动化接线

使用教程：8x16模拟开关阵列可级联XY脚双向导通自动化接线

以下通过点亮LED进行基本使用流程演示&#xff0c;实际可以连接复杂外设&#xff08;SPI、CAN、ADC等&#xff09; 单模块使用 RX、TX、5V和GND接到串口模块&#xff1b;X5接5V&#xff1b;Y2接LED;LED-接GND 串口模块插上电脑后&#xff0c;LED没有亮&#xff1b;因为此时模…
阅读更多...
8 种快速易用的Python Matplotlib数据可视化方法

8 种快速易用的Python Matplotlib数据可视化方法

你是否曾经面对一堆复杂的数据&#xff0c;却不知道如何让它们变得直观易懂&#xff1f;别慌&#xff0c;Python 的 Matplotlib 库是你数据可视化的最佳伙伴&#xff01;它简单易用、功能强大&#xff0c;能将枯燥的数字变成引人入胜的图表。无论是学生、数据分析师还是程序员&…
阅读更多...
C# 深入理解类(实例构造函数)

C# 深入理解类(实例构造函数)

实例构造函数 实例构造函数是一个特殊的方法&#xff0c;它在创建类的每个新实例时执行。 构造函数用于初始化类实例的状态。如果希望能从类的外部创建类的实例&#xff0c;需要将构造函数声明为public。 图7-2阐述了构造函数的语法。除了下面这几点&#xff0c;构造函数看起…
阅读更多...
RabbitMQ——消息确认

RabbitMQ——消息确认

一、消息确认机制 生产者发送的消息&#xff0c;可能有以下两种情况&#xff1a; 1> 消息消费成功 2> 消息消费失败 为了保证消息可靠的到达消费者&#xff08;&#xff01;&#xff01;&#xff01;注意&#xff1a;消息确认机制和前面的工作模式中的publisher confi…
阅读更多...
测试W5500的第2步_使用ioLibrary库创建TCP客户端

测试W5500的第2步_使用ioLibrary库创建TCP客户端

ioLibrary库下载地址&#xff1a;文件下载地址:https://gitee.com/wiznet-hk/STM32F10x_W5500_Examples 源文件下载地址:https://gitee.com/wiznet-hk 没有注册的&#xff0c;只能复制粘贴了。 本文介绍了如何初始化STM32的硬件资源&#xff0c;配置W5500的网络参数&#xff…
阅读更多...
深度学习之用CelebA_Spoof数据集搭建一个活体检测-训练好的模型用MNN来推理

深度学习之用CelebA_Spoof数据集搭建一个活体检测-训练好的模型用MNN来推理

一、模型转换准备 首先确保已完成PyTorch到ONNX的转换&#xff1a;深度学习之用CelebA_Spoof数据集搭建活体检测系统&#xff1a;模型验证与测试。这里有将PyTorch到ONNX格式的模型转换。 二、ONNX转MNN 使用MNN转换工具进行格式转换&#xff1a;具体的编译过程可以参考MNN的…
阅读更多...
开源安全大模型Foundation-Sec-8B实操

开源安全大模型Foundation-Sec-8B实操

一、兴奋时刻 此时此刻，晚上22点55分，从今天早上6点左右开始折腾，花费了接近10刀的环境使用费，1天的休息时间，总算是把Foundation-Sec-8B模型跑起来了，中间有两次胜利就在眼前，但却总在远程端口转发环节出问题，让人难受。直到晚上远程Jupyter访问成功那一刻，眉开眼笑，…
阅读更多...
【JavaWeb】MySQL

【JavaWeb】MySQL

1 引言 1.1 为什么学&#xff1f; 在学习SpringBootWeb基础知识(IOC、DI等)时&#xff0c;在web开发中&#xff0c;为了应用程序职责单一&#xff0c;方便维护&#xff0c;一般将web应用程序分为三层&#xff0c;即&#xff1a;Controller、Service、Dao 。 之前的案例中&am…
阅读更多...
微信小游戏流量主广告自动化浏览功能案例5

微信小游戏流量主广告自动化浏览功能案例5

功能需求&#xff1a; 支持APP单行文本框输入1个小程序链接&#xff0c;在“文件传输助手”界面发送小程序链接并进入。 主要有“文章列表首页”和“文章内容”页面。每个页面支持点击弹窗广告、槽位广告、视频广告入口、视频广告内第三方广告。 弹窗广告、槽位广告、视频广…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023