百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术教程 > 正文

Tomcat处理HTTP请求流程解析

csdh11 2025-05-16 12:36 2 浏览

1、一个简单的 HTTP 服务器

在Web应用中,浏览器请求一个URL,服务器就把生成的HTML网页发送给浏览器,而浏览器和服务器之间的传输协议是HTTP,那么接下来我们看下如何用Java来实现一个简单的HTTP服务器。

具体代码实现

import java.nio.charset.StandardCharsets;
import java.io.*;
import java.util.*;
import java.net.*;

/**
 * HTTP 服务
 */
public class HttpServer {
    public static void main(String[] args) throws IOException {
        // 监听指定端口
        ServerSocket ss = new ServerSocket(9901);
        System.out.println("server is running...");
        for (;;) {
            Socket sock = ss.accept();
            System.out.println("connected from " + sock.getRemoteSocketAddress());
            // 开启线程处理接收到的socket数据
            Thread t = new Handler(sock);
            t.start();
        }
    }
}

/**
 * 执行类
 */
class Handler extends Thread {
    Socket sock;

    public Handler(Socket sock) {
        this.sock = sock;
    }

    public void run() {
        try (InputStream input = this.sock.getInputStream()) {
            try (OutputStream output = this.sock.getOutputStream()) {
                handle(input, output);
            }
        } catch (Exception e) {
            try {
                this.sock.close();
            } catch (IOException ioe) {
            }
            System.out.println("client disconnected.");
        }
    }

    /**
     * 具体执行方法
     * 处理http输入数据,转换输出
     * @param input
     * @param output
     * @throws IOException
     */
    private void handle(InputStream input, OutputStream output) throws IOException {
        System.out.println("Process new http request...");
        BufferedReader reader = new BufferedReader(new InputStreamReader(input, StandardCharsets.UTF_8));
        BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(output, StandardCharsets.UTF_8));
        // 读取HTTP请求:
        boolean requestOk = false;
        String first = reader.readLine();
        if (first.startsWith("GET / HTTP/1.")) {
            requestOk = true;
        }
        for (;;) {
            String header = reader.readLine();
            if (header.isEmpty()) { // 读取到空行时, HTTP Header读取完毕
                break;
            }
            System.out.println(header);
        }
        System.out.println(requestOk ? "Response OK" : "Response Error");
        if (!requestOk) {
            // 发送错误响应:
            writer.write("HTTP/1.0 404 Not Found-lzf\r\n");
            writer.write("Content-Length: 0\r\n");
            writer.write("\r\n");
            writer.flush();
        } else {
            // 发送成功响应:
            String data = "<html><body><h1 style="color:red">Hello, LZF!</h1></body></html>";
            int length = data.getBytes(StandardCharsets.UTF_8).length;
            writer.write("HTTP/1.0 200 OK\r\n");
            writer.write("Connection: close\r\n");
            writer.write("Content-Type: text/html\r\n");
            writer.write("Content-Length: " + length + "\r\n");
            writer.write("\r\n"); // 空行标识Header和Body的分隔
            writer.write(data);
            writer.flush();
        }
    }
}
复制代码

我们用 javac HttpServer.java 命令将java文件编译成可执行类,然后运行命令 java HttpServer

可以看到 server 已经正常启动,我们在网页上输入 127.0.0.1:9901, 可以看到已经能够正常返回了,是不是很简单呀。

2、使用 Tomcat 处理HTTP请求

从上面我们可以看到编写HTTP服务器其实是非常简单的,只需要先编写基于多线程的TCP服务,然后在一个TCP连接中读取HTTP请求,发送HTTP响应就可以了。

但是,要编写一个完善的HTTP服务器,还要考虑更多东西例如:

  • 识别正确和错误的HTTP请求;
  • 识别正确和错误的HTTP头;
  • IO异常处理;
  • ...

我们一直都在强调不要重复造轮子,Java发展了这么久处理TCP连接,解析HTTP协议这些底层工作早已有了现成的API。JavaEE提供的Servlet API,我们可以使用Servlet API编写自己的Servlet来处理HTTP请求,

接下来我们看一个简单的例子

import java.nio.charset.StandardCharsets;
import java.io.*;
import java.util.*;
import java.net.*;
import java.io.PrintWriter;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

