stef_buwalda/pism
1
0
Fork 0
mirror of https://github.com/2OOP/pism.git synced 2026-02-05 03:14:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Multithreaded server implementation.

Browse Source
This commit is contained in:
Bas de Jong
2025-09-11 16:09:18 +02:00
parent bb0abe7937
commit 11556ad363
3 changed files with 22 additions and 39 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
src/main/java/org/toop/Main.java
View File

@@ -1,13 +1,11 @@
package org.toop; package org.toop;
import org.toop.eventbus.EventRegistry;
import org.toop.eventbus.Events; import org.toop.eventbus.Events;
import org.toop.eventbus.GlobalEventBus; import org.toop.eventbus.GlobalEventBus;
import org.toop.server.Server; import org.toop.server.Server;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.toop.server.ServerTask;
public class Main { public class Main {
private static final Logger logger = LogManager.getLogger(Main.class); private static final Logger logger = LogManager.getLogger(Main.class);
@@ -18,8 +16,7 @@ public class Main {
throw new RuntimeException("A event could not be initialized"); throw new RuntimeException("A event could not be initialized");
} }
Server server = new Server(Server.ServerBackend.LOCAL, "127.0.0.1", "5000"); Server.start("local", "127.0.0.1", "5001");
Window.start(); Window.start();
} }
@@ -29,17 +26,17 @@ public class Main {
*/ */
private static boolean initEvents() { private static boolean initEvents() {
try { try {
// GlobalEventBus.subscribeAndRegister(Events.ServerEvents.OnChangingServerBackend.class, e -> GlobalEventBus.subscribeAndRegister(Events.ServerEvents.OnChangingServerBackend.class, e ->
// logger.info("Changing server backend state to {}", e.backend()) logger.info("Changing server backend state to {}", e.backend())
// ); );
//
// GlobalEventBus.subscribeAndRegister(Events.ServerEvents.OnChangingServerIp.class, e -> GlobalEventBus.subscribeAndRegister(Events.ServerEvents.OnChangingServerIp.class, e ->
// logger.info("Changing server ip to {}", e.ip()) logger.info("Changing server ip to {}", e.ip())
// ); );
//
// GlobalEventBus.subscribeAndRegister(Events.ServerEvents.OnChangingServerPort.class, e -> GlobalEventBus.subscribeAndRegister(Events.ServerEvents.OnChangingServerPort.class, e ->
// logger.info("Changing server port to {}", e.port()) logger.info("Changing server port to {}", e.port())
// ); );
return true; return true;
} }

12
src/main/java/org/toop/server/Server.java
View File

@@ -168,10 +168,18 @@ public class Server extends Thread {
public void run() { public void run() {
while (true) { while (true) {
// logger.info(server.getIp()); logger.info("Ik ben Bas, hallo");
logger.info(this.isAlive()); try {
sleep(1000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
} }
} }
}
public static void start(String backend, String ip, String port) {
new Server(ServerBackend.valueOf(backend.toUpperCase()), ip, port).start();
}
} }

22
src/main/java/org/toop/server/ServerTask.java
View File

@@ -1,22 +0,0 @@
package org.toop.server;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.toop.Main;
public class ServerTask extends Thread {
private static final Logger logger = LogManager.getLogger(Main.class);
Server server;
public ServerTask(Server server) {
this.server = server;
}
public void run() {
while (true) {
// logger.info(server.getIp());
logger.info(this.isAlive());
}
}
}