java одно-одно сообщение широковещательный сокет

Question

Я пытаюсь реализовать эту программу сокетов, которая передает широковещательные сообщения всем подключенным клиентам. То, что я пытаюсь сделать, - это широковещательное сообщение конкретному клиенту. Я пытался изменить

/** Передача данного текста всем клиентам. */ раздел.

Но, не мог избавиться от него. Может ли кто-нибудь предложить лучшее решение для этого.

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

public class ChatServer { 

    private static final String USAGE = "Usage: java ChatServer"; 

    /** Default port number on which this server to be run. */ 
    private static final int PORT_NUMBER = 8008; 

    /** List of print writers associated with current clients, 
    * one for each. */ 
    private List<PrintWriter> clients; 

    /** Creates a new server. */ 
    public ChatServer() { 
     clients = new LinkedList<PrintWriter>(); 
    } 

    /** Starts the server. */ 
    public void start() { 
     System.out.println("AndyChat server started on port " 
          + PORT_NUMBER + "!"); 
     try { 
      ServerSocket s = new ServerSocket(PORT_NUMBER); 
      for (;;) { 
       Socket incoming = s.accept(); 
       new ClientHandler(incoming).start(); 
      } 
     } catch (Exception e) { 
      e.printStackTrace(); 
     } 
     System.out.println("AndyChat server stopped."); 
    } 

    /** Adds a new client identified by the given print writer. */ 
    private void addClient(PrintWriter out) { 
     synchronized(clients) { 
      clients.add(out); 
     } 
    } 

    /** Adds the client with given print writer. */ 
    private void removeClient(PrintWriter out) { 
     synchronized(clients) { 
      clients.remove(out); 
     } 
    } 

    /** Broadcasts the given text to all clients. */ 
    private void broadcast(String msg) { 
     for (PrintWriter out: clients) { 
      out.println(msg); 
      out.flush(); 
     } 
    } 

    public static void main(String[] args) { 
     if (args.length > 0) { 
      System.out.println(USAGE); 
      System.exit(-1); 
     } 
     new ChatServer().start(); 
    } 

    /** A thread to serve a client. This class receive messages from a 
    * client and broadcasts them to all clients including the message 
    * sender. */ 
    private class ClientHandler extends Thread { 

     /** Socket to read client messages. */ 
     private Socket incoming; 

     /** Creates a hander to serve the client on the given socket. */ 
     public ClientHandler(Socket incoming) { 
      this.incoming = incoming; 
     } 

     /** Starts receiving and broadcasting messages. */ 
     public void run() { 
      PrintWriter out = null; 
      try { 
       out = new PrintWriter(
         new OutputStreamWriter(incoming.getOutputStream())); 

       // inform the server of this new client 
       ChatServer.this.addClient(out); 

       out.print("G G Connect! "); 
       out.flush(); 

       BufferedReader in 
        = new BufferedReader(
         new InputStreamReader(incoming.getInputStream())); 
       for (;;) { 
        String msg = in.readLine(); 
        if (msg == null) { 
         break; 
        } else { 
         if (msg.trim().equals("BYE")) 
          break; 
         System.out.println("Received: " + msg); 
         // broadcast the receive message 
         ChatServer.this.broadcast(msg); 
        } 
       } 
       incoming.close(); 
       ChatServer.this.removeClient(out); 
      } catch (Exception e) { 
       if (out != null) { 
        ChatServer.this.removeClient(out); 
       } 
       e.printStackTrace(); 
      } 
     } 
    } 
} 

Answer 1

Вещание означает отправку его всем. Когда вы говорите «трансляция одному человеку», вы имеете в виду, что хотите просто отправить сообщение одному клиенту?

Если это так, то вам нужно получить PrintWriter для этого клиента, и отправить сообщение через этот объект:

private void sendMessage(PrintWriter client, String msg) { 
    client.println(msg); 
    client.flush(); 
} 

Кстати, вместо использования:

for (;;) { 
} 

Вы следует использовать:

while (true) { 
} 

Легче признать бесконечным циклом.

О, и не нужно писать ChatServer.this в ChatServer.this.broadcast(msg);. Вы можете вызвать широковещательное сообщение, просто набрав broadcast(msg):.