Initial project for 1.5.2 branch

src/main/java/cn/forevermc/server/mcpc/FMCServer.java

@@ -0,0 +1,90 @@
+package cn.forevermc.server.mcpc;
+
+import cn.forevermc.server.mcpc.command.DebugCommand;
+import cn.forevermc.server.mcpc.command.StaffCommand;
+import cn.forevermc.server.mcpc.event.DebugEvent;
+import cn.forevermc.server.mcpc.service.ReportService;
+import cn.forevermc.server.mcpc.util.Util;
+import com.google.gson.Gson;
+import lombok.Getter;
+import org.bukkit.configuration.file.FileConfiguration;
+import org.bukkit.plugin.java.JavaPlugin;
+import org.bukkit.scheduler.BukkitTask;
+
+import java.util.UUID;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
+/**
+ * ForeverMC 服务器状态报告插件
+ *
+ * @author 夜雨
+ * @since 2022-11-14 11:05
+ */
+public class FMCServer extends JavaPlugin {
+
+	public static final Gson GSON = new Gson();
+
+	@Getter
+	private static FileConfiguration configuration;
+
+	private static Logger log;
+	private BukkitTask statusServiceTask;
+
+	@Override
+	public void onEnable() {
+		log = getLogger();
+		configuration = getConfig();
+		defConfig();
+
+		{
+			// config
+			log.info("debug: " + configuration.getBoolean("debug.enable"));
+			log.info("debug.staff: " + configuration.getStringList("debug.staff"));
+			log.info("report: " + configuration.getBoolean("report.enable"));
+			log.info("report.id: " + configuration.getString("report.id"));
+		}
+
+		getCommand("debug").setExecutor(new DebugCommand(this));
+		getCommand("staff").setExecutor(new StaffCommand(this));
+
+		getServer().getPluginManager().registerEvents(new DebugEvent(), this);
+
+		if (configuration.getBoolean("report.enable")) {
+			statusServiceTask = new ReportService(FMCServer.this).runTaskTimerAsynchronously(FMCServer.this, 0, 60);
+		}
+	}
+
+	@Override
+	public void onDisable() {
+		if (statusServiceTask != null) {
+			statusServiceTask.cancel();
+		}
+	}
+
+	@Override
+	public void reloadConfig() {
+		super.reloadConfig();
+		configuration = getConfig();
+	}
+
+	public static void log(Level level, String msg) {
+		log.log(level, msg);
+	}
+
+	/** 默认配置 */
+	private void defConfig() {
+		configuration.addDefault("debug.enable", false);
+		configuration.addDefault("debug.staff", new String[0]);
+		configuration.addDefault("report.enable", false);
+		configuration.addDefault("report.id", UUID.randomUUID().toString());
+		configuration.addDefault("report.api.info", "http://localhost:8091/fmc/server/info");
+		configuration.addDefault("report.api.status", "http://localhost:8091/fmc/server/status");
+		configuration.addDefault("report.token", "");
+		configuration.addDefault("report.name", "FMCServer#" + Util.randomString(8));
+		configuration.addDefault("report.clientURL", "");
+		configuration.addDefault("report.ip", "");
+		configuration.options().copyDefaults(true);
+		saveConfig();
+	}
+}

src/main/java/cn/forevermc/server/mcpc/bean/ServerStatusRequest.java

