【手写Tomcat】5.实现自己定义的MyHttpRequest

一时失言乱红尘 2023-09-30 07:55 31阅读 0赞

在上一次，我们设计了自己的Servlet，现在我们来对具体的Servlet进行实现。

我们首先来对MyHttpRequest进行实现，这个类就相当于Tomcat里面的HttpServletRequest，我们实现最基本的几个功能。分别是：

*   **getParameter(String name)**
 *   **getMethod()**
 *   **getUri()**

--------------------

# 代码编写 #

>  **我们首先在MyHttpServlet接口里面定义这几个方法。**

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_19_color_FFFFFF_t_70_g_se_x_16][]

>  **然后在MyHttpRequestImpl类里面实现这几个方法，我们首先定义几个成员变量**

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_20_color_FFFFFF_t_70_g_se_x_16][]

> 写一个构造器，在创建对象时传入一个InputStream流，并使用这个流就行初始化

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_19_color_FFFFFF_t_70_g_se_x_16 1][]

>  **这个init方法我们最后实现，我们先实现接口里面的几个方法**

**getParameter(String name)**

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_18_color_FFFFFF_t_70_g_se_x_16][]

**getMethod()**

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_18_color_FFFFFF_t_70_g_se_x_16 1][]

**getUri()**

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_18_color_FFFFFF_t_70_g_se_x_16 2][]

>  **为了测试方便，我们再写一个toString()方法**

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 1][]

--------------------

>  **现在，我们对前面提到的init()方法进行实现，这个方法要对成员属性进行初始化。我们这里仅考虑2种请求方式，一直get，一种post。又因为get和post的http请求不一样，所以我们要分开进行处理。**

> **我们先来对get请求进行处理，我在前面的http介绍里面说过，get请求的参数在请求行中就有体现。所以我们通过请求行就能得到请求参数，方法，uri。如果对http请求不了解，请参考[http请求][http]，[get和post][http]。**

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 2][]

>  **于是，我们就可以定义一个方法来对get请求进行处理**

public void setGetParamsAndUri(String requestLine) {
            //得到最后一个空格索引
            int lastSpace = requestLine.lastIndexOf(" ");
            //通过第一个空格索引和最后一个空格索引就能得到uri和参数
            String s = requestLine.substring(requestLine.indexOf(" ")+1, lastSpace);
            //判断是否含有？
            if (s.contains("?")) {
                //得到第一个？索引
                int firstFlag = s.indexOf("?");
                //？前面的就是uri
                uri = s.substring(0, firstFlag);
                //后面的就是参数
                String params = s.substring(firstFlag + 1);
                //将字符串传给setParams进行初始化
                setParams(params);
            } else {
                //没有?直接赋值
                uri = s;
            }
        }

public void setParams(String params) {
            //通过&进行分割
            String[] kvs = params.split("&");
            for (String kv : kvs) {
                //通过=进行分割
                String[] keyVal = kv.split("=");
                //如果keyVal是正确写法就将参数和值存入HashMap中进行保存
                if (keyVal.length == 2) {
                    String key = keyVal[0];
                    String value = keyVal[1];
                    parameters.put(key, value);
                }
            }
        }

> **下面我们再对post进行处理，post的请求和get不同，请求行中没有参数，参数在请求体中。我们写一个方法来对post进行处理**

