一、问题引出

1、我们上篇文章写了一个最简单的socket服务端，但这个服务端还有待优化。为了测试问题，我们在写回给客户端数据之前，让程序睡眠5秒，表示我们这个业务需要处理5秒才能完成，然后我们通过浏览器测试一下这个服务端。服务端代码如下：

package com.suncy.article.article2;

import org.springframework.boot.logging.java.SimpleFormatter;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.nio.charset.StandardCharsets;
import java.text.SimpleDateFormat;
import java.util.Date;


public class HttpTestServer {
    public static void main(String[] args) throws IOException, InterruptedException {
        //1、创建服务端Socket对象，绑定端口号。
        ServerSocket ss = new ServerSocket(8000);

        //2、服务端需要一直等待连接状态
        while (true) {

            //3、调用accept()方法来侦听端口号是否有连接请求，拿到与客户端通信的socket句柄，此接口会阻塞在这里，指到有客户端连接
            Socket s = ss.accept();

            //4、打印开始时间
            SimpleDateFormat sdt = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
            System.out.println("接收客户端连接世界：" + sdt.format(new Date()));

            //5、向服务端写入http协议数据
            OutputStream outputStream = s.getOutputStream();
            String httpData = "HTTP/1.1 200 OK\n" +
                    "Server: server" +
                    "Content-Type: text/html\n" +
                    "\r\n" +
                    "hello Client\n";

            //6、睡眠5秒
            Thread.sleep(5000);

            //7、打印结束时间
            outputStream.write(httpData.getBytes(StandardCharsets.UTF_8));

            //8.关闭socket流
            s.close();
            System.out.println("关闭客户端连接世界：" + sdt.format(new Date()));
        }
    }
}

我们同时打开两个浏览器页面，输入127.0.0.1:8000访问这个服务端， 然后我们查看一下服务端打印的日志：

image.png

我们发现竟然有4条请求信息，暂时先不管为什么有4条，但是我们可以看到这个时间是按顺序访问的，并不支持并发。

那么为什么只能顺序访问呢？

原因就在于我们编写的服务端程序，在while死循环中，是接收到一个客户端的连接在处理业务，但如果这个客户端连接不关闭的话，我们的代码就不可能再次走到Socket s = ss.accept()这个地方，就不能接收客户端的连接。

二、并发的socket服务端程序

为了能支持并发的任务处理，我们需要多线程的编程基础，现在我们重新修改一下这个服务端代码，主要修改地方就是将写入客户端的操作放入到线程当中去处理。

package com.suncy.article.article2;

import lombok.SneakyThrows;

import java.io.IOException;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.nio.charset.StandardCharsets;
import java.text.SimpleDateFormat;
import java.util.Date;

public class HttpMultithreadingServer {
    public static void main(String[] args) throws IOException, InterruptedException {
        //1、创建服务端Socket对象，绑定端口号。
        ServerSocket ss = new ServerSocket(8000);

        //2、服务端需要一直等待连接状态
        while (true) {

            //3、调用accept()方法来侦听端口号是否有连接请求，拿到与客户端通信的socket句柄，此接口会阻塞在这里，指到有客户端连接
            Socket s = ss.accept();

            //开启一个新的线程
            new Thread(new Runnable() {
                @SneakyThrows
                @Override
                public void run() {
                    //4、打印开始时间
                    SimpleDateFormat sdt = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
                    System.out.println("接收客户端连接世界：" + sdt.format(new Date()));

                    //5、向服务端写入http协议数据
                    OutputStream outputStream = s.getOutputStream();
                    String httpData = "HTTP/1.1 200 OK\n" +
                            "Server: server" +
                            "Content-Type: text/html\n" +
                            "\r\n" +
                            "hello Client\n";

                    //6、睡眠5秒
                    Thread.sleep(5000);

                    //7、打印结束时间
                    outputStream.write(httpData.getBytes(StandardCharsets.UTF_8));

                    //8.关闭socket流
                    s.close();
                    System.out.println("关闭客户端连接世界：" + sdt.format(new Date()));
                }
            }).start();
        }
    }
}

再次打开两个浏览器，输入127.0.0.1:8000访问，我们查询一下服务端的日志：

image.png

在同时接收到了客户端请求，并在5秒之后关闭了客户端的连接，但还有一个问题，那就是我们就在浏览器发了两条请求，那么为什么会有4次连接呢？
我们通过在浏览器中，右键检查，并打开network按钮，我们发现，浏览器还会存在一个favicon.ico的请求，这应该是浏览器自己的逻辑了，但是并不影响我们的测试结果

image.png

三、总结

通过增加多线程，我们就完成了简单的java并发处理socket的的方法。