@@ -0,0 +1,94 @@
+package cn.forevermc.server.mcpc.bean;
+
+import lombok.Data;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * 服务器状态
+ *
+ * @author 夜雨
+ * @since 2024-08-06 20:38
+ */
+@Data
+public class ServerStatusRequest {
+
+	private String id;
+
+	private ServerStatus status;
+
+	/**
+	 * @author 夜雨
+	 * @since 2021-12-02 19:56
+	 */
+	@Data
+	public static class ServerStatus {
+
+		/** true 为维护中 */
+		private boolean isDebugging;
+
+		/** TPS */
+		private double tps;
+
+		/** 报告时间 */
+		private long reportAt;
+
+		/** JVM 状态 */
+		private JVM jvm = new JVM();
+
+		/** 在线列表 */
+		private List<String> onlineList = new ArrayList<>();
+
+		/**
+		 * 设置 TPS 取平均
+		 *
+		 * @param tpsList TPS 列表
+		 */
+		public void setTps(double[] tpsList) {
+			double sum = 0;
+			for (int i = 0; i < tpsList.length; i++) {
+				sum += tpsList[i];
+			}
+			tps = sum / tpsList.length;
+		}
+
+		/**
+		 * JVM 状态
+		 *
+		 * @author 夜雨
+		 * @since 2022-11-11 14:52
+		 */
+		@Data
+		public static class JVM {
+
+			/** CPU 已使用 */
+			private double cpuUsed;
+
+			/** 内存状态 */
+			private Memory memory = new Memory();
+
+			/**
+			 * 内存状态
+			 *
+			 * @author 夜雨
+			 * @since 2022-11-15 09:54
+			 */
+			@Data
+			public static class Memory {
+
+				/** 已使用 */
+				private long used;
+
+				/** 已申请 */
+				private long committed;
+
+				/** 最大内存 */
+				private long max;
+
+				/** JVM 名称 */
+				private String name;
+			}
+		}
+	}
+}

src/main/java/cn/forevermc/server/mcpc/command/DebugCommand.java

@@ -0,0 +1,111 @@
+package cn.forevermc.server.mcpc.command;
+
+import cn.forevermc.server.mcpc.FMCServer;
+import cn.forevermc.server.mcpc.util.Util;
+import org.bukkit.command.Command;
+import org.bukkit.command.CommandExecutor;
+import org.bukkit.command.CommandSender;
+import org.bukkit.command.TabCompleter;
+import org.bukkit.configuration.file.FileConfiguration;
+import org.bukkit.entity.Player;
+import org.bukkit.plugin.java.JavaPlugin;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.logging.Level;
+
+/**
+ * 维护模式
+ *
+ * @author 夜雨
+ * @since 2024-08-07 12:44
+ */
+public class DebugCommand implements CommandExecutor {
+
+	/**
+	 * 指令动作
+	 *
+	 * @author 夜雨
+	 * @since 2024-08-07 20:15
+	 */
+	private enum Action {
+
+		/** 启用 */
+		TRUE,
+
+		/** 禁用 */
+		FALSE,
+
+		/** 当前状态 */
+		STATUS
+	}
+
+	private final JavaPlugin plugin;
+	private final List<String> actionList;
+
+	public DebugCommand(JavaPlugin plugin) {
+		this.plugin = plugin;
+
+		// 提示
+		actionList = new ArrayList<>();
+		for (Action action : Action.values()) {
+			actionList.add(action.toString().toLowerCase());
+		}
+		plugin.getCommand("debug").setTabCompleter(new TabCompleter() {
+
+			@Override
+			public List<String> onTabComplete(CommandSender commandSender, Command command, String s, String[] args) {
+				if (args.length == 1) {
+					return actionList;
+				}
+				return new ArrayList<>();
+			}
+		});
+	}
+
+	@Override
+	public boolean onCommand(CommandSender sender, Command command, String label, String[] args) {
+		FileConfiguration config = FMCServer.getConfiguration();
+
+		boolean isEnable = config.getBoolean("debug.enable");
+		Action action;
+		if (args.length == 1) {
+			// 含动作参数
+			action = Util.enumValueOf(Action.class, args[0]);
+			if (action == Action.TRUE) {
+				isEnable = true;
+			}
+			if (action == Action.FALSE) {
+				isEnable = false;
+			}
+			if (action == Action.STATUS) {
+				if (isEnable) {
+					Util.returnMsg(sender, Level.INFO, "当前维护模式：启用");
+				} else {
+					Util.returnMsg(sender, Level.INFO, "当前维护模式：禁用");
+				}
+				return true;
+			}
+		} else {
+			// 直接切换
+			isEnable = !isEnable;
+		}
+		config.set("debug.enable", isEnable);
+		if (isEnable) {
+			Player[] players = plugin.getServer().getOnlinePlayers();
+			List<String> staffList = config.getStringList("debug.staff");
+			// 踢出非维护人员
+			for (Player player : players) {
+				if (!staffList.contains(player.getName())) {
+					player.kickPlayer("服务器正在维护，请稍后重试");
+				}
+			}
+			Util.returnMsg(sender, Level.INFO, "已启用维护模式");
+		} else {
+			Util.returnMsg(sender, Level.INFO, "已禁用维护模式");
+		}
+		plugin.saveConfig();
+		plugin.reloadConfig();
+		return true;
+	}
+}

