Minecraft/asys
Archived
0
Fork 0
Code Activity

Новые модули: McProcessServer и McScreenServer

Browse Source 
Данные модули реализуют один из способов создания процесса сервера Minecraft.
Process - это создание контролируемого процесса, который завязан на самом ASys. Проще говоря, выключится ASys - "упадет" процесс.
Screen - подходит только для Unix-based систем (или запуск в Cygwin). Для запуска процесса используется утилита screen. Для контроля работы процесса так же задействуются утилиты pgrep и ps. Созданный процесс является неконтролируемым и при отключении ASys, созданный процесс продолжит "жизнь".
This commit is contained in:
DmitriyMX
2016-08-15 16:08:00 +03:00
parent 53c0f8a5c5
commit 00bfd67e2a
6 changed files with 212 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

75
SingleServer/src/main/java/asys/singleserver/mcserver/MinecraftProcessServer.java
View File

@@ -1,75 +0,0 @@
/*
* DmitriyMX <mail@dmitriymx.ru>
* 2016-08-15
*/
package asys.singleserver.mcserver;
import asys.api.MinecraftServer;
import java.io.File;
import java.io.IOException;
import java.util.List;
import java.util.Vector;
public class MinecraftProcessServer implements MinecraftServer {
private ProcessBuilder processBuilder;
private Process process;
private final String name;
private final byte[] newLine = "\n".getBytes();
public MinecraftProcessServer(String name, File directory, String mainJar, String jvmArgs, String params) {
processBuilder = new ProcessBuilder();
processBuilder.directory(directory);
List<String> commandLine = new Vector<>();
commandLine.add("java");
commandLine.add("-Dasys.server.name=\"" + name + "\"");
if ((jvmArgs != null) && (!jvmArgs.trim().isEmpty())) {
commandLine.add(jvmArgs);
}
commandLine.add("-jar");
commandLine.add(mainJar);
if ((params != null) && (!params.trim().isEmpty())) {
commandLine.add(params);
}
processBuilder.command(commandLine);
this.name = name;
}
public String getName() {
return name;
}
public void start() {
try {
process = processBuilder.start();
} catch (IOException e) {
e.printStackTrace();
}
}
public void stop() {
sendCommand("stop");
}
public void forceStop() {
process.destroy();
process = null;
}
public void sendCommand(String command) {
if (!isAlive()) return;
try {
process.getOutputStream().write(command.getBytes());
process.getOutputStream().write(newLine);
process.getOutputStream().flush();
} catch (IOException e) {
e.printStackTrace();
}
}
public boolean isAlive() {
return process != null && process.isAlive();
}
}

102
SingleServer/src/main/java/asys/singleserver/mcserver/MinecraftScreenServer.java
View File

@@ -1,102 +0,0 @@
/*
* DmitriyMX <mail@dmitriymx.ru>
* 2016-08-15
*/
package asys.singleserver.mcserver;
import asys.api.MinecraftServer;
import java.io.BufferedReader;
import java.io.File;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.Arrays;
import java.util.List;
import java.util.Vector;
public class MinecraftScreenServer implements MinecraftServer {
private ProcessBuilder startPB;
private String name;
private String serverPID;
public MinecraftScreenServer(String name, File directory, String mainJar, String jvmArgs, String params) {
startPB = new ProcessBuilder();
startPB.directory(directory);
List<String> commandLine = new Vector<>(Arrays.asList(new String[] { "screen", "-dmS", name, "java", "-Dasys.server.name=\"" + name + "\"" }));
if ((jvmArgs != null) && (!jvmArgs.trim().isEmpty())) {
commandLine.add(jvmArgs);
}
commandLine.add("-jar");
commandLine.add(mainJar);
if ((params != null) && (!params.trim().isEmpty())) {
commandLine.add(params);
}
this.startPB.command(commandLine);
this.name = name;
}
public String getName() {
return name;
}
public void start() {
try {
startPB.start();
Thread.sleep(500L);
Process process = Runtime.getRuntime().exec("bash -c \"screen -ls | sed 's/\\t//g' | grep '\\." + name + "(' | cut -f1 -d.\"");
BufferedReader br = new BufferedReader(new InputStreamReader(process.getInputStream()));
String out = br.readLine();
br.close();
process = Runtime.getRuntime().exec("pgrep -P " + out);
br = new BufferedReader(new InputStreamReader(process.getInputStream()));
serverPID = br.readLine();
br.close();
} catch (Exception e) {
e.printStackTrace();
}
}
public void stop() {
sendCommand("stop");
}
public void forceStop() {
ProcessBuilder sendCmdPB = new ProcessBuilder();
sendCmdPB.command("screen", "-S", this.name, "-X", "quit");
try {
sendCmdPB.start();
} catch (IOException e) {
e.printStackTrace();
}
}
public void sendCommand(String command) {
ProcessBuilder sendCmdPB = new ProcessBuilder();
sendCmdPB.command("screen", "-S", this.name, "-p", "0", "-X", "stuff", command + "\\r");
try {
sendCmdPB.start();
} catch (IOException e) {
e.printStackTrace();
}
}
public boolean isAlive() {
if (serverPID == null) return false;
try {
Process process = Runtime.getRuntime().exec("ps -p " + serverPID);
BufferedReader br = new BufferedReader(new InputStreamReader(process.getInputStream()));
br.readLine();
String line = br.readLine();
br.close();
return line != null;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
}