如何从服务器向所有连接的客户端发送消息答案

【问题标题】：how to send message to all connected client from server如何从服务器向所有连接的客户端发送消息
【发布时间】：2013-08-13 01:23:15
【问题描述】：

我创建了一个android应用，其中android应用充当客户端，服务器驻留在桌面应用中。

假设有 10 个 android 应用程序同时在 10 个不同的 android 平板电脑上运行，当从一台平板电脑收到一个更新时，桌面应用程序会将更新发送到所有其他剩余的平板电脑。服务器如何知道连接了多少客户端以及如何将消息发送给所有客户端

我的计划是在所有 android 中运行一个服务器，这样当从一台平板电脑收到一个更新时，桌面应用程序会将更新发送到所有其他剩余的平板电脑。

谁能告诉我一些关于这个的建议。

客户端

private int SERVER_PORT = 9999;
class Client implements Runnable {
            private Socket client;
            private PrintWriter out;
            private Scanner in;

            @Override
            public void run() {
                try {
                    client = new Socket("localhost", SERVER_PORT);
                    Log.d("Client", "Connected to server at port " + SERVER_PORT);
                    out = new PrintWriter(client.getOutputStream());
                    in = new Scanner(client.getInputStream());
                    String line;

                    while ((line = in.nextLine()) != null) {
                        Log.d("Client", "Server says: " + line);
                        if (line.equals("Hello client")) {
                            out.println("Reply");
                            out.flush();
                        }
                    }

                } catch (UnknownHostException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }

        }

服务器类

class ServerThread implements Runnable {
        private ServerSocket server;

        @Override
        public void run() {
            try {
                server = new ServerSocket(SERVER_PORT);
                Log.d("Server", "Start the server at port " + SERVER_PORT
                        + " and waiting for clients...");
                while (true) {
                    Socket socket = server.accept();
                    Log.d("Server",
                            "Accept socket connection: "
                                    + socket.getLocalAddress());
                    new Thread(new ClientHandler(socket)).start();
                }
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }

    }

    class ClientHandler implements Runnable {

        private Socket clientSocket;
        private PrintWriter out;
        private Scanner in;

        public ClientHandler(Socket clietSocket) {
            this.clientSocket = clietSocket;
        }

        @Override
        public void run() {
            try {
                out = new PrintWriter(clientSocket.getOutputStream());
                in = new Scanner(clientSocket.getInputStream());
                String line;
                Log.d("ClientHandlerThread", "Start communication with : "
                        + clientSocket.getLocalAddress());
                out.println("Hello client");
                out.flush();
                while ((line = in.nextLine()) != null) {
                    Log.d("ClientHandlerThread", "Client says: " + line);
                    if (line.equals("Reply")){
                        out.print("Server replies");
                        out.flush();
                    }
                }
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }

        }

    }

【问题讨论】：

如果您正在编写生产应用程序，请使用 GCM 或某种 XMPP 消息传递。但是，您可以在没有 GCM 的情况下执行此操作，您需要将所有连接的客户端套接字记录在 List 中，然后遍历它以发送消息。为什么不也调查一下dreamincode.net/forums/topic/…

标签： android client-server client

【解决方案1】：

您可以将套接字保存在一个列表中，并通过该列表中的所有输出流发送消息：

Socket socket = Server.accept();
sockets.add(socket);  //sockets is an ArrayList<Socket>

public void sendMessageToEveryone(String msg) {
for(Socket s : sockets) {
  s.getOutputStream().write(msg.getBytes());
  s.getOutputStream().flush();
}

【讨论】：

【解决方案2】：

您可以使用 Google Cloud Messaging 服务。

看看这个页面： https://developer.android.com/google/gcm/index.html

【讨论】：

是否需要网络