src/main/java/cn/forevermc/server/mcpc/command/StaffCommand.java

@@ -0,0 +1,104 @@
+package cn.forevermc.server.mcpc.command;
+
+import cn.forevermc.server.mcpc.FMCServer;
+import cn.forevermc.server.mcpc.util.Util;
+import org.bukkit.command.Command;
+import org.bukkit.command.CommandExecutor;
+import org.bukkit.command.CommandSender;
+import org.bukkit.command.TabCompleter;
+import org.bukkit.configuration.file.FileConfiguration;
+import org.bukkit.plugin.java.JavaPlugin;
+
+import java.util.ArrayList;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Set;
+import java.util.logging.Level;
+
+/**
+ * 维护人员操作
+ *
+ * @author 夜雨
+ * @since 2024-08-07 12:44
+ */
+public class StaffCommand implements CommandExecutor {
+
+	/**
+	 * 指令动作
+	 *
+	 * @author 夜雨
+	 * @since 2024-08-07 14:29
+	 */
+	private enum Action {
+
+		/** 添加 */
+		ADD,
+
+		/** 移除 */
+		REMOVE,
+
+		/** 列表 */
+		LIST
+	}
+
+	private final JavaPlugin plugin;
+	private final List<String> actionList;
+
+	public StaffCommand(JavaPlugin plugin) {
+		this.plugin = plugin;
+
+		// 提示
+		actionList = new ArrayList<>();
+		for (Action action : Action.values()) {
+			actionList.add(action.toString().toLowerCase());
+		}
+		plugin.getCommand("staff").setTabCompleter(new TabCompleter() {
+
+			@Override
+			public List<String> onTabComplete(CommandSender commandSender, Command command, String s, String[] args) {
+				if (args.length == 1) {
+					return actionList;
+				}
+				return new ArrayList<>();
+			}
+		});
+	}
+
+	@Override
+	public boolean onCommand(CommandSender sender, Command command, String label, String[] args) {
+		FileConfiguration config = FMCServer.getConfiguration();
+		Action action = Util.enumValueOf(Action.class, args[0]);
+		if (action == null) {
+			Util.returnMsg(sender, Level.WARNING, "使用方式: /staff [add|remove|list] <value>");
+			return true;
+		}
+		Set<String> staffSet = new HashSet<>(config.getStringList("debug.staff"));
+		if (action == Action.LIST) {
+			Util.returnMsg(sender, Level.INFO, "维护人员列表: " + staffSet);
+		} else {
+			if (args.length < 2) {
+				Util.returnMsg(sender, Level.WARNING, "使用方式: /staff [add|remove|list] <value>");
+				return true;
+			}
+			String value = args[1];
+			if (value.isEmpty()) {
+				Util.returnMsg(sender, Level.WARNING, "请输入维护人员 ID");
+				return true;
+			}
+			switch (action) {
+				case ADD:
+					staffSet.add(value);
+					Util.returnMsg(sender, Level.INFO, String.format("已添加 %s 维护人员", value));
+					break;
+				case REMOVE:
+					staffSet.remove(value);
+					Util.returnMsg(sender, Level.INFO, String.format("已移除 %s 维护人员", value));
+					break;
+			}
+			config.set("debug.staff", staffSet.toArray(new String[0]));
+			plugin.saveConfig();
+			plugin.reloadConfig();
+		}
+		return true;
+	}
+}

src/main/java/cn/forevermc/server/mcpc/event/DebugEvent.java

@@ -0,0 +1,30 @@
+package cn.forevermc.server.mcpc.event;
+
+import cn.forevermc.server.mcpc.FMCServer;
+import org.bukkit.configuration.file.FileConfiguration;
+import org.bukkit.event.EventHandler;
+import org.bukkit.event.Listener;
+import org.bukkit.event.player.PlayerJoinEvent;
+
+import java.util.List;
+
+/**
+ * 调试事件
+ *
+ * @author 夜雨
+ * @since 2024-08-07 12:35
+ */
+public class DebugEvent implements Listener {
+
+	@EventHandler
+	public void onPlayerJoin(PlayerJoinEvent event) {
+		FileConfiguration config = FMCServer.getConfiguration();
+		if (!config.getBoolean("debug.enable")) {
+			return;
+		}
+		List<String> staff = config.getStringList("debug.staff");
+		if (!staff.contains(event.getPlayer().getName())) {
+			event.getPlayer().kickPlayer("服务器正在维护，请稍后重试");
+		}
+	}
+}

src/main/java/cn/forevermc/server/mcpc/service/ReportService.java

@@ -0,0 +1,159 @@
+package cn.forevermc.server.mcpc.service;
+
+import cn.forevermc.server.mcpc.FMCServer;
+import cn.forevermc.server.mcpc.bean.ServerStatusRequest;
+import cn.forevermc.server.mcpc.util.HTTP;
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParser;
+import com.sun.management.OperatingSystemMXBean;
+import org.bukkit.Bukkit;
+import org.bukkit.Server;
+import org.bukkit.configuration.file.FileConfiguration;
+import org.bukkit.entity.Player;
+import org.bukkit.plugin.java.JavaPlugin;
+import org.bukkit.scheduler.BukkitRunnable;
+
+import java.io.File;
+import java.lang.management.ManagementFactory;
+import java.lang.management.MemoryMXBean;
+import java.nio.file.Files;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.logging.Level;
+
+/**
+ * 状态报告服务
+ *
+ * @author 夜雨
+ * @since 2022-11-11 14:38
+ */
+public class ReportService extends BukkitRunnable {
+
+	private final Server server = Bukkit.getServer();
+	private final ServerStatusRequest request = new ServerStatusRequest();
+	private final MemoryMXBean jvmMemory = ManagementFactory.getMemoryMXBean();
+	private final OperatingSystemMXBean operatingSystemMXBean;
+
+	private final String api;
+	private final JavaPlugin plugin;
+	private final double[] tpsList = new double[9];
+
+	/** 失败时间，用于失败时任务执行周期将会更长 */
+	private long failAt = -1;
+
+	public ReportService(JavaPlugin plugin) {
+		this.plugin = plugin;
+
+		api = FMCServer.getConfiguration().getString("report.api.status");
+		operatingSystemMXBean = ManagementFactory.getPlatformMXBean(OperatingSystemMXBean.class);
+
+		if (api == null || api.isEmpty()) {
+			FMCServer.log(Level.WARNING, "start report task fail because of not found report.api.status in configuration");
+			return;
+		}
+		request.setId(plugin.getConfig().getString("report.id"));
+		request.setStatus(new ServerStatusRequest.ServerStatus());
+
+		// TPS 计算
+		server.getScheduler().scheduleSyncRepeatingTask(plugin, new Runnable() {
+
+			private int ticks;
+			private int tpsI;
+			private long cs;
+			private double tps;
+
+			@Override
+			public void run() {
+				long s = System.currentTimeMillis() / 1000;
+				if (cs == s) {
+					ticks++;
+				} else {
+					cs = s;
+					tpsI++;
+					tpsList[tpsI % tpsList.length] = tps = tps == 0 ? ticks : ((tps + ticks) / 2);
+					ticks = 0;
+				}
+			}
+		}, 0, 1);
+	}
+
+	/** 报告基本信息 */
+	private void sendInfo() throws Exception {
+		FileConfiguration config = FMCServer.getConfiguration();
+		String api = config.getString("report.api.info");
+		if (api == null || api.isEmpty()) {
+			FMCServer.log(Level.WARNING, "start report task fail because of not found report.api.info in configuration");
+			return;
+		}
+		File iconFile = new File(new File(plugin.getDataFolder().getParent()).getParent(), "server-icon.png");
+		Server server = plugin.getServer();
+
+		Map<String, Object> params = new HashMap<>();
+		List<HTTP.PostFile> postFileList = new ArrayList<>();
+
+		params.put("id", config.getString("report.id").trim());
+		params.put("name", config.getString("report.name").trim());
+		params.put("core", server.getVersion().trim());
+		params.put("bootAt", System.currentTimeMillis());
+		params.put("clientURL", config.getString("report.clientURL").trim());
+		params.put("maxOnline", server.getMaxPlayers());
+		params.put("ip", config.getString("report.ip").trim());
+		if (iconFile.exists()) {
+			HTTP.PostFile file = new HTTP.PostFile();
+			file.setField("icon");
+			file.setFileName("server-icon.png");
+			file.setBytes(Files.readAllBytes(iconFile.toPath()));
+			postFileList.add(file);
+		}
+		String resp = HTTP.post(api, params, postFileList);
+		JsonObject respObj = JsonParser.parseString(resp).getAsJsonObject();
+		Integer code = respObj.get("code").getAsInt();
+		if (!code.equals(20000)) {
+			FMCServer.log(Level.WARNING, "report server info error: " + respObj.get("msg").getAsString());
+		}
+	}
+
+	/** 报告状态 */
+	@Override
+	public void run() {
+		// 失败时延长周期，(15+-3) 秒
+		if (System.currentTimeMillis() - failAt < 1E3 * 15) {
+			return;
+		}
+		ServerStatusRequest.ServerStatus status = request.getStatus();
+		status.getOnlineList().clear();
+		Player[] players = server.getOnlinePlayers();
+		for (Player player : players) {
+			status.getOnlineList().add(player.getName());
+		}
+		status.setTps(tpsList);
+		status.setDebugging(FMCServer.getConfiguration().getBoolean("debug.enable"));
+		status.setReportAt(System.currentTimeMillis());
+		status.getJvm().setCpuUsed(operatingSystemMXBean.getProcessCpuLoad());
+		status.getJvm().getMemory().setUsed(jvmMemory.getHeapMemoryUsage().getUsed());
+		status.getJvm().getMemory().setCommitted(jvmMemory.getHeapMemoryUsage().getCommitted());
+
+		try {
+			String resp = HTTP.post(api, HTTP.ContentType.JSON, FMCServer.GSON.toJson(request));
+			if (resp == null || resp.isEmpty()) {
+				FMCServer.log(Level.WARNING, "report fail for empty result");
+				return;
+			}
+			JsonObject respObj = JsonParser.parseString(resp).getAsJsonObject();
+			Integer code = respObj.get("code").getAsInt();
+			// 数据中心通知需要发送基本信息，与接口约定返回代码为 20001，消息为 REQUIRED_BASE_INFO
+			if (code.equals(20001) && respObj.get("msg").getAsString().equals("REQUIRED_BASE_INFO")) {
+				FMCServer.log(Level.WARNING, "server required send base info");
+				sendInfo();
+			} else if (!code.equals(20000)) {
+				failAt = System.currentTimeMillis();
+				FMCServer.log(Level.SEVERE, "report fail: " + respObj.get("msg").getAsString());
+			}
+		} catch (Exception ignored) {
+			failAt = System.currentTimeMillis();
+			// 超时，连接失败的视为终端离线
+		}
+	}
+}

