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());
}
}
}