5

我正在构建一个小型聊天应用程序，其中客户端 A 想要向客户端 C 发送一些东西，而服务器 B 介于两者之间。首先，这是解决问题的正确方法吗？我能够向服务器发送数据和从服务器接收数据，但仅限于客户端。例如，如果客户端 A 向服务器 B 发送数据，而客户端 C 向服务器 B 发送数据，那么我可以将数据发送回 A 和C 就像一个回声服务器。但我想要的是通过服务器 B 将来自客户端 A 的数据转发到客户端 C。

以下是服务器代码：

public class Server {
    public static void main(String[] args) {
        int port = 666; //random port number
        try {
            ServerSocket ss = new ServerSocket(port);
            System.out.println("Waiting for a client....");

            System.out.println("Got a client :) ... Finally, someone saw me through all the cover!");
            System.out.println();
            while(true) {
                Socket socket = ss.accept();

                SSocket sSocket = new SSocket(socket);
                Thread t = new Thread(sSocket);
                t.start();
                System.out.println("Socket Stack Size-----"+socketMap.size());
            }
        }
        catch (Exception e) { }
    }
}

class SSocket implements Runnable {
    private Socket socket;

    public SSocket(Socket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        try {
            InputStream in = socket.getInputStream();
            OutputStream out = socket.getOutputStream();

            DataInputStream dIn = new DataInputStream(in);
            DataOutputStream dOut = new DataOutputStream(out);

            String line = null;
            while (true) {
                line = dIn.readUTF();
                System.out.println("Recievd the line----" + line);
                dOut.writeUTF(line + " Comming back from the server");
                dOut.flush();
                System.out.println("waiting for the next line....");    
            }
        }
        catch (Exception e) { }
    }
}

客户端代码是：

public class Client {
    public static void main(String[] args) {
        int serverPort = 666;

        try {
            InetAddress inetAdd = InetAddress.getByName("127.0.0.1");
            Socket socket = new Socket(inetAdd, serverPort);

            InputStream in = socket.getInputStream();
            OutputStream out = socket.getOutputStream();

            DataInputStream dIn = new DataInputStream(in);
            DataOutputStream dOut = new DataOutputStream(out);

            BufferedReader keyboard = new BufferedReader(new InputStreamReader(System.in));

            System.out.println("Type in something and press enter. Will send it to the server and tell ya what it thinks.");
            System.out.println();

            String line = null;
            while (true) {
                line = keyboard.readLine();
                System.out.println("Wrinting Something on the server");
                dOut.writeUTF(line);
                dOut.flush();

                line = dIn.readUTF();
                System.out.println("Line Sent back by the server---" + line);
            }
        }
        catch (Exception e) { }
    }
}
4

3 回答 3

5

当您的客户端连接到服务器时，您的服务器会Socket为其创建一个，在这里Socket socket = ss.accept();，您的套接字变量将持有该客户端。

现在，如果您只是继续将您的客户端套接字添加到循环中，arraylist您while将拥有一个与您的服务器主动连接的客户端列表，例如：

接受后：

clients = new ArrayList<DataOutputStream>();
Socket socket = ss.accept();
os = new DataOutputStream(socket.getOutputStream());
clients.add(os);

现在，当您在该数组列表中拥有所有客户端时clients，您可以遍历它，或者使用某些协议定义我应该在读取后发送数据的客户端。

Iterator<DataOutputStream> it = clients.iterator();
while ((message = reader.readLine()) != null) { //reading    
    while (it.hasNext()) {
        try {
            DataOutputStream oss = it.next();
            oss.write(message);//writing
            oss.flush();
        }
        catch (Exception e) { }
     }
 }

这将遍历 arraylist 中所有可用的客户端，并将发送给所有客户端。您可以定义仅发送给某些人的方式。

例如：维护一个ActiveClients arraylist并与一些 GUI 交互可能是或可能，定义您要向所有客户端发送什么消息。然后将那些客户端 outputStreams 添加到ActiveClients

ActiveClients.add(clients.get(2));

或删除它们，如果你不想要它们。

ActiveClients.remove(clients.get(2));

现在只需循环通过它arraylist来发送如上所述的数据。

于 2012-04-26T12:07:26.700 回答
1

您可以为每个客户端创建消息队列：

  1. Client C客户端 A 向服务器 B发送带有地址的消息“Hi” 。
  2. 服务器 B 接收到消息并将其添加到客户端 C 的消息队列中。
  3. 与客户端 C 通信的服务器 B 中的线程检查消息队列，检索消息并将其发送给客户端 C。
  4. 客户端 C 收到消息。
于 2012-04-26T11:56:49.550 回答
0

如果我没记错的话，您一定是在接收来自 Server 或 SSocket 类的消息时遇到问题。您的代码发生的情况是，当您从客户端向服务器发送消息时，Server 类接收您的消息也会在客户端中给出消息的回显。但是，当您从服务器类发送消息时，您不会在客户端类中收到任何消息。

要使其正常工作，您必须按以下方式修改代码：

SSocket 类

String line = null;
while (true) {
    line = dIn.readUTF();
    System.out.println("Recievd the line----" + line);
    dOut.writeUTF(line + " Comming back from the server");
    dOut.flush();
    System.out.println("waiting for the next line....");
}

您应该添加这些行：

String Line2 = take.nextLine(); //The user types a message for the client
dOut.writeUTF(Line2 + " Comming back from the server"); //The message is sent to the client

用这个替换while循环，它将正常工作。

while (true) {       
    line = dIn.readUTF(); //Takes the msg from the client
    System.out.println("Recievd the line----" + line); //Prints the taken message

    String Line2 = take.nextLine(); //The user types a message for the client
    dOut.writeUTF(Line2 + " Comming back from the server"); //The message is sent to the client
    dOut.flush();
    System.out.println("waiting for the next line....");
}
于 2014-11-11T22:44:45.217 回答