KleinerServer() throws IOException {
while(true) {
Socket client = server.accept();
ServerSendingThread sst = new ServerSendingThread(client);
sst.start();
}
}public void run(){
try{
System.out.println("Neue Verbindung zu Client");
out = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
Scanner scanner = new Scanner(System.in);
while(!(msg = scanner.nextLine()).equalsIgnoreCase("end")) {
sendMessage(msg); // Methode nicht mit angegeben; ist selbsterklärend
} Client() throws IOException {
Socket server = new Socket ("localhost", 1234);
ClientReadingThread st = new ClientReadingThread(server);
st.start();
}public void run() {
try {
BufferedReader reader = new BufferedReader(new InputStreamReader(s.getInputStream()));
String msg;
while((msg=reader.readLine())!=null) {
System.out.println(msg)
}
}catch (IOException e) {}
}public class Server implements Runnable {
private List<ClientHandler> clients;
@Override
public void run() {
while (true) {
// Verbindungsanfragen annehmen
// ClientHandler = ...;
//clients.add(clientHandler);
}
}
public void sendMessageToAllClients(String text) {
for (ClientHandler client : clients) {
client.sendMessage(text);
}
}
}
