我知道这个问题已经被问过,我尝试了不同的解决方案,但我被困在执行部分.. :(服务器发送消息到所有连接的客户端
目前多个客户端可以连接到服务器,我使用了javadocs的多线程KnockKnock服务器/客户端示例,并稍微编辑它,以便您可以将消息发送到服务器,并将其回显给您,但我希望能够使它如果客户端1发送消息,则服务器会将它们广播回所有连接到服务器的客户端。
我试过环顾四周,看到与我现在在同一位置的人,并且他们被告知做一个列表以跟踪所有连接,然后遍历列表并发送消息,但我真的不知道在哪个类中放置它或如何处理它。
如果有人能告诉我或者只是给我暗示的地方,我应该开始,这将不胜感激,因为我真的只是停留在那一刻:(
这里我也正是我在至今:
服务器:
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
public class Server {
public static void main(String[] args) throws IOException {
boolean listening = true;
try (ServerSocket serverSocket = new ServerSocket(4444)) {
while (listening) {
ServerThread thread = new ServerThread(serverSocket.accept());
thread.start();
}
} catch (IOException e) {
System.err.println("Could not listen on port ");
System.exit(-1);
}
}
}
ServerThread
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
public class ServerThread extends Thread{
private Socket socket = null;
public ServerThread(Socket socket) {
super("MultiServerThread");
this.socket = socket;
}
public void run() {
try (
PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
BufferedReader in = new BufferedReader(
new InputStreamReader(
socket.getInputStream()));
) {
while (true) {
String input = in.readLine();
System.out.println(input);
out.println("ecco " + input);
if (input.equals("Bye"))
break;
}
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
客户端(未确定是否有必要,但这里是它反正)
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
public class Client {
public static void main(String[] args) throws IOException {
try (
Socket kkSocket = new Socket("172.30.242.51", 4444);
PrintWriter out = new PrintWriter(kkSocket.getOutputStream(), true);
BufferedReader in = new BufferedReader(
new InputStreamReader(kkSocket.getInputStream()));
) {
BufferedReader stdIn =
new BufferedReader(new InputStreamReader(System.in));
while (true) {
if(in != null) {
String input = stdIn.readLine();
out.println("Client: " + input);
System.out.println(in.readLine());
out.flush();
}
}
} catch (UnknownHostException e) {
System.err.println("Don't know about host ");
System.exit(1);
} catch (IOException e) {
System.err.println("Couldn't get I/O for the connection to ");
System.exit(1);
}
}
}
周末愉快=)
很抱歉,但这个看起来很混乱,我:( –