moin, mein Textchat funktioniert nur halb, also, wenn ich einen Client sich in den Server einwählen lasse, funktioniert das ganze bei der ersten Nachricht, aber dann nicht mehr.
Danke für eure hilfe
Java:
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.Iterator;
public class Server {
private int port;
private ServerSocket server;
private ArrayList<PrintWriter> clientWriterList;
public Server() {
this(5555);
}
public Server(int port) {
this.port = port;
}
public static void main(String[] args) {
Server s = new Server();
if(s.runServer()) {
s.listenToClients();
} else {
System.out.println("Fehler!");
}
}
private class Handler implements Runnable {
Socket client;
BufferedReader reader;
public Handler(Socket client) {
try {
this.client = client;
reader = new BufferedReader(new InputStreamReader(client.getInputStream()));
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
@Override
public void run() {
String message;
try {
while((message = reader.readLine()) != null) {
System.out.println(message);
sendToAllClients(message);
message ="";
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
private boolean runServer() {
try {
server = new ServerSocket(port);
System.out.println("Server wurde gestartet!");
clientWriterList = new ArrayList<PrintWriter>();
return true;
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
return false;
}
}
private void listenToClients() {
while(true) {
try {
Socket client = server.accept();
PrintWriter writer = new PrintWriter(client.getOutputStream());
clientWriterList.add(writer);
Thread clientThread = new Thread(new Handler(client));
clientThread.start();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
private void sendToAllClients(String message) {
Iterator it = clientWriterList.iterator();
while(it.hasNext()) {
PrintWriter writer = (PrintWriter) it.next();
writer.println(message);
writer.flush();
}
}
}
Java:
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;
public class Client {
private String address;
private int port;
private Socket client;
private PrintWriter writer;
private BufferedReader reader;
public Client() {
this("localhost", 5555);
}
public Client(String address, int port) {
this.address = address;
this.port = port;
}
public static void main(String[] args) {
Client c = new Client();
c.start();
}
public class MessagesFromServerListener implements Runnable {
@Override
public void run() {
String message;
try {
while((message = reader.readLine()) != null ) {
System.out.println(message);
}
} catch (IOException e) {
System.out.println("Nachricht konnte nicht empfangen werden");
e.printStackTrace();
}
}
}
private void start() {
if(!connectedToServer()) {
System.out.println("Nicht verbunden!");
}
Scanner sc = new Scanner(System.in);
sendMessageToServer(new Scanner(System.in).nextLine());
Thread t = new Thread(new MessagesFromServerListener());
t.start();
}
private boolean connectedToServer() {
try {
client = new Socket(address, port);
reader = new BufferedReader(new InputStreamReader(client.getInputStream()));
writer = new PrintWriter(client.getOutputStream());
System.out.println("Verbindung hergestellt");
return true;
} catch (IOException e) {
System.out.println("Verbindung fehlgeschlagen");
e.printStackTrace();
return false;
}
}
private void sendMessageToServer(String message) {
writer.println(message);
writer.flush();
}
}