src/main/java/cn/forevermc/server/mcpc/util/HTTP.java

@@ -0,0 +1,252 @@
+package cn.forevermc.server.mcpc.util;
+
+import cn.forevermc.server.mcpc.FMCServer;
+import lombok.Data;
+import lombok.Getter;
+
+import javax.net.ssl.HttpsURLConnection;
+import javax.net.ssl.SSLContext;
+import javax.net.ssl.TrustManager;
+import javax.net.ssl.X509TrustManager;
+import java.io.BufferedInputStream;
+import java.io.BufferedOutputStream;
+import java.io.ByteArrayInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.net.HttpURLConnection;
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.net.URL;
+import java.net.URLEncoder;
+import java.nio.charset.StandardCharsets;
+import java.security.KeyManagementException;
+import java.security.NoSuchAlgorithmException;
+import java.security.cert.X509Certificate;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * HTTP 操作
+ *
+ * @author 夜雨
+ * @since 2024-08-06 14:35
+ */
+public class HTTP {
+
+	/**
+	 * 请求类型
+	 *
+	 * @author 夜雨
+	 * @version 2022-01-02 12:16
+	 */
+	@Getter
+	public enum ContentType {
+
+		/** 默认 URL 请求 */
+		DEFAULT(null),
+
+		/** FORM 表单模拟 */
+		FORM("application/x-www-form-urlencoded"),
+
+		/** JSON */
+		JSON("application/json; charset=utf-8"),
+
+		/** 数据流 */
+		STREAM("multipart/form-data; charset=utf-8; boundary=B7018kpqFPpgrWAKIR0lHNAanJEqJEyz");
+
+		final String value;
+
+		ContentType(String value) {
+			this.value = value;
+		}
+
+	}
+
+	/**
+	 * 发送 POST 请求
+	 *
+	 * @param url  请求地址
+	 * @param type 数据体类型
+	 * @param data 数据
+	 * @return 返回结果
+	 * @throws Exception 请求异常
+	 */
+	public static String post(String url, ContentType type, String data) throws Exception {
+		HttpURLConnection connection = getConnection(url, type);
+		connection.setRequestMethod("POST");
+		connection.setDoInput(true);
+		connection.setDoOutput(true);
+		connection.setUseCaches(false);
+		connection.setInstanceFollowRedirects(true);
+		if (data != null && !data.isEmpty()) {
+			BufferedOutputStream bos = new BufferedOutputStream(connection.getOutputStream());
+			bos.write(data.getBytes(StandardCharsets.UTF_8));
+			bos.flush();
+			bos.close();
+		}
+
+		String result = "";
+		if (HttpURLConnection.HTTP_OK == connection.getResponseCode()) {
+			result = toString(connection.getInputStream());
+		}
+		connection.disconnect();
+		return result;
+	}
+
+	public static String post(String url, Map<String, Object> params, List<PostFile> postFileList) throws Exception {
+		final String newLine = "\r\n";
+		final String paramHeader = "Content-Disposition: form-data; name=\"%s\"";
+		final String fileHeader = "Content-Disposition: form-data; name=\"%s\"; filename=\"%s\"";
+		final String split = ContentType.STREAM.getValue().split("boundary=")[1];
+
+		HttpURLConnection connection = getConnection(url, ContentType.STREAM);
+		connection.setDoInput(true);
+		connection.setDoOutput(true);
+		connection.setUseCaches(false);
+		connection.setRequestMethod("POST");
+		connection.setChunkedStreamingMode(4096);
+
+		DataOutputStream dos = new DataOutputStream(connection.getOutputStream());
+		{
+			// 参数
+			for (Map.Entry<String, Object> param : params.entrySet()) {
+				dos.writeBytes("--" + split);
+				dos.writeBytes(newLine);
+				// 参数协议
+				dos.writeBytes(String.format(paramHeader, param.getKey()));
+				dos.writeBytes(newLine);
+				dos.writeBytes("Content-Type: text/plain; charset=UTF-8");
+				dos.writeBytes(newLine);
+				dos.writeBytes("Content-Transfer-Encoding: 8bit");
+				dos.writeBytes(newLine);
+				dos.writeBytes(newLine);
+				Object value = param.getValue();
+				if (value != null) {
+					dos.write(value.toString().getBytes(StandardCharsets.UTF_8));
+				}
+				dos.writeBytes(newLine);
+			}
+			// 文件
+			for (PostFile postFile : postFileList) {
+				ByteArrayInputStream bais = new ByteArrayInputStream(postFile.getBytes());
+				dos.writeBytes("--" + split);
+				dos.writeBytes(newLine);
+				dos.writeBytes(String.format(fileHeader, postFile.getField(), URLEncoder.encode(postFile.getFileName(), "UTF-8")));
+				dos.writeBytes(newLine);
+				dos.writeBytes("Content-Type: application/octet-stream");
+				dos.writeBytes(newLine);
+				dos.writeBytes(newLine);
+
+				byte[] buffer = new byte[4096];
+				int l;
+				while ((l = bais.read(buffer)) != -1) {
+					dos.write(buffer, 0, l);
+				}
+				// 协议结尾
+				dos.writeBytes(newLine);
+				dos.writeBytes("--" + split + "--");
+				dos.writeBytes(newLine);
+			}
+			// 协议结尾
+			dos.writeBytes(newLine);
+			dos.writeBytes("--" + split + "--");
+			dos.writeBytes(newLine);
+			dos.flush();
+		}
+		// 返回
+		if (connection.getResponseCode() >= 300) {
+			throw new Exception("HTTP Request error, Response code: " + connection.getResponseCode());
+		}
+		String result = toString(connection.getInputStream());
+		connection.disconnect();
+		return result;
+	}
+
+	/**
+	 * 获取连接
+	 *
+	 * @param url         URL 地址
+	 * @param contentType Content-ContentType 数据类型
+	 * @return HTTP 连接
+	 */
+	private static HttpURLConnection getConnection(String url, ContentType contentType) throws IOException, NoSuchAlgorithmException, KeyManagementException, URISyntaxException {
+		// 转 URL 对象
+		url = url.startsWith("http") ? url : "http://" + url;
+		URL connectURL = new URI(url).toURL();
+
+		HttpURLConnection connection = (HttpURLConnection) connectURL.openConnection();
+		// SSL 连接
+		if (url.trim().startsWith("https")) {
+			SSLContext sslcontext = SSLContext.getInstance("TLS");
+			sslcontext.init(null, new TrustManager[] {new X509TrustManager() {
+
+				public X509Certificate[] getAcceptedIssuers() {
+					return null;
+				}
+
+				public void checkServerTrusted(X509Certificate[] chain, String authType) {
+				}
+
+				public void checkClientTrusted(X509Certificate[] chain, String authType) {
+				}
+			}}, null);
+			if (connection instanceof HttpsURLConnection) {
+				((HttpsURLConnection) connection).setSSLSocketFactory(sslcontext.getSocketFactory());
+			}
+		}
+		// 数据类型
+		if (contentType != null && contentType.getValue() != null) {
+			connection.setRequestProperty("Content-Type", contentType.getValue());
+		}
+		connection.setRequestProperty("Token", FMCServer.getConfiguration().getString("report.token"));
+		// 超时
+		connection.setReadTimeout(3000);
+		connection.setConnectTimeout(3000);
+		return connection;
+	}
+
+	/**
+	 * 读取数据流为字符串
+	 *
+	 * @param is 输入流
+	 * @return 字符串
+	 * @throws IOException IO 异常
+	 */
+	private static String toString(InputStream is) throws IOException {
+		StringBuilder sb = new StringBuilder();
+		BufferedInputStream bis = new BufferedInputStream(is);
+
+		InputStreamReader isr = new InputStreamReader(bis, StandardCharsets.UTF_8);
+
+		char[] buffer = new char[4096];
+		int l;
+		while ((l = isr.read(buffer)) != -1) {
+			sb.append(buffer, 0, l);
+		}
+		isr.close();
+		bis.close();
+		is.close();
+		return sb.toString();
+	}
+
+	/**
+	 * 发送文件
+	 *
+	 * @author 夜雨
+	 * @since 2024-08-07 23:50
+	 */
+	@Data
+	public static class PostFile {
+
+		/** 字段名 */
+		private String field;
+
+		/** 文件名 */
+		private String fileName;
+
+		/** 字节数据 */
+		private byte[] bytes;
+	}
+}

