搭建Tomcat(三)---重写service方法

目录

引入

一、在Java中创建一个新的空项目(初步搭建)

问题:

要求在tomcat软件包下的MyTomcat类中编写main文件,实现在MyTomcat中扫描myweb软件包中的所有Java文件,并返回“@WebServlet(url="myFirst")”中url内填写的值:

①main函数解析:

首先,main函数用try-catch做了异常处理:

指定包名:

 获取包下所有类的类对象:

扫描遍历:

二、搭建服务器端

在socket软件包的Server文件中编写:当存在客户端连接后,获取:

分析一下获取路径和请求方法的过程:

三、搭建

重写service方法:


引入

前面已经提到了,TomCat就是项目运行的环境,之前用到的Servlet文件都是通过eclipse中的tomcat容器来运行的,那么接下来在Java文件中去模拟这个过程。

在tomcat项目中创建Servlet项目。

一、在Java中创建一个新的空项目(初步搭建)

创建新项目后再去在目录下创建如下软件包Java类。

@WebServlet接口中代码:

package com.qcby.tomcat.webservlet;import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;@Retention(value= RetentionPolicy.RUNTIME)
@Target(value={ElementType.TYPE})
public @interface WebServlet {String url() default "";String className() default "";
}

myweb里面的MyFirstServlet等三个文件内调用@WebServlet接口,如下代码:
(以MyFirstServlet为例:)

package com.qcby.tomcat.myweb;import com.qcby.tomcat.HttpServlet.HttpServlet;
import com.qcby.tomcat.webservlet.WebServlet;@WebServlet(url="myFirst")
public class MyFirstServlet extends HttpServlet {}

问题:

要求在tomcat软件包下的MyTomcat类中编写main文件,实现在MyTomcat中扫描myweb软件包中的所有Java文件,并返回“@WebServlet(url="myFirst")”中url内填写的值:

MyTomcat内:

