package org.jeecg.modules.dry.socket;

import lombok.extern.slf4j.Slf4j;
import org.checkerframework.checker.units.qual.C;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

@Slf4j
public class SocketServerConfig {
    public static ServerSocket serverSocket = null;

    public static ConcurrentHashMap<String, Socket> clientMap = new ConcurrentHashMap<>();


    private static final ThreadPoolExecutor threadpool = new ThreadPoolExecutor(15, 15,
            10L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());

    public void createSocket() {

            new Thread(() -> {
                try {
                    serverSocket = new ServerSocket(1115);
                    log.info("开启socket监听，端口：1115");
                    while (true) {
                        Socket socket = serverSocket.accept();
                        clientMap.put(socket.getRemoteSocketAddress().toString(), socket);
                        log.info("接收到客户端连接:" + socket.getRemoteSocketAddress());
                        threadpool.execute(new ServerReceiveThread(socket));
                    }
                }catch (IOException e) {
                    log.error("socket服务启动异常");
                    e.printStackTrace();
                }
            }).start();

    }
}