// WebServlet注解表示这是一个Servlet,并映射到地址/:
@WebServlet(urlPatterns = "/")
public class HelloServlet extends HttpServlet {
    protected void doGet(HttpServletRequest req, HttpServletResponse resp)
            throws ServletException, IOException {
        // 设置响应类型:
        resp.setContentType("text/html");
        // 获取输出流:
        PrintWriter pw = resp.getWriter();
        String name = req.getParameter("name");
        // 写入响应:
        if (null == name) {
            pw.write("<h1>Hello, world!</h1>");
        } else {
            pw.write("<h1>Hello, " + name + "!</h1>");
        }
        // 最后不要忘记flush强制输出:
        pw.flush();
    }
}

其中 Servlet API是一个jar包,我们需要通过Maven来引入它,才能正常编译。编写pom.xml文件如下

<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.lzf.learnjava</groupId>
    <artifactId>web-servlet-hello1</artifactId>
    <packaging>war</packaging>
    <version>1.0-SNAPSHOT</version>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
        <java.version>8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>javax.servlet</groupId>
            <artifactId>javax.servlet-api</artifactId>
            <version>4.0.0</version>
            <scope>provided</scope>
        </dependency>
    </dependencies>

    <build>
        <finalName>hello</finalName>
    </build>
</project>

具体代码结构目录如下

Mavean 打包出来的是war包, 需要运行的话得先启动Web服务器,而Web服务我们最常用的就是Tomcat。首先我们到官网下载Tomcat服务器,解压后

Tomcat目录:

bin:存放启动和关闭tomcat脚本 conf:存放不同的配置文件(server.xml和web.xml) doc:存放Tomcat文档 lib:存放Tomcat运行需要的库文件(JARS) logs:存放Tomcat执行时的LOG文件 webapps:Tomcat的主要Web发布目录(包括应用程序示例) work:存放jsp编译后产生的class文件

把hello.war复制到Tomcat的webapps目录下,Tomcat 默认监听的8080的端口,可以通过修改 conf/server.xml -> Connector 里的 port 属性来改变监听端口。然后切换到bin目录,执行startup.sh或startup.bat启动Tomcat服务器

  网页上输入
http://localhost:9903/hello/?name=Qc ,成功访问!

接下来我们来分析Tomcat 是如何处理一个HTTP请求的过程

首先我们先了解Tomcat 的体系架构

参考上面的图解释下:

1.Server组件
   即服务器,每个tomcat程序启动后,就是一个server。
    
2、Service组件
   一个Server可以包含多个Service,Service这是一种抽象的服务,它把连接器和处理引擎结合在一起。

3、Connector组件:
   一个Service可以有多个Connector,Connector组件用于处理连接和并发。一般说来常见于server.xml
中的连接器类型通常有4种:
  1) HTTP连接器 2) SSL连接器 3) AJP 1.3连接器 4) proxy连接器
  
4、Engine组件:
   Engine是Servlet处理器的一个实例,即servlet引擎,其defaultHost属性是用来来为其定义一个接收所
有发往非明确定义虚拟主机的请求的host组件。如前面示例中定义的:
   <Engine name=”Catalina” defaultHost=”localhost”>

5、Host组件:
   位于Engine容器中,用于接收请求并进行相应处理的主机或虚拟主机.
   
  <!-- 自定义host , 类似 nginx 反向代理功能 />   -->
  <Host name="aaatc.test" appBase="webapps2">
  </Host>

  <!--如果一个主机有两个或两个以上的主机名,额外的名称均可以以别名的形式进行定义: -->
  <Host name="localhost" appBase="webapp" unpackWARs="true">
  <Alias>bbbtc.test</Alias>
  </Host>


6、Context组件:
   Context在某些意义上类似于apache中的路径别名,一个Context定义用于标识tomcat实例中的一个Web应用程序

了解了架构之后我们看请求过程

1、用户打开浏览器输入地址,请求被发送到本机端口9903,被在那里监听的Coyote HTTP/1.1 Connector获得。

2、Connector把该请求交给它所在的Service的Engine来处理,并等待Engine的回应。

3、Engine获得请求localhost:9903/hello/?name=Qc,匹配所有的虚拟主机Host。

