Wenn Client postet, kommt auf den Server leider nicht. Was mache ich hier falsch?
Java:
import com.google.common.eventbus.EventBus;
import com.google.common.eventbus.Subscribe;
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
private ServerSocket serverSocket;
private Personal person;
private EventBus eventBus;
public Server(ServerSocket serverSocket) {
this.serverSocket = serverSocket;
this.eventBus = new EventBus();
this.eventBus.register(this);
}
public void serverStarted() {
try {
Socket socket = serverSocket.accept();
System.out.println("New Client has connected");
if (socket.isConnected()) {
System.out.println("Connected....");
}
} catch (IOException e) {
e.printStackTrace();
}
}
@Subscribe
public void print(Personal p) {
this.person = p;
}
public String toString() {
return this.person.getName();
}
public static void main(String[] args) {
try {
ServerSocket serverSocket = new ServerSocket(4444);
Server server = new Server(serverSocket);
server.serverStarted();
System.out.println(server.toString());
} catch (IOException e) {
e.printStackTrace();
}
}
}
public class Client {
private EventBus bus;
public static Personal person;
public Client(Socket socket) {
try {
this.bus = new EventBus();
this.bus.register(this);
} catch (IOException e) {
e.printStackTrace();
}
}
public void sendMessage(Personal personal) {
bus.post(personal);
}
public static void main(String[] main) {
try {
Socket socket = new Socket("Localhost", 4444);
Client client = new Client(socket);
client.sendMessage(new Personal("Test", 19, "Student"));
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
Zuletzt bearbeitet:
