服务器runnable

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