编写一个简单的tomcat

分类：Tomcat作者：编程之家用户

简单处理

// 客户端和服务器的通信，说到底就是两个数据的传输，
// 客户端发送inputStream给服务器，服务器回复
// outputStream给客户端。
public class TomcatServerV1 {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(8080);
        while (true) {//一直监听，直到受到停止的命令
            Socket socket = null;
            try {
                socket = serverSocket.accept();//如果没有请求，会一直hold在这里等待，有客户端请求的时候才会继续往下执行
                // log
                BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));//获取输入流(请求)
                StringBuilder stringBuilder = new StringBuilder();
                String line = null;
                while ((line = bufferedReader.readLine()) != null && !line.equals("")) {//得到请求的内容，注意这里作两个判断非空和""都要，只判断null会有问题
                    stringBuilder.append(line).append("<br>");
                }
                String result = stringBuilder.toString();
                System.out.println(result);
                // echo
                PrintWriter printWriter = new PrintWriter(socket.getOutputStream(), true);//这里第二个参数表示自动刷新缓存
                printWriter.println("HTTP/1.1 200 OK");
                printWriter.println("Content-Type:text/html;charset=utf-8");
                printWriter.println();

                printWriter.println("<h5>你刚才发送的请求数据是：<br>");
                printWriter.write(result);//将日志输出到浏览器
                printWriter.println("</h5>");
                // release
                printWriter.close();
                bufferedReader.close();
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

image-20210926182411888

每个请求一个线程

class RequestHandler implements Runnable{
    private Socket socket;

    public RequestHandler(Socket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        // log
        try {
            BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));//获取输入流(请求)
            StringBuilder stringBuilder = new StringBuilder();
            String line = null;
            while ((line = bufferedReader.readLine()) != null && !line.equals("")) {
                stringBuilder.append(line).append("<br>");
            }
            String result = stringBuilder.toString();
            System.out.println(result);
            // echo
            PrintWriter printWriter = new PrintWriter(socket.getOutputStream(), true);//这里第二个参数表示自动刷新缓存
            printWriter.println("HTTP/1.1 200 OK");
            printWriter.println("Content-Type:text/html;charset=utf-8");
            printWriter.println();

            printWriter.println("<h5>你刚才发送的请求数据是：<br>");
            printWriter.write(result);//将日志输出到浏览器
            printWriter.println("</h5>");
            // release
            printWriter.close();
            bufferedReader.close();
            socket.close();
        }catch (Exception e) {
            e.printStackTrace();
        }
    }
}

public class TomcatServerV2 {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(8888);
        while (true) {//一直监听，直到受到停止的命令
            Socket socket = null;
            socket = serverSocket.accept();//如果没有请求，会一直hold在这里等待，有客户端请求的时候才会继续往下执行
            RequestHandler requestHandler = new RequestHandler(socket);
            new Thread(requestHandler).start();
        }
    }
}

模拟tomcat

正如前面的博客：Servlet笔记中记录：

image-20210926205932056

首先建一个MyServlet接口，然后创建一个抽象类MyHttpServlet继承接口，最后建一个UserServlet实现具体的doGet，doPost等方法。

pom依赖添加servlet和dom4j。DOM4J是dom4j.org出品的一个开源XML解析包。

项目目录：

image-20210926212535405

原理图：

image-20210926214259219

Request.java

package cn.orzlinux.Bean.mytomcat.http;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;

