Question

使用java socket怎么能够实现将一个客户端发送到服务端的消息转发到另一个客户端?

Answer 1

public class TCPlient {
public static void main(String[] args) {
String str = null;
Socket clientSocket; // 创建客户端套接字
DataInputStream in = null; // 创建DataInputStream对象
DataOutputStream out = null; // 创建DataOutputStream对象
try {
clientSocket = new Socket("127.0.0.1", 4331); // 实例化Socket对象
//clientSocket = new Socket("192.168.152.139", 6379);
in = new DataInputStream(clientSocket.getInputStream()); // 实例化DataInputStream对象
// 实例化DataOutputStream对象
out = new DataOutputStream(clientSocket.getOutputStream());
out.writeUTF("你好！！"); // 写数据
while (true) {
str = in.readUTF(); // 读取流中数据
out.writeUTF(((int) (Math.random() * 10) + 1) + ""); // 向流中写入0到10之间的随机数
System.out.println("客户端收到：" + str); // 输出信息
Thread.sleep(1000); // 线程休眠
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
public class TCPServer {
public static void main(String[] args) {
ServerSocket serverSocket = null; // 创建服务器端套接字
Socket clientSocket = null; // 创建客户端套接字
String str = null;
DataOutputStream out = null; // 创建DataOutputStream类对象
DataInputStream in = null; // 创建DataInputStream类对象
try {
serverSocket = new ServerSocket(4331); // 实例化ServerSocket对象
clientSocket = serverSocket.accept(); // 接收客户的套接字连接呼叫
in = new DataInputStream(clientSocket.getInputStream()); // 实例化DataInputStream对象
out = new DataOutputStream(clientSocket.getOutputStream()); // 实例化DataOutputStream对象
while (true) {
str = in.readUTF(); // 读取客户放入连接中的信息
out.writeUTF("hello，我是服务器"); // 通过输出流向线路中写信息
out.writeUTF(str);
System.out.println("服务器收到：" + str);
Thread.sleep(1000); // 线程休眠
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
//要发到另一个client，就让server转发消息就行。

Answer 2

用一个集合记住所有客户的Socket，收到数据包，就根据收发要求，转发