在前面，我们已经可以实现游览器和服务器之间的通讯了，但是由于这是一个单线程的程序，所以运行效率低下。现在我们来对程序进行改进，我们让服务器每接收到一个请求就创建一个新的线程来处理请求。

我们对上次代码进行改进。首先先创建一个类来实现Runnable接口实现多线程。

public class RequestHandler implements Runnable{
}

然后在这个类里面定义一个Socket成员属性，并且创建一个构造器来对Socket进行初始化

    //定义一个socket对象
    private Socket socket = null;
    //在初始化对象时传入socket
    public RequestHandler(Socket socket) {
        this.socket = socket;
    }

实现Runnable接口的run方法

    @Override
    public void run() {
        //对请求进行处理
    }

我们在这里最重要的是要先实现多线程，其它的实现后面再做。所以我们直接把上一次写的对响应处理的代码部分复制过来即可。然后进行一些简单异常处理。

现在我们和上次一样来创建一个类在8080端口进行循环监听

        //得到ServerSocket，在8080端口进行监听
        ServerSocket serverSocket = new ServerSocket(8080);
        System.out.println("---------服务器启动成功----------");
        while (!serverSocket.isClosed()) {
                
        }

等待客服端的连接

        //等待连接
        Socket socket = serverSocket.accept();

如果有连接，那么我们就创建一个新线程进行处理

        //创建一个线程来处理请求
        RequestHandler requestHandler = new RequestHandler(socket);
        new Thread(requestHandler).start();

完整代码如下

import com.clucky.myTomcat.thread.RequestHandler;

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

public class MyTomcat02 {

    public static void main(String[] args) {
        try {
            //得到ServerSocket，在8080端口进行监听
            ServerSocket serverSocket = new ServerSocket(8080);
            System.out.println("---------服务器启动成功----------");
            while (!serverSocket.isClosed()) {
                System.out.println("-------------------------------------------------");
                System.out.println("等待连接");
                //等待连接
                Socket socket = serverSocket.accept();
                System.out.println("连接成功");
                //创建一个线程来处理请求
                RequestHandler requestHandler = new RequestHandler(socket);
                new Thread(requestHandler).start();
            }
        } catch (IOException e) {
            System.out.println("服务器启动失败");
        }
    }
}

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

public class RequestHandler implements Runnable{

    //定义一个socket对象
    private Socket socket = null;
    //在初始化对象时传入socket
    public RequestHandler(Socket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        try {
            System.out.println(Thread.currentThread().getName()+"线程开启成功，开始处理数据");
            //得到输入流
            InputStream inputStream = socket.getInputStream();
            //将字节输入流转为字符输入流。并将编码设置为utf-8
            BufferedReader bufferedReader = new BufferedReader(
                    new InputStreamReader(inputStream, StandardCharsets.UTF_8));
            String line = null;
            //循环读取
            System.out.println("开始读取内容");
            while ((line = bufferedReader.readLine()) != null) {
                //如果为空就结束读取
                if (line.length() == 0) break;
                System.out.println(line);
            }
            System.out.println("读取内容结束");
            //得到输出流
            OutputStream outputStream = socket.getOutputStream();
            //设置响应头
            String responseHead = "HTTP/1.1 200\r\n" +
                    "Content-Type: text/html;charset=utf-8\r\n\r\n";
            //设置响应体
            String responseBody = "<h1>这是我自己写的Tomcat</h1>";
            //http响应消息内容
            String response = responseHead + responseBody;
            //写回数据
            outputStream.write(response.getBytes());
            System.out.println("响应成功");
            //关闭流
            outputStream.close();
            inputStream.close();
            socket.close();
            System.out.println("本次连接结束，正常关闭socket");
            System.out.println("-------------------------------------------------\n");
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            //保证一定关闭socket
            if (!socket.isClosed()){
                try {
                    socket.close();
                } catch (IOException e) {
                    System.out.println("socket关闭失败");
                }
            }
        }
    }
}