Extracts a ServerHandler from the Server class to reduce complexity

This commit is contained in:
Kristian Knarvik 2021-08-21 13:43:27 +02:00
parent cd396eee6b
commit 44d8d6ee6b
8 changed files with 212 additions and 144 deletions

View File

@ -2,7 +2,7 @@ package net.knarcraft.minecraftserverlauncher;
import net.knarcraft.minecraftserverlauncher.profile.Collection; import net.knarcraft.minecraftserverlauncher.profile.Collection;
import net.knarcraft.minecraftserverlauncher.profile.ServerLauncherController; import net.knarcraft.minecraftserverlauncher.profile.ServerLauncherController;
import net.knarcraft.minecraftserverlauncher.server.Server; import net.knarcraft.minecraftserverlauncher.server.ServerHandler;
import net.knarcraft.minecraftserverlauncher.userinterface.ServerConsoles; import net.knarcraft.minecraftserverlauncher.userinterface.ServerConsoles;
import net.knarcraft.minecraftserverlauncher.userinterface.ServerLauncherGUI; import net.knarcraft.minecraftserverlauncher.userinterface.ServerLauncherGUI;
import net.knarcraft.minecraftserverlauncher.utility.CommonFunctions; import net.knarcraft.minecraftserverlauncher.utility.CommonFunctions;
@ -88,7 +88,7 @@ public class Main {
boolean runningNew = serversRunning(); boolean runningNew = serversRunning();
if (serversAreRunning && !runningNew) { if (serversAreRunning && !runningNew) {
//Servers stopped running //Servers stopped running
Server.serversStopped(); ServerHandler.serversStopped();
gui.updateGUIElementsWhenServersStartOrStop(false); gui.updateGUIElementsWhenServersStartOrStop(false);
gui.setStatus("Servers are stopped"); gui.setStatus("Servers are stopped");
} else if (!serversAreRunning && runningNew) { } else if (!serversAreRunning && runningNew) {

View File

@ -2,6 +2,7 @@ package net.knarcraft.minecraftserverlauncher.profile;
import net.knarcraft.minecraftserverlauncher.Main; import net.knarcraft.minecraftserverlauncher.Main;
import net.knarcraft.minecraftserverlauncher.server.Server; import net.knarcraft.minecraftserverlauncher.server.Server;
import net.knarcraft.minecraftserverlauncher.server.ServerHandler;
import net.knarcraft.minecraftserverlauncher.userinterface.ServerConsoles; import net.knarcraft.minecraftserverlauncher.userinterface.ServerConsoles;
import net.knarcraft.minecraftserverlauncher.userinterface.ServerLauncherGUI; import net.knarcraft.minecraftserverlauncher.userinterface.ServerLauncherGUI;
import net.knarcraft.minecraftserverlauncher.utility.CommonFunctions; import net.knarcraft.minecraftserverlauncher.utility.CommonFunctions;
@ -239,10 +240,10 @@ public class Profile {
if (data[1].contains("!")) { if (data[1].contains("!")) {
String[] servers = data[1].split("!", -1); String[] servers = data[1].split("!", -1);
for (String server : servers) { for (String server : servers) {
profile.collections.add(new Collection(Server.fromString(server))); profile.collections.add(new Collection(ServerHandler.fromString(server)));
} }
} else { } else {
profile.collections.add(new Collection(Server.fromString(data[1]))); profile.collections.add(new Collection(ServerHandler.fromString(data[1])));
} }
} else { } else {
profile = parseProfile(profileString.split(";", -1)); profile = parseProfile(profileString.split(";", -1));

View File

@ -2,6 +2,7 @@ package net.knarcraft.minecraftserverlauncher.profile;
import net.knarcraft.minecraftserverlauncher.Main; import net.knarcraft.minecraftserverlauncher.Main;
import net.knarcraft.minecraftserverlauncher.server.Server; import net.knarcraft.minecraftserverlauncher.server.Server;
import net.knarcraft.minecraftserverlauncher.server.ServerHandler;
import net.knarcraft.minecraftserverlauncher.server.ServerTypeHandler; import net.knarcraft.minecraftserverlauncher.server.ServerTypeHandler;
import net.knarcraft.minecraftserverlauncher.userinterface.ServerLauncherGUI; import net.knarcraft.minecraftserverlauncher.userinterface.ServerLauncherGUI;
import net.knarcraft.minecraftserverlauncher.userinterface.ServerTab; import net.knarcraft.minecraftserverlauncher.userinterface.ServerTab;
@ -392,7 +393,7 @@ public class ServerLauncherController {
}); });
} }
if (this.currentProfile.getRunInBackground()) { if (this.currentProfile.getRunInBackground()) {
Executors.newSingleThreadExecutor().execute(Server::startServers); Executors.newSingleThreadExecutor().execute(ServerHandler::startServers);
this.serverLauncherGUI.hideToTray(); this.serverLauncherGUI.hideToTray();
} }
} }