public class Request {
    // 如/usr
    private String uri;
    // 请求方法
    private String method;
    public Request(InputStream inputStream) {
        try {
            BufferedReader reader = new BufferedReader(new InputStreamReader((inputStream)));
            //取HTTP请求响应的第一行，GET /user HTTP/1.1，按空格隔开
            String[] data = reader.readLine().split(" ");
            this.uri = data[1];
            this.method = data[0];
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public String getUri() {
        return uri;
    }

    public void setUri(String uri) {
        this.uri = uri;
    }

    public String getMethod() {
        return method;
    }

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

response

package cn.orzlinux.Bean.mytomcat.http;

import java.io.OutputStream;

public class Response {
    public OutputStream outputStream;

    public static final String responsebody="HTTP/1.1 200+\r\n"+"Content-Type：text/html+\r\n"
            +"\r\n";
    public Response(OutputStream outputStream){
        this.outputStream=outputStream;
    }
}

MyServlet

package cn.orzlinux.Bean.mytomcat.servlet;

import cn.orzlinux.Bean.mytomcat.http.Request;
import cn.orzlinux.Bean.mytomcat.http.Response;

public interface MyServlet {
    void init() throws Exception;
    void service(Request request, Response response) throws Exception;
    void destroy();
}

MyHttpServlet

package cn.orzlinux.Bean.mytomcat.servlet;

import cn.orzlinux.Bean.mytomcat.http.Request;
import cn.orzlinux.Bean.mytomcat.http.Response;

public abstract class MyHttpServlet implements MyServlet {
    public void init() throws Exception {

    }

    public void service(Request request, Response response) throws Exception {
        if("get".equalsIgnoreCase(request.getMethod())) {
            this.doGet(request,response);
        } else {
            this.doPost(request,response);
        }
    }

    public abstract void doGet(Request request,Response response);

    public abstract void doPost(Request request,Response response);


    public void destroy() {

    }
}

userServlet

package cn.orzlinux.Bean.mytomcat.servlet;

import cn.orzlinux.Bean.mytomcat.http.Request;
import cn.orzlinux.Bean.mytomcat.http.Response;

import java.io.IOException;
import java.io.OutputStream;

public class UserServlet extends MyHttpServlet {
    public void doGet(Request request, Response response) {
        System.out.println("doget");
        this.doPost(request,response);
    }

    public void doPost(Request request, Response response){
        OutputStream outputStream = response.outputStream;
        String result = Response.responsebody+"user handle successful";
        try {
            outputStream.write(result.getBytes());
            outputStream.flush();
            outputStream.close();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}

RequestHandler

package cn.orzlinux.Bean.mytomcat.socket;

import cn.orzlinux.Bean.mytomcat.http.Request;
import cn.orzlinux.Bean.mytomcat.http.Response;
import cn.orzlinux.Bean.mytomcat.servlet.MyHttpServlet;

import java.io.*;
import java.net.Socket;

public class RequestHandler implements Runnable{
    private Socket socket;

    public RequestHandler(Socket socket) {
        this.socket = socket;
    }


    public void run() {
        // log
        try {
            Request request = new Request(socket.getInputStream());
            Response response = new Response(socket.getOutputStream());
            String uri = request.getUri();
            System.out.println(uri);

            String servletName = TomcatServerV3.urlmapping.get(uri);
            MyHttpServlet servlet = TomcatServerV3.servletMapping.get(servletName);

            if(servlet!=null) {
                servlet.service(request,response);
            }else{
                String resp=Response.responsebody+"can not find servlet";
                OutputStream outputStream=socket.getOutputStream();
                System.out.println(resp);
                outputStream.write(resp.getBytes());
                outputStream.flush();
                outputStream.close();
            }
        }catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                socket.close();
            }catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

TomcatServerV3

package cn.orzlinux.Bean.mytomcat.socket;


import cn.orzlinux.Bean.mytomcat.servlet.MyHttpServlet;
import cn.orzlinux.Bean.mytomcat.socket.RequestHandler;
import org.dom4j.Document;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;

import java.io.File;
import java.io.IOException;
import java.lang.annotation.ElementType;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.HashMap;
import java.util.List;

public class TomcatServerV3 {
    public static final int port = 8080;
    // 定义mytomcat.xml中的两个映射
    public static final HashMap<string, myhttpservlet=""> servletMapping = new HashMap<string, myhttpservlet="">();

    public static final HashMap<string,string> urlmapping=new HashMap<string, string="">();

    public static void main(String[] args) throws IOException {
        TomcatServerV3 tomcatServerV3 = new TomcatServerV3();
        tomcatServerV3.init();
        tomcatServerV3.run();

    }

    // 初始化，加载xml里面的servlet信息
    private void init() {
        try {
            String path = TomcatServerV3.class.getResource("/").getPath();
            SAXReader reader = new SAXReader();
            Document document = reader.read(new File(path+"mytomcat.xml"));

            Element rootelement = document.getRootElement();
            List<element> elements = rootelement.elements();
            for(Element element:elements) {
                if ("servlet".equalsIgnoreCase(element.getName())){
                    Element servletname=element.element("servlet-name");
                    Element servletclass=element.element("servlet-class");
                    System.out.println(servletname.getText()+"==>"+servletclass.getText());
                    //需要注意的是servletMapping映射的第二个参数，要通过反射的方式进行实例化
                    servletMapping.put(servletname.getText(),
                            (MyHttpServlet) Class.forName(servletclass.getText().trim()).newInstance());
                }else if ("servlet-mapping".equalsIgnoreCase(element.getName())){
                    Element servletname=element.element("servlet-name");
                    Element urlpattern=element.element("url-pattern");
                    System.out.println(servletname.getText()+"==>"+urlpattern.getText());
                    urlmapping.put(urlpattern.getText(),servletname.getText());
                }
            }

        }catch (Exception e) {
            e.printStackTrace();
        }
    }

    private void run() {
        ServerSocket serverSocket= null;
        try {
            serverSocket = new ServerSocket(port);
            System.out.println("====服务启动====");
            while(!serverSocket.isClosed()){
                Socket socket=serverSocket.accept();
                RequestHandler requestHandler=new RequestHandler(socket);
                new Thread(requestHandler).start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

输出：

userServlet==>cn.orzlinux.Bean.mytomcat.servlet.UserServlet
userServlet==>/user
====服务启动====
/
HTTP/1.1 200+
Content-Type：text/html+

can not find servlet
/user
doget

image-20210926212451062

最后再回顾一下原理图：

image-20210926214259219

参考

java基于Socket实现的一个简单的HTTP服务器

从零开始手写Tomcat，一文彻底搞懂Tomcat运行流程（附源码）

原文地址：https://www.cnblogs.com/hqinglau-orzlinux/p/how-to-build-a-simple-tomcat.html

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

tomcat WEB-INF web.xml 映射jsp 为servlet 修改.jsp后缀为.php
&lt;servlet&gt; &lt;servlet-name&gt;tomcatpooljsp&lt;/servlet-name&gt; &lt;jsp-file&gt;/WEB-INF/tomcatpool.jsp&lt;/jsp-file&gt; &lt;/servlet&gt; &lt;servlet-mapping&gt; &lt;servlet-name&gt;tomcatpooljsp&lt;/servlet-nam...
使用Tomcat重新加载功能加快开发速度
遵循Java Servlet 规范第4节中的建议 ，Apache Tomcat实现了系统地重新加载Java类的方法，以允许在不重新启动整个服务器的情况下更新应用程序的组件。 此功能对于开发非常重要，因为事实证明，随着服务器启动和重启时间的延长，这会严重浪费开发人员的时间。实际上，Java EE堆栈应用服务器的服务器重新启动时间很慢，这是Tomcat广泛用于个人和企业级项目的推动力之一。但是，即使Tomcat也无法 像运行时重新加载应用程序一样快地启动。通过仅重新加载隔离的应用程序的更改的类，开发人员..
使用JMX监控TOMCAT
如何在Tomcat中启用JMX进行监视和管理
JMX（Java管理扩展）是一项非常强大的技术，可让您管理，监视和配置Tomcat MBean。如果您是Tomcat管理员，那么您应该熟悉如何在tomcat中启用JMX来监视堆内存，线程，CPU使用率，类以及配置各种MBean。在本文中，我将讨论如何使用JConsole启用并连接到Tomcat。我假设您已经安装了Tomcat（如果没有）；您可以参考安装指南。转到安装了Tomcat的路径 转到bin文件夹 将文件创建为“ setenv.sh” 使用vi编辑器修改文件并添加以下内容
TomCat 9 安装配置
总览介绍 建立 取得Java 获取TomCat 将TomCat安装为Windows服务 将TomCat设置为Linux服务（系统化） 使用Nginx作为反向代理 基本用法 手动启动和停止TomCat 验证TomCat服务器正在运行 服务静态文件 服务Java服务器页面（JSP） 修改设定 部署网络应用 使用管理网页界面 创建一个TomCat管理员用户 访问管理网络应用 管理网络应用 结论 参考链接介绍在最简单的概念中，To.
Apache Tomcat的高级管理器和监视器PSI Probe
PSI Probe是Lambda Probe的社区驱动分支，使用相同的开源许可证（GPLv2）分发。它旨在替换和扩展Tomcat Manager，从而使管理和监视Apache Tomcat实例更加容易。与许多其他服务器监视工具不同，PSI Probe不需要对现有应用程序进行任何更改。它通过可访问Web的界面提供所有功能，只需将其部署到服务器即可使用。这些功能包括：请求：即使在每个应用程序的基础上，实时监视流量。 会话：浏览/搜索属性，查看上一个IP，到期，估计大小。 JSP：浏览，查看源代码，进
监视和管理Tomcat
监视和管理Tomcat目录介绍 启用JMX远程 使用JMX远程Ant任务管理Tomcat JMXAccessorOpenTask-JMX打开连接任务 JMXAccessorGetTask：获取属性值Ant任务 JMXAccessorSetTask：设置属性值Ant任务 JMXAccessorInvokeTask：调用MBean操作Ant任务 JMXAccessorQueryTask：查询MBean Ant任务 JMXAccessorCreateTask：远程创建MBean Ant任
jetty和tomcat性能比较_tomcat启动jar包
1.tomcat与jetty都是一种servlet引擎，他们都支持标准的servlet规范和javaEE规范
高达起源the origin_idea找不到tomcat
“The origin server did not find a current representation for the target resource...
idea配置Tomcat时没有Artifacts选项
Artifacts是maven中的一个概念，表示某个module要如何打包，例如war exploded、war、jar、ear等等这种打包形式；
idea 添加依赖_idea Tomcat
使用 IDEA 编辑器开发项目十分便捷，这里介绍使用 IDEA 编辑器添加 Tomcat
servlet和tomcat的知识点有哪些
这篇“servlet和tomcat的知识点有哪些”文章的知识点大部分人都不太理解，所以小编给大家总结了以下内容，内容详细，步骤清晰，具有一定的借鉴价值，希望大家阅...
Tomcat管理平台实例分析
这篇文章主要讲解了“Tomcat管理平台实例分析”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“Tomcat管理平...
tomcat虚拟主机怎么配置
本文小编为大家详细介绍“tomcat虚拟主机怎么配置”，内容详细，步骤清晰，细节处理妥当，希望这篇“tomcat虚拟主机怎么配置”文章能帮助大家解决疑惑，下面跟
tomcat相关配置与eclipse集成的方法
今天小编给大家分享一下tomcat相关配置与eclipse集成的方法的相关知识点，内容详细，逻辑清晰，相信大部分人都还太了解这方面的知识，所以分享这篇文章给大家
Tomcat之web应用的目录组成结构是怎样的
这篇“Tomcat之web应用的目录组成结构是怎样的”文章的知识点大部分人都不太理解，所以小编给大家总结了以下内容，内容详细，步骤清晰，具有一定的借鉴价值，
tomcat目录映射的方法
今天小编给大家分享一下tomcat目录映射的方法的相关知识点，内容详细，逻辑清晰，相信大部分人都还太了解这方面的知识，所以分享这篇文章给大家参考一下，希望大...
tomcat的环境怎么配置
这篇“tomcat的环境怎么配置”文章的知识点大部分人都不太理解，所以小编给大家总结了以下内容，内容详细，步骤清晰，具有一定的借鉴价值，希望大家阅读完这篇文...
cacti监控tomcat
环境：tomcat：apache-tomcat-7.0.35 cactiEZ:10.1系统：centos5.6_x64一、配置tomcat服务器1、添加账号vim tomcat-users.xml 重启tomcat2、安装snmp协议yum...
Tomcat怎样整合APR？
一、 软环下载地址软件链接地址https://files.cnblogs.com/files/jinrf/openssl-1.0.2-latest.tar.gzhttps://files.cnblogs.com/files/jinrf/apr-util-1.6...
pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot