無法向所有客戶端發送消息Java

Question

我正在使用A服務器，它可以接收來自所有客戶端的消息並將它們發送給其他人。我可以收到消息，但我無法向所有客戶端發送消息，儘管我從所有客戶端獲得正確的消息流。

這是我的代碼 如果你想測試，請在cmd - >遠程登錄本地主機端口號

import java.io.*; 
import java.util.*; 
import java.net.*; 

public class Server 
{ 

    private ServerSocket s; 
    private Hashtable saveOutputStreams = new Hashtable(500,80); 

    //Constructor 
    public Server(int port) throws IOException 
    { 
     listen(port); 
    } 
    //Listen method 
    public void listen(int port) throws IOException 
    { 
     s = new ServerSocket(port); 

     while(true) 
     { 
      Socket incoming = s.accept(); 

      OutputStream sout = incoming.getOutputStream(); 

      saveOutputStreams.put(incoming, sout); 
      Runnable r = new ThreadHandler(this,incoming); 
      Thread t = new Thread(r); 
      t.start(); 
     } 
    } 
    // Create a table of streams to process in for loop of senToAll method 
    Enumeration getOutputStreams() 
    { 
     return saveOutputStreams.elements(); 
    } 
    // Send message to all clients 
    public void sendToAll(String message) 
    { 
     synchronized(saveOutputStreams) 
     { 
      for(Enumeration e = getOutputStreams();e.hasMoreElements();) 
      { 

       OutputStream getOut = (OutputStream)e.nextElement(); 
       PrintWriter outp = new PrintWriter(getOut); 

       try 
       { 
        outp.println("sent"+ message); 
        System.out.println("Stream: "+getOut); 
        System.out.println("PrinWriter "+outp); 

       } 
       catch(Exception ie) 
       { 
        ie.printStackTrace(); 
        System.out.println("Error"); 
       } 

       finally 
       { 
        System.out.println("done sen To All"); 
       } 
      } 
     } 
    } 
    // Main 
    public static void main(String []args) throws IOException 
    { 
     new Server(8015); 
    } 
} 

class ThreadHandler implements Runnable 
{ 
    private Socket incoming; 
    private Server serverP; 

    public ThreadHandler(Server server, Socket socket) 
    { 
     serverP = server; 
     incoming = socket; 
    } 

    public synchronized void run() 
    { 
     try 
     { 
      try 
      { 

       InputStream inStream = incoming.getInputStream(); 
       OutputStream outStream = incoming.getOutputStream(); 

       Scanner in = new Scanner(inStream); 
       PrintWriter out = new PrintWriter(outStream,true); 

       out.println("TungAnh'Server"); 
       String message = in.nextLine(); 
       serverP.sendToAll(message); 

       out.println("receieve: "+message); 
       out.println("done"); 
       System.out.println("current Stream: "+ outStream); 
       System.out.println("PrinWriter "+ out); 

      } 
      finally 
      { 
       incoming.close(); 
      } 
     } 
     catch(IOException e) 
     { 
      e.printStackTrace(); 
     } 
    } 
} 

Answer 1

我提高你的代碼一點點：

1. 奇怪的日誌刪除
2. 新增實例管理
3. 添加了一些流關閉
4. ...

如果你要使用我的代碼，你應該看看同步（我的方法是同步的，但它們應該與同一個鎖定對象/類同步）和異常處理。我無法在這個問題上花更多時間，對此抱歉。

結果（對我的作品）：

package test; 

import java.io.IOException; 
import java.io.InputStream; 
import java.io.OutputStream; 
import java.io.PrintWriter; 
import java.net.ServerSocket; 
import java.net.Socket; 
import java.util.ArrayList; 
import java.util.List; 
import java.util.Scanner; 

public class Server 
{ 

    private ServerSocket s; 

    //Constructor 
    public Server(int port) throws IOException 
    { 
     listen(port); 
    } 
    //Listen method 
    public void listen(int port) throws IOException 
    { 
     s = new ServerSocket(port); 

     while(true) 
     { 
      Socket incoming = s.accept(); 
      Runnable r = new ThreadHandler(this,incoming); 
      Thread t = new Thread(r); 
      t.start(); 
     } 
    } 

    // Main 
    public static void main(String []args) throws IOException 
    { 
     new Server(8015); 
    } 
} 

class ThreadHandler implements Runnable 
{ 
    private Socket incoming; 

    private static List<ThreadHandler> instances = new ArrayList<ThreadHandler>(); 

    public synchronized void addInstance() { 
     instances.add(this); 
    } 

    public synchronized void removeInstance() { 
     instances.remove(this); 
    } 

    public ThreadHandler(Server server, Socket socket) 
    { 
     incoming = socket; 
     addInstance(); 
    } 

    public synchronized void sendToAll(String msg, ThreadHandler me) { 
     for (ThreadHandler h : instances) { 
      if (h == me) continue; 

      OutputStream outStream = null; 
      PrintWriter print = null; 
      try { 
       outStream = h.incoming.getOutputStream(); 
       print = new PrintWriter(outStream); 
       print.println(msg); 
       print.flush(); 
      } catch (IOException e) { 
       // TODO Auto-generated catch block 
       e.printStackTrace(); 
      } 
     } 
    } 

    public synchronized void run() 
    { 
     try 
     { 
      try 
      { 

       InputStream inStream = incoming.getInputStream(); 
       OutputStream outStream = incoming.getOutputStream(); 

       Scanner in = null; 
       try { 
        in = new Scanner(inStream); 

        PrintWriter out = new PrintWriter(outStream,true); 

        out.println("Vojta's Server"); 

        while (true) { 
         try { 
          String message = in.nextLine(); 
          sendToAll(message, this); 
         } catch (Exception e) { 

         } 

        } 


       } catch (Exception e) { 

       } 
       finally { 
        if (in != null) { 
         in.close(); 
        } 
       } 
      } 
      finally 
      { 
       incoming.close(); 
      } 
     } 
     catch(IOException e) 
     { 
      e.printStackTrace(); 
     } finally { 
      removeInstance(); 
     } 
    } 
}