4、Engine匹配到名为localhost的Host(即使匹配不到也把请求交给该Host处理,因为该Host被定义为该Engine的默认主机)名为localhost的Host获得请求/hello/?name=Qc,匹配它所拥有的所有的Context。 Host匹配到路径为/hello 的Context(如果匹配不到就把该请求交给路径名为""的Context去处理)。

5、在它的mapping table中寻找出对应的Servlet 处理数据。

6、构造HttpServletRequest对象和HttpServletResponse对象,作为参数调用JspServlet的doGet()或doPost().执行业务逻辑、数据存储等程序。

7、Context把执行完之后的HttpServletResponse对象返回给Host。

8、Host把HttpServletResponse对象返回给Engine。

9、Engine把HttpServletResponse对象返回Connector。

10、Connector把HttpServletResponse对象返回给浏览器。

以上就是 Tomcat 处理一个HTTP请求的完整流程。

3、将 Tomcat 以 Jar 包的方式引入

Tomcat 实际上也是一个Java程序,我们可以把 Tomcat 以 Jar 包的方式引入,然后自己编写一个main()方法,先启动Tomcat,然后让它加载我们的webapp就行。我们常用的 SpringBoot 框架采用的就是这样的方式。

首先我们需要先建一个项目 web-servlet-hello-tomcat, 编写pom.xml文件

<project xmlns="http://maven.apache.org/POM/4.0.0"
      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
 <modelVersion>4.0.0</modelVersion>
 <groupId>com.lzf.learnjava</groupId>
 <artifactId>web-servlet-hello-tomcat</artifactId>
 <packaging>war</packaging>
 <version>1.0-SNAPSHOT</version>

 <properties>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
     <maven.compiler.source>8</maven.compiler.source>
     <maven.compiler.target>8</maven.compiler.target>
     <java.version>8</java.version>
     <tomcat.version>9.0.58</tomcat.version>
 </properties>

 <dependencies>
     <dependency>
         <groupId>org.apache.tomcat.embed</groupId>
         <artifactId>tomcat-embed-core</artifactId>
         <version>${tomcat.version}</version>
         <scope>provided</scope>
     </dependency>
     <dependency>
         <groupId>org.apache.tomcat.embed</groupId>
         <artifactId>tomcat-embed-jasper</artifactId>
         <version>${tomcat.version}</version>
         <scope>provided</scope>
     </dependency>
 </dependencies>

 <build>
     <finalName>hello</finalName>
 </build>
</project>

然后,我们编写一个main()方法,启动Tomcat服务器

package com.lzf.learnjava.servlet;

import org.apache.catalina.Context;
import org.apache.catalina.WebResourceRoot;
import org.apache.catalina.startup.Tomcat;
import org.apache.catalina.webresources.DirResourceSet;
import org.apache.catalina.webresources.StandardRoot;

import java.io.File;

/**
* @author liuzufa
*/
public class Main {
   public static void main(String[] args) throws Exception {
       // 启动Tomcat:
       Tomcat tomcat = new Tomcat();
       tomcat.setPort(Integer.getInteger("port", 9904));
       tomcat.getConnector();
       // 创建webapp:
       Context ctx = tomcat.addWebapp("", new File("src/main/webapp").getAbsolutePath());
       WebResourceRoot resources = new StandardRoot(ctx);
       resources.addPreResources(
               new DirResourceSet(resources, "/WEB-INF/classes", new File("target/classes").getAbsolutePath(), "/"));
       ctx.setResources(resources);
       tomcat.start();
       tomcat.getServer().await();
   }
}

除去前面的手动输出HTML的方法,我们还可以使用JSP。JSP是Java Server Pages的缩写,它的文件必须放到/src/main/webapp下,文件名必须以.jsp结尾,整个文件与HTML并无太大区别,但需要插入变量,或者动态输出的地方,使用特殊指令<% ... %>。

JSP和Servlet有什么区别?其实它们没有任何区别,因为JSP在执行前首先被编译成一个Servlet。在Tomcat的临时目录下,可以找到一个hello_jsp.java的源文件,这个文件就是Tomcat把JSP自动转换成的Servlet源码。

4、总结

 1、学会使用java编写一个简单http服务
 2、解释了Tomcat处理一次HTTP请求的完整流程
 3、将Tomcat以jar 的方式引入项目中,学会了简单的JSP开发。


