package com.lyms.etl.socket;


import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class ServerThread implements Runnable {

    public Socket socket;

    public ServerThread (Socket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        try {
            BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            while (true) {
                if (socket.getKeepAlive())
                {
                    System.out.println(SocketService.socketList.size());
                    System.out.println("关闭"+socket.getPort());
                }
                String str = br.readLine();
                System.out.println("接收到"+socket.getPort()+"消息:"+str);
                for (Socket item : SocketService.socketList) {
                    if (item.getPort() == socket.getPort())
                    {
                        PrintWriter pw = new PrintWriter(item.getOutputStream());
                        pw.println("服务器说："+str);
                        pw.flush();
                    }

                }
            }
        } catch (IOException e) {
            System.out.println(socket.getPort());
        }
    }

}