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("當(dāng)前讀取的數(shù)據(jù)：{}", 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返回?cái)?shù)據(jù)之前關(guān)閉，因?yàn)镮nputStream關(guān)閉之后會(huì)導(dǎo)致Socket關(guān)閉，你說奇怪不奇怪，這樣一來就不能正常返回?cái)?shù)據(jù)了，報(bào)錯(cuò)說Socket已經(jīng)關(guān)閉
                 */
                try (Socket s = ss.accept();
                     InputStream is = s.getInputStream();
                     OutputStream os = s.getOutputStream()) {
                    LOGGER.debug("等待請求...");
                    LOGGER.debug("新請求進(jìn)入");
                    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("即將返回?cái)?shù)據(jù)：{}", response.toString());
                    if (!s.isClosed()) {
                        LOGGER.debug("正在返回?cái)?shù)據(jù)");
                        os.write(response.toString().getBytes());
                        os.flush();
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}