package com.lyms.etl.socket;

import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.CopyOnWriteArrayList;

/**
 * Created by Administrator on 2020-06-15.
 */
public class SocketService {
    public static CopyOnWriteArrayList<Socket> socketList = new CopyOnWriteArrayList<>();

    public static void main(String args[])throws Exception {
        ServerSocket serverSocket = new ServerSocket(5208);
        System.out.println("聊天室开启");
        while (true) {
            Socket socket= serverSocket.accept();
            System.out.println("上线通知： 用户" + socket.getPort() + "上线啦！");
            socketList.add(socket);
            new Thread(new ServerThread(socket)).start();
        }
    }

}