src/main/java/cn/forevermc/server/mcpc/util/Util.java

@@ -0,0 +1,75 @@
+package cn.forevermc.server.mcpc.util;
+
+import cn.forevermc.server.mcpc.FMCServer;
+import org.bukkit.ChatColor;
+import org.bukkit.command.CommandSender;
+import org.bukkit.entity.Player;
+
+import java.security.SecureRandom;
+import java.util.logging.Level;
+
+/**
+ * 工具
+ *
+ * @author 夜雨
+ * @since 2024-08-06 20:40
+ */
+public class Util {
+
+	/**
+	 * 空安全的字符串转枚举
+	 *
+	 * @param enumType 枚举类
+	 * @param name     枚举字段字符串
+	 * @return 枚举
+	 * @param <T> 枚举类型
+	 */
+	public static <T extends Enum<T>> T enumValueOf(Class<T> enumType, String name) {
+		if (name == null) {
+			return null;
+		}
+		T[] ts = enumType.getEnumConstants();
+		if (ts == null) {
+			throw new IllegalArgumentException(enumType.getName() + " is not an enum type");
+		}
+		for (int i = 0; i < ts.length; i++) {
+			if (ts[i].name().equalsIgnoreCase(name)) {
+				return ts[i];
+			}
+		}
+		return null;
+	}
+
+	/**
+	 * 输出指令结果，如果是控制台则输出控制台，如果是玩家则输出到玩家
+	 *
+	 * @param sender 发送者
+	 * @param level  等级
+	 * @param msg    消息
+	 */
+	public static void returnMsg(CommandSender sender, Level level, String msg) {
+		if (sender instanceof Player) {
+			Player player = (Player) sender;
+			ChatColor color = level == Level.WARNING ? ChatColor.GREEN : ChatColor.RED;
+			player.sendMessage(color + msg);
+		} else {
+			FMCServer.log(level, msg);
+		}
+	}
+
+	/**
+	 * 随机字符串
+	 *
+	 * @param length 长度
+	 * @return 随机字符串
+	 */
+	public static String randomString(int length) {
+		String pool = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789";
+		SecureRandom r = new SecureRandom();
+		StringBuilder sb = new StringBuilder();
+		for (int i = 0; i < length; i++) {
+			sb.append(pool.charAt(r.nextInt(pool.length() - 1)));
+		}
+		return sb.toString();
+	}
+}

src/main/resources/plugin.yml

@@ -0,0 +1,17 @@
+name: FMCServer
+main: cn.forevermc.server.mcpc.FMCServer
+version: '0.0.1'
+
+author: Timi
+website: imyeyu.net
+description: This plugin is ForeverMC Server status reporter
+
+commands:
+    debug:
+        description: 启用或禁用维护模式
+        usage: "/<command> [true|false|status]"
+        permission: op
+    staff:
+        description: 添加或移除维护人员
+        usage: "/<command> [add|remove|list] <value>"
+        permission: op