public void setPostParamsAndUri(String requestLine, StringBuilder sb) {
            try {
                //得到uri
                uri = requestLine.substring(requestLine.indexOf(" ") + 1, requestLine.lastIndexOf(" "));
                //URLDecoder是对游览器的请求进行解码
                //传入的sb就是请求头+请求体
                //我们通过寻找最后一个换行符就能得到请求体
                String params = URLDecoder.decode(sb.substring(sb.lastIndexOf("\n")+1), "utf-8");
                //和get一样传入参数字符串，然后对参数进行初始化
                setParams(params);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

>  **下面，我们来编写我们的init方法**

public void init() {
            try {
                //定义一个字节数组
                byte[] bytes = new byte[1024];
                int len = 0;
                //定义一个StringBuilder来对http请求进行存储
                StringBuilder sb = new StringBuilder();
                //读取内容
                while ((len = inputStream.read(bytes)) != -1) {
                    sb.append(new String(bytes, 0, len));
                    if (len != bytes.length) break;
                }
                //获得请求行并进行解码
                String requestLine = URLDecoder.decode(sb.substring(0, sb.indexOf("\r")), "utf-8");
                requestLine = URLDecoder.decode(requestLine, "utf-8");
                //得到请求行第一个空格位置
                int firstSpace = requestLine.indexOf(" ");
                //得到请求方法
                method = requestLine.substring(0, firstSpace);
                //通过方法调用不同方法
                if ("GET".equals(method)) {
                    setGetParamsAndUri(requestLine);
                } else if ("POST".equals(method)) {
                    setPostParamsAndUri(requestLine, sb);
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

--------------------

> **上面，我们就已经把基本的3个方法实现了，当然，肯定还有不完善的地方，如字符串处理，对其他请求方法的处理，异常参数处理等。但是我们写这个的主要目的是为了对tomcat的运行机制有更深的认识，不需要太过于关注细节，所以，上面这样写就行了。下面给出这个类的完整代码**

import java.io.IOException;
    import java.io.InputStream;
    import java.net.URLDecoder;
    import java.util.HashMap;
    import java.util.Map;
    
    public class MyHttpRequestImpl implements MyHttpRequest {
    
        //定义成员属性
        private String method;
        private String uri;
        private Map<String, String> parameters = new HashMap<>();
        private InputStream inputStream;
    
        public MyHttpRequestImpl(InputStream inputStream) {
            this.inputStream = inputStream;
            //对成员属性进行初始化
            init();
        }
    
        public void init() {
            try {
                //定义一个字节数组
                byte[] bytes = new byte[1024];
                int len = 0;
                //定义一个StringBuilder来对http请求进行存储
                StringBuilder sb = new StringBuilder();
                //读取内容
                while ((len = inputStream.read(bytes)) != -1) {
                    sb.append(new String(bytes, 0, len));
                    if (len != bytes.length) break;
                }
                //获得请求行并进行解码
                String requestLine = URLDecoder.decode(sb.substring(0, sb.indexOf("\r")), "utf-8");
                requestLine = URLDecoder.decode(requestLine, "utf-8");
                //得到请求行第一个空格位置
                int firstSpace = requestLine.indexOf(" ");
                //得到请求方法
                method = requestLine.substring(0, firstSpace);
                //通过方法调用不同方法
                if ("GET".equals(method)) {
                    setGetParamsAndUri(requestLine);
                } else if ("POST".equals(method)) {
                    setPostParamsAndUri(requestLine, sb);
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    
        public void setGetParamsAndUri(String requestLine) {
            //得到最后一个空格索引
            int lastSpace = requestLine.lastIndexOf(" ");
            //通过第一个空格索引和最后一个空格索引就能得到uri和参数
            String s = requestLine.substring(requestLine.indexOf(" ")+1, lastSpace);
            //判断是否含有？
            if (s.contains("?")) {
                //得到第一个？索引
                int firstFlag = s.indexOf("?");
                //？前面的就是uri
                uri = s.substring(0, firstFlag);
                //后面的就是参数
                String params = s.substring(firstFlag + 1);
                //将字符串传给setParams进行初始化
                setParams(params);
            } else {
                //没有?直接赋值
                uri = s;
            }
        }
    
        public void setPostParamsAndUri(String requestLine, StringBuilder sb) {
            try {
                //得到uri
                uri = requestLine.substring(requestLine.indexOf(" ") + 1, requestLine.lastIndexOf(" "));
                //URLDecoder是对游览器的请求进行解码
                //传入的sb就是请求头+请求体
                //我们通过寻找最后一个换行符就能得到请求体
                String params = URLDecoder.decode(sb.substring(sb.lastIndexOf("\n")+1), "utf-8");
                //和get一样传入参数字符串，然后对参数进行初始化
                setParams(params);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    
        public void setParams(String params) {
            //通过&进行分割
            String[] kvs = params.split("&");
            for (String kv : kvs) {
                //通过=进行分割
                String[] keyVal = kv.split("=");
                //如果keyVal是正确写法就将参数和值存入HashMap中进行保存
                if (keyVal.length == 2) {
                    String key = keyVal[0];
                    String value = keyVal[1];
                    parameters.put(key, value);
                }
            }
        }
    
        @Override
        public String getParameter(String name) {
            if (parameters.containsKey(name)) {
                return parameters.get(name);
            }
            return "";
        }
    
        @Override
        public String getMethod() {
            return method;
        }
    
        @Override
        public String getUri() {
            return uri;
        }
    
        @Override
        public String toString() {
            return "MyHttpRequestImpl{" +
                    "method='" + method + '\'' +
                    ", uri='" + uri + '\'' +
                    ", parameters=" + parameters +
                    '}';
        }
    }

--------------------

# 代码测试 #

**我创建了一个测试类来测试刚刚写的代码，测试类非常简单，代码如下**

import com.clucky.myTomcat.myHttp.MyHttpRequest;
    import com.clucky.myTomcat.myHttp.MyHttpRequestImpl;
    
    import java.io.*;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    public class Test {
    
        public static void main(String[] args) {
            try {
                //得到ServerSocket，在8080端口进行监听
                ServerSocket serverSocket = new ServerSocket(8080);
                System.out.println("---------服务器启动成功----------");
                while (!serverSocket.isClosed()) {
                    //等待连接
                    Socket socket = serverSocket.accept();
                    System.out.println("连接成功.....");
                    //得到输入流
                    InputStream inputStream = socket.getInputStream();
                    MyHttpRequest myHttpRequest = new MyHttpRequestImpl(inputStream);
                    System.out.println(myHttpRequest);
                    //写回数据
                    socket.getOutputStream().write("HTTP/1.1 200\r\n\r\nhello".getBytes());
                    System.out.println("断开连接.....");
                    //关闭流
                    inputStream.close();
                    socket.close();
                }
            } catch (IOException e) {
                System.out.println("服务器启动失败");
            }
        }
    }

>  **我们再来创建一个表单来对post进行测试，代码如下**

<!DOCTYPE html>
    <html lang="en">
    <head>
        <meta charset="UTF-8">
        <title>login</title>
    </head>
    <body>
    <form action="http://localhost:8080/login" method="post">
        username:<input type="text" name="username"/><br/>
        password:<input type="password" name="password"/><br/>
        <input type="submit">
    </form>
    </body>
    </html>

--------------------

## 测试GET请求 ##

首先我们运行测试类，在游览器输入[http://localhost:8080/people?name=zs&age=18][http_localhost_8080_people_name_zs_age_18]，然后查看控制台输出。输入如下

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 3][]

**成功获取到所有参数，说明GET请求没有问题。**

--------------------

## 测试POST请求 ##

首先运行测试类，然后打开html文件，账号密码随便输入，点击提交后查看控制台输出

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_17_color_FFFFFF_t_70_g_se_x_16][]

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 4][]

**获取到的用户名和密码与我们输入一样，说明POST请求也没有问题。**

--------------------

## 现在，我们已经实现了我们自己定义的MyHttpServlet，在下一篇文章，我们来实现我们自己定义的MyHttpResponse！！！ ##

[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_19_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/9242ed221b57416081da5162df8a34e6.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0,size_19,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_20_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/00e14546d98747b0a91f30ad53ceb934.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_19_color_FFFFFF_t_70_g_se_x_16 1]: https://img-blog.csdnimg.cn/ea3e159f016047bcb31f66a7375525f4.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0,size_19,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_18_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/fd026a489b7a41aaa257879917f1ea9a.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0,size_18,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_18_color_FFFFFF_t_70_g_se_x_16 1]: https://img-blog.csdnimg.cn/61444e54a7034726ad174fa771b6a060.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0,size_18,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_18_color_FFFFFF_t_70_g_se_x_16 2]: https://img-blog.csdnimg.cn/8b77fc2df94043f4862175e1fc433a6f.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0,size_18,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 1]: https://img-blog.csdnimg.cn/87fcfb513ff44589a5381a373c9ccae2.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0,size_20,color_FFFFFF,t_70,g_se,x_16
[http]: https://blog.csdn.net/m0_51545690/article/details/123090635
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 2]: https://img-blog.csdnimg.cn/9ca2c6139f284c9d800b79bd6a387a87.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0,size_20,color_FFFFFF,t_70,g_se,x_16
[http_localhost_8080_people_name_zs_age_18]: http://localhost:8080/people?name=zs&age=18
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 3]: https://img-blog.csdnimg.cn/cbd0da16c43f4846b1ba95ed7e2bc7da.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_17_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/dda24ca3c0f64f8cb5093189b58043fd.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0,size_17,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 4]: https://img-blog.csdnimg.cn/81e24960183c4e158e31cca5b0e41d46.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5LiN5pyN6L6T55qE5bCR5bm0,size_20,color_FFFFFF,t_70,g_se,x_16