package com.qcby.tomcat;import com.qcby.tomcat.webservlet.WebServlet;import java.io.File;
import java.net.URL;
import java.net.URLClassLoader;
import java.util.ArrayList;
import java.util.Enumeration;
import java.util.List;public class MyTomcat {public static void main(String[] args) {//扫描myweb这个包下的所有文件,并获取到它的@WebServlet中的url的值// get current dirtry {// 1. 扫描包路径 (com.wzh.tomcat.myweb)String packageName = "com.qcby.tomcat.myweb";List<Class<?>> classes = getClasses(packageName);   //通过getClasses()方法获取到了myweb这个包下面的所有类的类对象,并将其放到了类对象中// 2. 遍历所有类,检查是否有@WebServlet注解for (Class<?> clazz : classes) {if (clazz.isAnnotationPresent(WebServlet.class)) {// 3. 获取@WebServlet注解的值WebServlet webServlet = clazz.getAnnotation(WebServlet.class);System.out.println("类名: " + clazz.getName() + " | URL路径: " + webServlet.url());}}} catch (Exception e) {e.printStackTrace();//打印异常}}/*** 获取指定包下的所有类** @param packageName 包名,例如 "com.qcby.tomcat.myweb"* @return 类对象列表* @throws Exception*/private static List<Class<?>> getClasses(String packageName) throws Exception {List<Class<?>> classes = new ArrayList<>(); //将类文件封装进List中String path = packageName.replace('.', '/'); // 将包名转换为文件路径// 通过类加载器获取包的资源路径ClassLoader classLoader = Thread.currentThread().getContextClassLoader();Enumeration<URL> resources = classLoader.getResources(path);while (resources.hasMoreElements()) {URL resource = resources.nextElement();File directory = new File(resource.toURI());// 扫描文件夹下的所有类文件if (directory.exists()) {for (File file : directory.listFiles()) {if (file.getName().endsWith(".class")) {    //获得.class文件(.java->.class)此处获取的就是经过编译后的.class文件// 获取类的完整类名String className = packageName + "." + file.getName().replace(".class", "");classes.add(Class.forName(className));}}}}return classes;}
}

解析:

①main函数解析:
首先,main函数用try-catch做了异常处理:
  • try-catch块用于捕获并处理在扫描包和读取注解时可能发生的异常。
指定包名
  • String packageName = "com.qcby.tomcat.myweb";:定义了一个字符串变量packageName,它存储了要扫描的包名。
 获取包下所有类的类对象
  • List<Class<?>> classes = getClasses(packageName);
  • 这行代码调用了一个名为getClasses的方法(后面分析getClasses就知道这是一个获取类对象的方法),将这些获取的类对象写入到一个泛型中,方便后续遍历。
  • 调用getClasses方法,传入包名,获取该包下所有类的Class对象列表,并存储在classes变量中。
扫描遍历:

对获得并写入List中的每个文件进行isAnnotationPresent判断是否有@WebServlet注解:

注释:isAnnotationPresent是Java语言中的一种方法,它主要用于判断某个类、方法、变量等元素上是否存在指定类型的注解。】

  • 调用clazz.getAnnotation(WebServlet.class);时,Java虚拟机(JVM)会做以下几件事情:
  1. 检查clazz对象所代表的类上是否存在WebServlet注解的实例。
  2. 如果存在,返回这个注解的实例。
  3. 如果不存在,返回null

扫描获得后打印输出。 

那么分析完成main函数后,接着来分析一下getClases方法具体是怎么实现获取包中类信息的:

(详细参见注释:)

// 定义一个静态方法,用于获取指定包名下的所有类对象列表
private static List<Class<?>> getClasses(String packageName) throws Exception {List<Class<?>> classes = new ArrayList<>(); // 初始化一个ArrayList,用于存储找到的类对象// 将包名中的点(.)替换为文件路径中的斜杠(/),以构造资源路径String path = packageName.replace('.', '/');// 获取当前线程的类加载器,用于加载资源ClassLoader classLoader = Thread.currentThread().getContextClassLoader();// 通过类加载器获取指定路径下的所有资源(可能是目录或JAR文件中的条目)Enumeration<URL> resources = classLoader.getResources(path);// 遍历所有找到的资源while (resources.hasMoreElements()) {URL resource = resources.nextElement(); // 获取下一个资源URL// 注意:这里假设资源是一个文件系统上的目录,但这不是总是正确的,特别是当资源在JAR中时File directory = new File(resource.toURI()); // 将资源URL转换为File对象(这里存在潜在问题,对于JAR文件不适用)// 检查目录是否存在(对于文件系统上的资源有效)if (directory.exists()) {// 遍历目录下的所有文件和子目录for (File file : directory.listFiles()) {// 检查文件是否以".class"结尾,即是否是类文件(.java文件经过编译后的.class文件)if (file.getName().endsWith(".class")) {// 构造类的完整名称(包括包名)String className = packageName + "." + file.getName().replace(".class", "");// 使用反射加载类,并添加到类列表中// 注意:这里可能会抛出ClassNotFoundException,但在这个方法内部没有捕获处理classes.add(Class.forName(className));}}}}// 返回找到的类对象列表return classes;
}

二、搭建服务器端

在socket软件包的Server文件中编写:
当存在客户端连接后,获取:

package com.qcby.tomcat.socket;import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;public class Server {public static void main(String[] args) throws  Exception {// 1.打开通信端口   tomcat:8080   3306  ---------》进行网络通信ServerSocket serverSocket = new ServerSocket(8080);System.out.println("****************server start.....");//2.接受请求数据while (true){Socket socket = serverSocket.accept();  //--------------------->注意:此时监听网卡的是:主线程System.out.println("有客户进行了链接");new Thread(()->{//处理数据---------》数据的处理在于读和写try {handler(socket);} catch (Exception e) {e.printStackTrace();}}).start();}}public static void handler(Socket socket) throws Exception {//读取请求的数据InputStream inputStream = socket.getInputStream();requestContext(inputStream);}public static void requestContext(InputStream inputStream) throws IOException { //获取全部信息//将bit流转为文字信息int count = 0;while (count == 0){count = inputStream.available();}byte[] bytes = new byte[count];inputStream.read(bytes);String Context = new String(bytes);System.out.println(Context);//解析数据if(Context.equals("")){System.out.println("你输入了一个空请求");}else {String firstLine=Context.split("\\n")[0];String path=firstLine.split("\\s")[1];String method=firstLine.split("\\s")[0];System.out.println(path+" "+method);}}//获取第一个词和第二个词
//    public static void requestContext(InputStream inputStream) throws IOException {
//        StringBuilder sb = new StringBuilder();
//        int ch;
//        // 读取输入流直到遇到换行符或文件结束
//        while ((ch = inputStream.read()) != -1) {
//            if (ch == '\n') {
//                break; // 遇到换行符,停止读取
//            }
//            sb.append((char) ch); // 将读取的字符添加到StringBuilder中
//        }
//
//        String firstLine = sb.toString().trim(); // 获取第一行并去除首尾空格
//        if (firstLine.isEmpty()) {
//            System.out.println("你输入了一个空请求");
//        } else {
//            String[] words = firstLine.split("\\s+"); // 使用正则表达式按空格分割单词
//            if (words.length >= 2) {
//                System.out.println("第一个词是:" + words[0]);
//                System.out.println("第二个词是:" + words[1].substring(1));
//            } else {
//                System.out.println("第一行没有足够的词");
//            }
//        }
//    }}

分析一下获取路径和请求方法的过程:

  1. String firstLine = Context.split("\\n")[0];
    • 这行代码将 Context 字符串按照换行符(\n)进行分割,并取出分割后的第一个元素(即第一行)赋值给 firstLine
  2. String path = firstLine.split("\\s")[1];
    • 接着,这行代码将 firstLine 按照空白字符(包括空格、制表符等,\s 是一个正则表达式,用于匹配任何空白字符)进行分割,并取出分割后的第二个元素(索引为1)赋值给 path。这里假设路径是 firstLine 中方法名后面的第一个元素。
  3. String method = firstLine.split("\\s")[0];
    • 这行代码再次对 firstLine 按照空白字符进行分割,并取出分割后的第一个元素(索引为0)赋值给 method。这里假设方法名是 firstLine 中的第一个元素。
  4. System.out.println(path + " " + method);
    • 最后,这行代码打印出 path 和 method 的值,但顺序是先打印 path,后打印 method,中间用空格分隔。

三、搭建

【注:接口--接口就是用来定义方法的;实现接口类就必须实现接口中的方法;

抽象类中可以有抽象方法,也可以有具体方法;抽象类实现了接口,那么抽象类可以有选择性的实现接口中的方法】

重写service方法:

HTTP请求:

请求方法--Get,Post....等(主要是Get\Post方式)

而上述实现service方法,就是为了获取请求方法并且判断是Get还是Post请求(然后将请求送到doGet()/doPost()方法中)

在HttpServlet包中的方法HttpServlet抽象类中重写service方法:

首先创建request:

public class Request {private String path;private String method;public String getPath() {return path;}public void setPath(String path) {this.path = path;}public String getMethod() {return method;}public void setMethod(String method) {this.method = method;}
}

并且修改Server来得到path和method:

import com.qcby.tomcat.Request.Request;import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;public class Server {//实例化Requestprivate static Request request = new Request();public static void main(String[] args) throws Exception {// 1.打开通信端口   tomcat:8080   3306  ---------》进行网络通信ServerSocket serverSocket = new ServerSocket(8080);System.out.println("****************server start.....");//2.接受请求数据while (true) {Socket socket = serverSocket.accept();  //--------------------->注意:此时监听网卡的是:主线程System.out.println("有客户进行了链接");new Thread(() -> {//处理数据---------》数据的处理在于读和写try {handler(socket);} catch (Exception e) {e.printStackTrace();}}).start();}}public static void handler(Socket socket) throws Exception {//读取请求的数据InputStream inputStream = socket.getInputStream();requestContext(inputStream);}public static void requestContext(InputStream inputStream) throws IOException { //获取全部信息//将bit流转为文字信息int count = 0;while (count == 0) {count = inputStream.available();}byte[] bytes = new byte[count];inputStream.read(bytes);String Context = new String(bytes);System.out.println(Context);//解析数据if (Context.equals("")) {System.out.println("你输入了一个空请求");} else {String firstLine = Context.split("\\n")[0];String method = firstLine.split("\\s")[0];String path = firstLine.split("\\s")[1];System.out.println(method + " " + path);//任何请求都会被打到这个类中,随后就会被解析//将解析后的数据(method和path放进申请的static的Request实例中--再被运输给其他需要的地方)request.setMethod(method);request.setPath(path);}}

即可通过这种方式让HttpServlet中的service方法得到Http请求的key和请求方法:

import com.qcby.tomcat.Request.Request;
import com.qcby.tomcat.socket.Server;public abstract class HttpServlet {/** 一定不能是抽象方法因为HttpServlet是要被实现的* 根据用户的请求,来调用不用的方法去处理*       GET请求   doGet()请求*       POST请求  doPost()请求** *///重写service()方法public  void service(Request request){//一定不能是抽象方法因为HttpServlet是要被实现的if(request.getMethod().equals("GET")){doGet(request);}else if(request.getMethod().equals("POST")){doPost(request);}}//去实现doGet--意味着所有继承HttpServlet抽象类的对象,都要去实现这两个方法public abstract void doGet(Request request);//去实现doPostpublic abstract void doPost(Request request);}

那么就意味着(继承抽象类的实例必须实现抽象类中的方法):

那么到这里,一个基础的、连贯的tomcat雏形就存在了:

四、Tomcat雏形

1.tomcat的server接收到一个请求:

发送请求:

2.被tomcat的server接收到:

 3.此时server内部创建了一个static的Request实例,并被HttpServlet里面的service接收:

通过if-else if判断后,被送到对应的doGet或doPost方法:

由于HttpServlet是抽象类,所以所有继承这个抽象类的实例都要实现抽象类中的所有方法: 

类似:

同时,由于doGet()和doPost()方法都是抽象方法,所以HttpServlet想要实现这些方法,就要去到各自的实例中,而这个实例究竟是哪一个,则就对应path中存的路径了。 

以上就是一个基础的雏形(关于tomcat是如何接收并初步处理一个请求的)

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

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

相关文章

Linux介绍与安装CentOS 7操作系统

什么是操作系统 操作系统&#xff0c;英⽂名称 Operating System&#xff0c;简称 OS&#xff0c;是计算机系统中必不 可少的基础系统软件&#xff0c;它是 应⽤程序运⾏以及⽤户操作必备的基础环境 ⽀撑&#xff0c;是计算机系统的核⼼。 操作系统的作⽤是管理和控制计算机系…

【Linux】深入理解进程信号机制:信号的产生、捕获与阻塞

&#x1f3ac; 个人主页&#xff1a;谁在夜里看海. &#x1f4d6; 个人专栏&#xff1a;《C系列》《Linux系列》《算法系列》 ⛰️ 时间不语&#xff0c;却回答了所有问题 目录 &#x1f4da;前言 &#x1f4da;一、信号的本质 &#x1f4d6;1.异步通信 &#x1f4d6;2.信…

【西门子PLC.博途】——面向对象编程及输入输出映射FC块

当我们做面向对象编程的时候&#xff0c;需要用到输入输出的映射。这样建立的变量就能够被复用&#xff0c;从而最大化利用了我们建立的udt对象。 下面就来讲讲映射是什么。 从本质上来说&#xff0c;映射就是拿实际物理对象对应程序虚拟对象&#xff0c;假设程序对象是I0.0&…

MySQL索引的理解

MySQL与磁盘的交互 根据冯诺依曼结构体系&#xff0c;我们知道我们任何上层的应用想要去访问磁盘就必须要通过内存来访问&#xff0c;MySQL作为一款储存数据的服务&#xff0c;肯定是很多时间要用来访问磁盘。而大量访问磁盘一定会影响运行效率的在innoDB的存储引擎下为了减少…

分布式全文检索引擎ElasticSearch-数据的写入存储底层原理

一、数据写入的核心流程 当向 ES 索引写入数据时&#xff0c;整体流程如下&#xff1a; 1、客户端发送写入请求 客户端向 ES 集群的任意节点&#xff08;称为协调节点&#xff0c;Coordinating Node&#xff09;发送一个写入请求&#xff0c;比如 index&#xff08;插入或更…

Maven 生命周期

文章目录 Maven 生命周期- Clean 生命周期- Build 生命周期- Site 生命周期 Maven 生命周期 Maven 有以下三个标准的生命周期&#xff1a; Clean 生命周期&#xff1a; clean&#xff1a;删除目标目录中的编译输出文件。这通常是在构建之前执行的&#xff0c;以确保项目从一个…

Android Studio AI助手---Gemini

从金丝雀频道下载最新版 Android Studio&#xff0c;以利用所有这些新功能&#xff0c;并继续阅读以了解新增内容。 Gemini 现在可以编写、重构和记录 Android 代码 Gemini 不仅仅是提供指导。它可以编辑您的代码&#xff0c;帮助您快速从原型转向实现&#xff0c;实现常见的…

#渗透测试#漏洞挖掘#红蓝攻防#护网#sql注入介绍04-盲SQL注入(Blind SQL Injection)

免责声明 本教程仅为合法的教学目的而准备&#xff0c;严禁用于任何形式的违法犯罪活动及其他商业行为&#xff0c;在使用本教程前&#xff0c;您应确保该行为符合当地的法律法规&#xff0c;继续阅读即表示您需自行承担所有操作的后果&#xff0c;如有异议&#xff0c;请立即停…

Scala 的迭代器

迭代器定义&#xff1a;迭代器不是一种集合&#xff0c;它是一种用于访问集合的方法。 迭代器需要通过集合对应的迭代器调用迭代器的方法来访问。 支持函数式编程风格&#xff0c;便于链式操作。 创建一个迭代器&#xff0c;相关代码如下&#xff1a; object Test {def mai…

底层理论基础(单片机)

计算机基础 IO逻辑 计算机系统中的高低电平逻辑1和0&#xff0c;数据在计算机中的存储、传输、运算都是以二进制形式进行的。 数据的传输通过总线真正传递的是电信号&#xff0c;高低电平&#xff08;0、1&#xff09;。运算在电路中进行&#xff0c;集成电路中运算。 计算机的…

B站bilibili视频转文字字幕下载方法

本文将讲述介绍一种使用本地工具如何快速的下载B站的字幕为本地文本文件的方法。 通常获取B站字幕需要在浏览器中安装第三方插件&#xff0c;通过插件获取字幕。随着大模型&#xff0c;生成式AI&#xff0c;ChatGPT的应用&#xff0c;B站也提供了AI小助手对视频的内容进行总结…

ROS+PX4+Gazebo仿真环境配置全流程解析

上一期文章介绍了我们即将发布的仿真平台&#xff0c;并提到后续需要在Ubuntu系统上进行PX4软件在环仿真。本期文章将为大家详细介绍如何配置Ubuntu环境以及安装ROS和PX4仿真环境。具体配置包括&#xff1a;Ubuntu 20.04 ROS Noetic PX4 Python3。 需要注意的是&#xff0c…

基础入门-APP应用微信小程序原生态开发H5+Vue技术WEB封装打包反编译抓包点

知识点&#xff1a; 1、基础入门-APP应用-开发架构安全问题 2、基础入门-小程序应用-开发架构安全问题 通用&#xff1a; 1、反编译-得到源码-源码提取资产&#xff08;泄漏的配置信息&#xff09;-安全测试 2、抓包-资产-安全测试 一、演示案例-移动App-开发架构-原生&H…

Elasticsearch:使用 Open Crawler 和 semantic text 进行语义搜索

作者&#xff1a;来自 Elastic Jeff Vestal 了解如何使用开放爬虫与 semantic text 字段结合来轻松抓取网站并使其可进行语义搜索。 Elastic Open Crawler 演练 我们在这里要做什么&#xff1f; Elastic Open Crawler 是 Elastic 托管爬虫的后继者。 Semantic text 是 Elasti…

Qt之自定义标题栏拓展(十)

Qt开发 系列文章 - user-defined-titlebars&#xff08;十&#xff09; 目录 前言 一、方式一 1.效果演示 2.创建标题栏类 3.可视化UI设计 4.定义相关函数 5.使用标题栏类 二、方式二 1.效果演示 2.创建标题栏类 3.定义相关函数 4.使用标题栏类 总结 前言 Qt自带…

vue3前端组件库的搭建与发布(一)

前言&#xff1a; 最近在做公司项目中&#xff0c;有这么一件事情&#xff0c;很是头疼&#xff0c;就是同一套代码&#xff0c;不同项目&#xff0c;要改相同bug&#xff0c;改好多遍&#xff0c;改的都想吐&#xff0c;于是就想做一个组件库&#xff0c;这样更新一下就全都可…

学技术学英文:代码中的锁:悲观锁和乐观锁

本文导读&#xff1a; 1. 举例说明加锁的场景&#xff1a; 多线程并发情况下有资源竞争的时候&#xff0c;如果不加锁&#xff0c;会出现数据错误&#xff0c;举例说明&#xff1a; 业务需求&#xff1a;账户余额>取款金额&#xff0c;才能取钱。 时间线 两人共有账户 …

Qt编译MySQL数据库驱动

目录 Qt编译MySQL数据库驱动 测试程序 Qt编译MySQL数据库驱动 &#xff08;1&#xff09;先找到MySQL安装路径以及Qt安装路径 C:\Program Files\MySQL\MySQL Server 8.0 D:\qt\5.12.12 &#xff08;2&#xff09;在D:\qt\5.12.12\Src\qtbase\src\plugins\sqldrivers\mysql下…

CTFHUB-web(SSRF)

内网访问 点击进入环境&#xff0c;输入 http://127.0.0.1/flag.php 伪协议读取文件 /?urlfile:///var/www/html/flag.php 右击查看页面源代码 端口扫描 1.根据题目提示我们知道端口号在8000-9000之间,使用bp抓包并进行爆破 POST请求 点击环境&#xff0c;访问flag.php 查看页…

游戏引擎学习第43天

仓库 https://gitee.com/mrxiao_com/2d_game 介绍运动方程 今天我们将更进一步&#xff0c;探索运动方程&#xff0c;了解真实世界中的物理&#xff0c;并调整它们&#xff0c;以创建一种让玩家感觉愉悦的控制体验。这并不是在做一个完美的物理模拟&#xff0c;而是找到最有趣…