diff --git a/severRunable.java b/severRunable.java new file mode 100644 index 0000000..3d61412 --- /dev/null +++ b/severRunable.java @@ -0,0 +1,38 @@ +import java.io.*; +import java.net.Socket; +import java.util.Properties; + +public class severRunable implements Runnable{ + Socket socket; + + public severRunable(Socket socket) { + this.socket = socket; + } + + public void run() { + try { + BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream())); + while(true){ + if(!sever.list.contains(socket)){ + sever.list.add(socket); + } + String message = br.readLine(); + System.out.println( "收到消息:" + message); + for (Socket s : sever.list) { + BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream())); + bw.write("收到消息:"+message); + bw.newLine(); + bw.flush(); + } + } + } catch (IOException e) { + e.printStackTrace(); + } + try { + socket.close(); + } catch (IOException e) { + throw new RuntimeException(e); + } + } + +}