作者:xiao6zi470
链接:
https://juejin.cn/post/7067917428319223845


相关推荐

完美解决华硕主板机箱前置面板连接音箱无声音问题

#精品长文创作季#最近新组装了一台电脑主机,听歌时发现,音箱音频输入线插入主板自带的音频输出端口LINEOUT声音正常。但当将音箱音频输入线插入机箱自带的音频输出端口却没有声音。...

Java 监控直播流rtsp协议转rtmp、hls、httpflv协议返回浏览器

Java监控直播流rtsp协议转rtmp、hls、httpflv协议返回浏览器...

编译安装OpenCV全攻略,附本地源码包

本文以Ubuntu(适用于18,20,22版本,其他的未进行测试)为例,介绍了编译安装OpenCV的最佳实践。其他平台比如windows,只需要参考本文的思路做稍微调整即可。一、为什么需要编译安装Op...

音视频录制+RTMP直播推拉流

音视频录制:1,录音通过条件编译识别pc或者mac://条件编译技术识别pc或者mac#ifdefQ_OS_WIN#defineFMT_NAME"dshow"...

Python Socket.IO 简介

Socket.IO是一种传输协议,支持客户端与服务器之间基于事件的实时双向通信。客户端通常但不总是web浏览器,一般情况下,客户端是采用js编写的,当然,也可以用python、Java等。...

MyCat系列二--配置文件之server.xml

MyCat系列二--配置文件之server.xml从【安装与基本使用】一文中,可以看到MyCat运行,需要进行一些配置文件的相关配置,本文将重点介绍配置文件server.xml的基本元素信息,尽量了解...

3分钟搞懂Socket.IO:接口调试技巧

在数字化协作需求井喷的今天,即时通讯、协同文档、MMO游戏等场景对实时交互提出了严苛要求。传统HTTP协议"请求-响应"的离散式通信机制已难以满足需求,这正是Socket.IO这类实时...

「云原生」Containerd ctr,crictl 和 nerdctl 命令介绍与实战操作

一、概述作为接替Docker运行时的Containerd在早在Kubernetes1.7时就能直接与Kubelet集成使用,只是大部分时候我们因熟悉Docker,在部署集群时采用了默认的dockers...

搜狗开源srpc:自研高性能通用RPC框架

今年7月底,搜狗公司开源了内部的工业级C++服务器引擎Workflow,一路收获业内许多认可和关注。9月15日,作为Workflow最重要的生态项目——srpc,一个基于其打造的轻量级RPC框架,也在...

socket.io 权限认证

socket.io是一款流行的WebSocket库,提供了实时双向通信的能力。它支持多种身份验证方式,可用于保护某些敏感信息。接下来,我们将介绍如何使用socket.io权限认证1.安装依...

Linux高性能服务器设计

C10K和C10M计算机领域的很多技术都是需求推动的,上世纪90年代,由于互联网的飞速发展,网络服务器无法支撑快速增长的用户规模。1999年,DanKegel提出了著名的C10问题:一台服务器上同时...

19K 标星!开源局域网文件传输神器,AirDrop 跨平台替代品!

传统文件传输方式(如USB、蓝牙、邮件)要么速度慢,要么操作繁琐,而AirDrop仅限苹果生态。如果你还在为手机和电脑之间传文件来回折腾?还在装各种臃肿的客户端、扫码连Wi-Fi、用数据线拖来...

WebRTC 入门教程:搭建WebRTC信令服务器

前言我们在学习WebRTC时,首先要把实验环境搭建好,这样我们就可以在上面做各种实验了。对于WebRTC来说,它有一整套规范,如怎样使用它的接口、使用SDP进行媒体协商、通过ICE收集地址并进...

在 Go 中使用 Websockets 和 Socket.IO - 教程

注意-本教程是使用Go1.9版和googollee/go-socket.io编写的Websockets是我觉得有趣的东西,因为它们为我们提供了应用程序之间通信的替代选项,而不是标准的R...

2021 年 Node.js 开发人员学习路线图

Node.js自发布以来,已成为业界重要破局者之一。Uber、Medium、PayPal和沃尔玛等大型企业,纷纷将技术栈转向Node.js。Node.js支持开发功能强大的应用,例如实时追踪...