socket编程时的发送与接收数据时的问题解析

package com.zoro.example.subscribe.queue;
import com.zoro.util.SendUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketAddress;
/**
* @author zoro
* @version 1.0
*/
public class TestSubscribeQueue {
    private static final Logger LOGGER = LoggerFactory.getLogger(TestSubscribeQueue.class);
    public static void main(String[] args) throws IOException {
        new Thread(new EventListener()).start();
    }
    private static String test(InputStream is) {
        BufferedReader br = null;
        InputStreamReader isr = null;
        StringBuilder sb = new StringBuilder();
        isr = new InputStreamReader(is);
        br = new BufferedReader(isr);
        String line = null;
        while (true) {
            try {
                line = br.readLine();
                if (line == null || line.length() == 0) {
                    break;
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
            sb.append(line);
            sb.append("\n");
            line = null;
            LOGGER.debug("当前读取的数据：{}", sb.toString());
        }
        return sb.toString();
    }
    static class EventListener implements Runnable {
        private final ServerSocket ss;
        public EventListener() throws IOException {
            ss = new ServerSocket(8087);
        }
        @Override
        public void run() {
            while (true) {
                /*
                这里得到的InputStream 不能在OutputStream返回数据之前关闭，因为InputStream关闭之后会导致Socket关闭，你说奇怪不奇怪，这样一来就不能正常返回数据了，报错说Socket已经关闭
                 */
                try (Socket s = ss.accept();
                     InputStream is = s.getInputStream();
                     OutputStream os = s.getOutputStream()) {
                    LOGGER.debug("等待请求...");
                    LOGGER.debug("新请求进入");
                    if (s.isClosed() || !s.isConnected() || s.isInputShutdown()) {
                        continue;
                    }
//                    String result = SendUtil.resolveInputStream(is);
                    String result = test(is);
                    LOGGER.debug("收到请求：{}", result);
                    StringBuilder response = new StringBuilder();
                    response.append("HTTP/1.1 200 OK\r\n");
                    response.append("Content-Type:text/html\r\n");
                    response.append("\r\n");
                    response.append("123252321");
                    LOGGER.debug("即将返回数据：{}", response.toString());
                    if (!s.isClosed()) {
                        LOGGER.debug("正在返回数据");
                        os.write(response.toString().getBytes());
                        os.flush();
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}