View File

@ -1,9 +1,9 @@
package net.knarcraft.minecraftserverlauncher.server; package net.knarcraft.minecraftserverlauncher.server;
import net.knarcraft.minecraftserverlauncher.Main; import net.knarcraft.minecraftserverlauncher.Main;
import net.knarcraft.minecraftserverlauncher.profile.Collection;
import net.knarcraft.minecraftserverlauncher.profile.ServerLauncherController; import net.knarcraft.minecraftserverlauncher.profile.ServerLauncherController;
import net.knarcraft.minecraftserverlauncher.server.servertypes.ServerType; import net.knarcraft.minecraftserverlauncher.server.servertypes.ServerType;
import net.knarcraft.minecraftserverlauncher.userinterface.ServerLauncherGUI;
import net.knarcraft.minecraftserverlauncher.utility.CommonFunctions; import net.knarcraft.minecraftserverlauncher.utility.CommonFunctions;
import javax.naming.ConfigurationException; import javax.naming.ConfigurationException;
@ -31,14 +31,9 @@ import java.util.regex.Pattern;
* @since 1.0.0 * @since 1.0.0
*/ */
public class Server { public class Server {
/**
* Available ram sizes. For ServerLauncherGUI combo
*/
private static final String[] ramList = {"512M", "1G", "2G", "3G", "4G", "5G", "6G", "7G", "8G", "9G", "10G",
"11G", "12G", "13G", "14G", "15G", "16G"};
private static final String jarDirectory = Main.getApplicationWorkDirectory() + File.separator + "files" + private static final String jarDirectory = Main.getApplicationWorkDirectory() + File.separator + "files" +
File.separator + "Jars" + File.separator; File.separator + "Jars" + File.separator;
private final String name; private final String name;
private final ArrayList<String> playerList; private final ArrayList<String> playerList;
private String path; private String path;
@ -51,7 +46,7 @@ public class Server {
private BufferedReader reader; private BufferedReader reader;
private boolean started; private boolean started;
private ScheduledExecutorService consoleOutputExecutor; private ScheduledExecutorService consoleOutputExecutor;
private static boolean stoppingServers = false; private final ServerLauncherGUI gui = Main.getController().getGUI();
/** /**
* Initializes a new server with default values * Initializes a new server with default values
@ -65,7 +60,7 @@ public class Server {
this.playerList = new ArrayList<>(); this.playerList = new ArrayList<>();
this.type = null; this.type = null;
this.serverVersion = ""; this.serverVersion = "";
this.maxRam = ramList[0]; this.maxRam = ServerHandler.getRamList()[0];
this.process = null; this.process = null;
this.writer = null; this.writer = null;
this.reader = null; this.reader = null;
@ -91,15 +86,6 @@ public class Server {
this.playerList = new ArrayList<>(); this.playerList = new ArrayList<>();
} }
/**
* Gets the list of available RAM choices allowed
*
* @return <p>All available RAM choices</p>
*/
public static String[] getRamList() {
return ramList;
}
/** /**
* Gets the buffered reader used to read from this server * Gets the buffered reader used to read from this server
* *
@ -109,101 +95,6 @@ public class Server {
return this.reader; return this.reader;
} }
/**
* Marks the servers as finished stopping when a stop is confirmed
*/
public static void serversStopped() {
if (stoppingServers) {
stoppingServers = false;
}
}
/**
* Tries to stop all enabled servers
*
* @throws IOException <p>If a writer's process is already closed but not null</p>
*/
public static void stop() throws IOException, InterruptedException {
if (stoppingServers) {
killServers();
return;
}
stoppingServers = true;
for (Collection collection : Main.getController().getCurrentProfile().getCollections()) {
Server server = collection.getServer();
if (server.writer != null) {
if (server.type.isProxy()) {
server.writer.write("end\n");
} else {
server.writer.write("stop\n");
}
server.writer.flush();
server.writer = null;
server.started = false;
}
}
}
/**
* Kills all server processes
*
* @throws InterruptedException <p>If interrupted waiting for any of the servers to stop</p>
*/
private static void killServers() throws InterruptedException {
for (Collection collection : Main.getController().getCurrentProfile().getCollections()) {
Server server = collection.getServer();
killServer(server);
}
}
/**
* Kills the given server after waiting 30 seconds for it to terminate normally
*
* @param server <p>The server to kill</p>
* @throws InterruptedException <p>If interrupted waiting for the server to stop</p>
*/
private static void killServer(Server server) throws InterruptedException {
if (server.process != null) {
if (!server.process.waitFor(30, TimeUnit.SECONDS)) {
server.process.destroyForcibly();
server.process.waitFor();
}
}
}
/**
* Runs all enabled servers with their settings
*/
public static void startServers() {
ServerLauncherController controller = Main.getController();
controller.getGUI().setStatus("Starting servers");
int serverNum = 0;
for (Collection collection : controller.getCurrentProfile().getCollections()) {
if (!collection.getServer().runServer(serverNum++ == 0)) {
controller.getGUI().showError("An error occurred. Start aborted. Please check the BuildTools log.");
try {
Server.stop();
} catch (IOException | InterruptedException e) {
e.printStackTrace();
}
controller.getGUI().updateGUIElementsWhenServersStartOrStop(false);
return;
}
}
}
/**
* Gets a server object from a server save string
*
* @param saveString <p>The string containing necessary data regarding the server</p>
* @return <p>A server in the same state it was saved in</p>
*/
public static Server fromString(String saveString) throws ConfigurationException {
String[] data = saveString.split(";");
return new Server(data[0], data[1], Boolean.parseBoolean(data[2]), data[3], data[4], data[5]);
}
/** /**
* Gets the name of the server * Gets the name of the server
* *
@ -269,6 +160,42 @@ public class Server {
} }
} }
/**
* Gets whether this server is a proxy server
*
* <p>A proxy server is a server running BungeeCord, Waterfall or Travertine.</p>
*
* @return <p>True if this server is a proxy server</p>
*/
public boolean isProxy() {
return this.type.isProxy();
}
/**
* Marks this server as stopped
*/
public void setStopped() {
this.started = false;
}
/**
* Gets the writer used to write to this server
*
* @return <p>The writer used.</p>
*/
public BufferedWriter getWriter() {
return this.writer;
}
/**
* Sets the writer used to write to this server
*
* @param writer <p>The new writer to use.</p>
*/
public void setWriter(BufferedWriter writer) {
this.writer = writer;
}
/** /**
* Gets the path for this server's files * Gets the path for this server's files
* *
@ -374,7 +301,7 @@ public class Server {
*/ */
private void addPlayer(String name) { private void addPlayer(String name) {
this.playerList.add(name); this.playerList.add(name);
Main.getController().getGUI().getServerControlTab().addPlayer(name); gui.getServerControlTab().addPlayer(name);
} }
/** /**
@ -384,7 +311,7 @@ public class Server {
*/ */
private void removePlayer(String name) { private void removePlayer(String name) {
playerList.removeIf(player -> player.equals(name)); playerList.removeIf(player -> player.equals(name));
Main.getController().getGUI().getServerControlTab().removePlayer(name); gui.getServerControlTab().removePlayer(name);
} }
/** /**
@ -401,8 +328,9 @@ public class Server {
* *
* @return <p>True if nothing went wrong</p> * @return <p>True if nothing went wrong</p>
*/ */
private boolean runServer(boolean isFirstServer) { public boolean runServer(boolean isFirstServer) {
if (stoppingServers) { if (ServerHandler.stoppingServers()) {
gui.logMessage("Stopping servers. Cannot start yet.");
return false; return false;
} }
//Ignore a disabled server //Ignore a disabled server
@ -412,20 +340,21 @@ public class Server {
} }
//Tries to do necessary pre-start work //Tries to do necessary pre-start work
if (!initializeJarDownload() || (!isFirstServer && !delayStartup())) { if (!initializeJarDownload() || (!isFirstServer && !delayStartup())) {
gui.logError("Failed to perform startup tasks.");
this.started = false; this.started = false;
return false; return false;
} }
if (stoppingServers) { if (ServerHandler.stoppingServers()) {
return false; return false;
} }
//Starts the server if possible //Starts the server if possible
try { try {
startServerProcess(); startServerProcess();
Main.getController().getGUI().setStatus("Servers are running"); gui.setStatus("Servers are running");
this.started = true; this.started = true;
return true; return true;
} catch (IOException e) { } catch (IOException e) {
Main.getController().getGUI().setStatus("Could not start server"); gui.setStatus("Could not start server");
this.started = false; this.started = false;
return false; return false;
} }
@ -573,7 +502,7 @@ public class Server {
*/ */
private boolean delayStartup() { private boolean delayStartup() {
try { try {
Main.getController().getGUI().setStatus("Delaying startup"); gui.setStatus("Delaying startup");
TimeUnit.SECONDS.sleep(Main.getController().getCurrentProfile().getDelayStartup()); TimeUnit.SECONDS.sleep(Main.getController().getCurrentProfile().getDelayStartup());
return true; return true;
} catch (InterruptedException e) { } catch (InterruptedException e) {
@ -589,19 +518,16 @@ public class Server {
* @return <p>True if nothing went wrong</p> * @return <p>True if nothing went wrong</p>
*/ */
private boolean initializeJarDownload() { private boolean initializeJarDownload() {
ServerLauncherController controller = Main.getController();
if (!controller.getDownloadAllJars()) {
try { try {
controller.getGUI().setStatus("Downloading jar..."); gui.setStatus("Downloading jar...");
this.downloadJar(); this.downloadJar();
controller.getGUI().setStatus("File downloaded"); gui.setStatus("File downloaded");
} catch (IOException e) { } catch (IOException e) {
controller.getGUI().setStatus("Error: Jar file not found"); gui.setStatus("Error: Jar file not found, not downloaded or not built.");
e.printStackTrace(); gui.logError("Unable to get required .jar file: " + e.getMessage());
this.started = false; this.started = false;
return false; return false;
} }
}
return true; return true;
} }

View File

@ -0,0 +1,140 @@
package net.knarcraft.minecraftserverlauncher.server;
import net.knarcraft.minecraftserverlauncher.Main;
import net.knarcraft.minecraftserverlauncher.profile.Collection;
import net.knarcraft.minecraftserverlauncher.profile.ServerLauncherController;
import net.knarcraft.minecraftserverlauncher.userinterface.ServerLauncherGUI;
import javax.naming.ConfigurationException;
import java.io.BufferedWriter;
import java.io.IOException;
import java.util.concurrent.TimeUnit;
public class ServerHandler {
/**
* Available ram sizes. For ServerLauncherGUI combo
*/
private static final String[] ramList = {"512M", "1G", "2G", "3G", "4G", "5G", "6G", "7G", "8G", "9G", "10G",
"11G", "12G", "13G", "14G", "15G", "16G"};
private static boolean stoppingServers = false;
private static final ServerLauncherGUI gui = Main.getController().getGUI();
/**
* Gets the list of available RAM choices allowed
*
* @return <p>All available RAM choices</p>
*/
public static String[] getRamList() {
return ramList;
}
/**
* Gets whether the servers are currently in the process of stopping
*
* @return <p>True if the servers are in the process of stopping.</p>
*/
public static boolean stoppingServers() {
return stoppingServers;
}
/**
* Marks the servers as finished stopping when a stop is confirmed
*/
public static void serversStopped() {
if (stoppingServers) {
stoppingServers = false;
}
}
/**
* Tries to stop all enabled servers
*
* @throws IOException <p>If a writer's process is already closed but not null</p>
*/
public static void stop() throws IOException, InterruptedException {
if (stoppingServers) {
killServers();
return;
}
stoppingServers = true;
for (Collection collection : Main.getController().getCurrentProfile().getCollections()) {
Server server = collection.getServer();
BufferedWriter writer = server.getWriter();
if (writer != null) {
if (server.isProxy()) {
writer.write("end\n");
} else {
writer.write("stop\n");
}
writer.flush();
server.setWriter(null);
server.setStopped();
}
}
//TODO: Set stoppingServers to false if no servers are actually running
}
/**
* Kills all server processes
*
* @throws InterruptedException <p>If interrupted waiting for any of the servers to stop</p>
*/
private static void killServers() throws InterruptedException {
for (Collection collection : Main.getController().getCurrentProfile().getCollections()) {
Server server = collection.getServer();
killServer(server);
}
}
/**
* Kills the given server after waiting 30 seconds for it to terminate normally
*
* @param server <p>The server to kill</p>
* @throws InterruptedException <p>If interrupted waiting for the server to stop</p>
*/
private static void killServer(Server server) throws InterruptedException {
Process serverProcess = server.getProcess();
if (serverProcess != null) {
if (!serverProcess.waitFor(30, TimeUnit.SECONDS)) {
serverProcess.destroyForcibly();
serverProcess.waitFor();
}
}
}
/**
* Runs all enabled servers with their settings
*/
public static void startServers() {
ServerLauncherController controller = Main.getController();
gui.setStatus("Starting servers");
int serverNum = 0;
for (Collection collection : controller.getCurrentProfile().getCollections()) {
if (!collection.getServer().runServer(serverNum++ == 0)) {
gui.showError("An error occurred. Start aborted. Please check relevant log files.");
try {
stop();
} catch (IOException | InterruptedException e) {
e.printStackTrace();
}
gui.updateGUIElementsWhenServersStartOrStop(false);
return;
}
}
}
/**
* Gets a server object from a server save string
*
* @param saveString <p>The string containing necessary data regarding the server</p>
* @return <p>A server in the same state it was saved in</p>
*/
public static Server fromString(String saveString) throws ConfigurationException {
String[] data = saveString.split(";");
return new Server(data[0], data[1], Boolean.parseBoolean(data[2]), data[3], data[4], data[5]);
}
}

View File

@ -3,7 +3,7 @@ package net.knarcraft.minecraftserverlauncher.userinterface;
import net.knarcraft.minecraftserverlauncher.Main; import net.knarcraft.minecraftserverlauncher.Main;
import net.knarcraft.minecraftserverlauncher.profile.Collection; import net.knarcraft.minecraftserverlauncher.profile.Collection;
import net.knarcraft.minecraftserverlauncher.profile.ServerLauncherController; import net.knarcraft.minecraftserverlauncher.profile.ServerLauncherController;
import net.knarcraft.minecraftserverlauncher.server.Server; import net.knarcraft.minecraftserverlauncher.server.ServerHandler;
import net.knarcraft.minecraftserverlauncher.utility.CommonFunctions; import net.knarcraft.minecraftserverlauncher.utility.CommonFunctions;
import javax.imageio.ImageIO; import javax.imageio.ImageIO;
@ -327,7 +327,7 @@ public class ServerLauncherGUI extends MessageHandler implements ActionListener,
private void handleMainTabButtons(Object actionSource) { private void handleMainTabButtons(Object actionSource) {
if (actionSource == startServerButton) { if (actionSource == startServerButton) {
controller.saveState(); controller.saveState();
Executors.newSingleThreadExecutor().execute(Server::startServers); Executors.newSingleThreadExecutor().execute(ServerHandler::startServers);
} else if (actionSource == stopServerButton) { } else if (actionSource == stopServerButton) {
stopServers(); stopServers();
} else if (actionSource == addServerButton) { } else if (actionSource == addServerButton) {
@ -404,7 +404,7 @@ public class ServerLauncherGUI extends MessageHandler implements ActionListener,
public void stopServers() { public void stopServers() {
try { try {
setStatus("Servers are stopping..."); setStatus("Servers are stopping...");
Server.stop(); ServerHandler.stop();
} catch (IOException e1) { } catch (IOException e1) {
showError("Could not stop server."); showError("Could not stop server.");
e1.printStackTrace(); e1.printStackTrace();

View File

@ -1,7 +1,7 @@
package net.knarcraft.minecraftserverlauncher.userinterface; package net.knarcraft.minecraftserverlauncher.userinterface;
import net.knarcraft.minecraftserverlauncher.Main; import net.knarcraft.minecraftserverlauncher.Main;
import net.knarcraft.minecraftserverlauncher.server.Server; import net.knarcraft.minecraftserverlauncher.server.ServerHandler;
import net.knarcraft.minecraftserverlauncher.server.ServerTypeHandler; import net.knarcraft.minecraftserverlauncher.server.ServerTypeHandler;
import net.knarcraft.minecraftserverlauncher.server.servertypes.ServerType; import net.knarcraft.minecraftserverlauncher.server.servertypes.ServerType;
@ -76,7 +76,7 @@ public class ServerTab implements ActionListener {
sl_panel_3.putConstraint(SpringLayout.WEST, lblMaxRam, 6, SpringLayout.EAST, serverTypes); sl_panel_3.putConstraint(SpringLayout.WEST, lblMaxRam, 6, SpringLayout.EAST, serverTypes);
panel.add(lblMaxRam); panel.add(lblMaxRam);
maxRam = new JComboBox<>(Server.getRamList()); maxRam = new JComboBox<>(ServerHandler.getRamList());
sl_panel_3.putConstraint(SpringLayout.NORTH, maxRam, 0, SpringLayout.NORTH, serverTypes); sl_panel_3.putConstraint(SpringLayout.NORTH, maxRam, 0, SpringLayout.NORTH, serverTypes);
sl_panel_3.putConstraint(SpringLayout.WEST, maxRam, 6, SpringLayout.EAST, lblMaxRam); sl_panel_3.putConstraint(SpringLayout.WEST, maxRam, 6, SpringLayout.EAST, lblMaxRam);
sl_panel_3.putConstraint(SpringLayout.EAST, maxRam, -10, SpringLayout.EAST, panel); sl_panel_3.putConstraint(SpringLayout.EAST, maxRam, -10, SpringLayout.EAST, panel);

View File

@ -11,7 +11,7 @@ public class ServerTest {
@Test @Test
public void fromStringTest() throws ConfigurationException { public void fromStringTest() throws ConfigurationException {
Server server = Server.fromString("asd;/home/;false;Bukkit;1.10.2;4G;"); Server server = ServerHandler.fromString("asd;/home/;false;Bukkit;1.10.2;4G;");
assertEquals("asd", server.getName()); assertEquals("asd", server.getName());
assertEquals("/home/", server.getPath()); assertEquals("/home/", server.getPath());
assertFalse(server.isEnabled()); assertFalse(server.isEnabled());