timi/FMCServer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

dependency FMCCore and timi-inject

Browse Source
This commit is contained in:
Timi
2025-07-24 11:20:15 +08:00
parent 8c5be21956
commit c2b5c00e8d
13 changed files with 147 additions and 826 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
pom.xml
View File

@ -6,7 +6,7 @@
<groupId>net.imyeyu.fmcserver</groupId>
<artifactId>FMCServer</artifactId>
<version>0.0.2</version>
<version>0.0.1+${mc.version}</version>
<packaging>jar</packaging>
<properties>
@ -51,9 +51,33 @@
<dependencies>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.17.0</version>
<groupId>org.spigotmc</groupId>
<artifactId>spigot-api</artifactId>
<version>1.9.4-R0.1-SNAPSHOT</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>cn.forevermc.spigot</groupId>
<artifactId>fmc-core</artifactId>
<version>0.0.1+1.9.4+</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>com.imyeyu.inject</groupId>
<artifactId>timi-inject</artifactId>
<version>0.0.1-legacy</version>
</dependency>
<dependency>
<groupId>cn.forevermc.spigot</groupId>
<artifactId>fmc-debug</artifactId>
<version>0.0.1+1.9.4+</version>
<scope>provided</scope>
<exclusions>
<exclusion>
<groupId>com.imyeyu.inject</groupId>
<artifactId>timi-inject</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
@ -70,12 +94,6 @@
<artifactId>httpclient5-fluent</artifactId>
<version>5.4.1</version>
</dependency>
<dependency>
<groupId>org.spigotmc</groupId>
<artifactId>spigot-api</artifactId>
<version>1.9.4-R0.1-SNAPSHOT</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>

68
src/main/java/cn/forevermc/server/spigot/FMCServer.java
View File

@ -1,13 +1,19 @@
package cn.forevermc.server.spigot;
import cn.forevermc.server.spigot.command.DebugCommand;
import cn.forevermc.server.spigot.event.DebugEvent;
import cn.forevermc.server.spigot.bean.Config;
import cn.forevermc.server.spigot.service.ReportService;
import lombok.Getter;
import org.apache.commons.lang3.StringUtils;
import org.bukkit.plugin.java.JavaPlugin;
import cn.forevermc.spigot.core.FMCCore;
import cn.forevermc.spigot.core.FMCPlugin;
import cn.forevermc.spigot.core.command.FMCCommand;
import com.google.gson.Gson;
import com.imyeyu.inject.InjectApp;
import com.imyeyu.inject.TimiInject;
import com.imyeyu.inject.annotation.IOCReturn;
import com.imyeyu.inject.annotation.Inject;
import com.imyeyu.inject.annotation.TimiInjectApplication;
import java.util.UUID;
import java.util.logging.Logger;
/**
* ForeverMC 服务器状态报告插件
@ -15,39 +21,51 @@ import java.util.UUID;
* @author 夜雨
* @since 2022-11-14 11:05
*/
public class FMCServer extends JavaPlugin {
@TimiInjectApplication
public class FMCServer extends FMCPlugin {
@Getter
private static FMCServer instance;
@Inject
private Config config;
private ReportService reportService;
@Inject
private ReportService service;
@Override
public void onLoad() {
instance = this;
FMCCore.register(this);
}
@Override
public void onEnable() {
saveDefaultConfig();
String reportId = getConfig().getString("report.id");
if (StringUtils.isBlank(reportId)) {
getConfig().set("report.id", UUID.randomUUID().toString());
saveConfig();
TimiInject.run(new InjectApp(this));
defaultConfig("config.yml");
if (config.getId() == null || config.getId().isEmpty()) {
config.setId(UUID.randomUUID().toString());
}
if (getConfig().getBoolean("report.enable")) {
reportService = new ReportService();
}
getCommand("debug").setExecutor(new DebugCommand());
getServer().getPluginManager().registerEvents(new DebugEvent(), this);
}
@Override
public void onDisable() {
saveConfig();
if (reportService != null && reportService.isWorking()) {
reportService.cancel();
}
saveConfigAs(config, getConfig());
}
@IOCReturn
public Gson gson() {
return new Gson();
}
@IOCReturn
public Logger log() {
return getLogger();
}
@IOCReturn
public FMCCommand fmcCommand() {
return fmcCommand;
}
@IOCReturn
public Config config() {
return loadConfigAs(Config.class, getConfig());
}
}

29
src/main/java/cn/forevermc/server/spigot/bean/Config.java Normal file
View File

@ -0,0 +1,29 @@
package cn.forevermc.server.spigot.bean;
import cn.forevermc.spigot.core.bean.ConfigPath;
import lombok.Data;
import java.util.List;
/**
* @author 夜雨
* @since 2025-07-23 23:51
*/
@Data
public class Config {
@ConfigPath("enable")
private boolean enable;
@ConfigPath("id")
private String id;
@ConfigPath("api")
private String api;
@ConfigPath("token")
private String token;
@ConfigPath("worlds")
private List<String> worlds;
}

2
src/main/java/cn/forevermc/server/spigot/bean/ReportRequest.java
View File

@ -17,7 +17,7 @@ public class ReportRequest {
private String id;
/** true 为调试中 */
private boolean debugging;
private Boolean isDebugging;
/** TPS */
private double tps;

94
src/main/java/cn/forevermc/server/spigot/bean/ServerStatusRequest.java
View File

@ -1,94 +0,0 @@
package cn.forevermc.server.spigot.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;
}
}
}
}

174
src/main/java/cn/forevermc/server/spigot/command/DebugCommand.java
View File

@ -1,174 +0,0 @@
package cn.forevermc.server.spigot.command;
import cn.forevermc.server.spigot.FMCServer;
import org.apache.commons.lang.ObjectUtils;
import org.bukkit.World;
import org.bukkit.command.Command;
import org.bukkit.command.CommandExecutor;
import org.bukkit.command.CommandSender;
import org.bukkit.configuration.ConfigurationSection;
import org.bukkit.configuration.file.FileConfiguration;
import org.bukkit.entity.Player;
import org.bukkit.scheduler.BukkitRunnable;
import java.util.Arrays;
import java.util.Collection;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.logging.Logger;
/**
* 调试指令
*
* @author 夜雨
* @since 2024-08-15 10:51
*/
public class DebugCommand implements CommandExecutor {
private final Logger log;
private BukkitRunnable freezeTimeRunnable;
private FMCServer fmcServer;
private FileConfiguration config;
public DebugCommand() {
fmcServer = FMCServer.getInstance();
config = fmcServer.getConfig();
log = fmcServer.getLogger();
List<World> worldList = fmcServer.getServer().getWorlds();
Map<String, Long> worldsTickMap = new HashMap<>();
ConfigurationSection worldsTickSection = config.getConfigurationSection("debug.worldsTick");
if (worldsTickSection != null) {
for (String key : worldsTickSection.getKeys(false)) {
worldsTickMap.put(key, (Long) ObjectUtils.defaultIfNull(worldsTickSection.getLong(key), 0L));
}
}
for (int i = 0; i < worldList.size(); i++) {
World world = worldList.get(i);
if (!worldsTickMap.containsKey(world.getName())) {
worldsTickMap.put(world.getName(), 0L);
}
}
config.set("debug.worldsTick", worldsTickMap);
fmcServer.saveConfig();
}
@Override
public boolean onCommand(CommandSender commandSender, Command command, String s, String[] strings) {
log.info(Arrays.toString(strings));
return false;
}
// public DebugCommand() {
// appendChildren("true", new ConsolePlayerCommand() {
//
// @Override
// protected void run(String[] strings) {
// enable();
// success("已启用调试模式");
// fmcServer.saveConfig();
// fmcServer.reloadConfig();
// }
// });
// appendChildren("false", new ConsolePlayerCommand() {
//
// @Override
// protected void run(String[] strings) {
// disable();
// success("已禁用调试模式");
// fmcServer.saveConfig();
// fmcServer.reloadConfig();
// }
// });
// appendChildren("status", new ConsolePlayerCommand() {
//
// @Override
// protected void run(String[] strings) {
// if (config.getDebug().isEnable()) {
// success("当前维护模式：启用");
// } else {
// success("当前维护模式：禁用");
// }
// }
// });
//
// if (config.getDebug().isEnable()) {
// enable();
// } else {
// disable();
// }
// }
// @Override
// public void run(String[] args) {
// boolean isEnable = !config.getReport().isEnable();
// config.getDebug().setEnable(isEnable);
//
// success(String.format("已%s调式模式", isEnable ? "启用" : "禁用"));
// if (isEnable) {
// enable();
// } else {
// disable();
// }
// fmcServer.saveConfig();
// fmcServer.reloadConfig();
// }
/** 启用 */
private void enable() {
// config.getDebug().setEnable(true);
List<World> worldList = fmcServer.getServer().getWorlds();
for (int i = 0; i < worldList.size(); i++) {
World world = worldList.get(i);
// 记录当前时刻
// config.getDebug().getWorldsTick().put(world.getName(), world.getFullTime());
// 正午
world.setFullTime(6000);
// 禁用天气
world.setStorm(false);
world.setThundering(false);
}
// 暂停时间
if (freezeTimeRunnable != null) {
freezeTimeRunnable.cancel();
}
freezeTimeRunnable = new BukkitRunnable() {
@Override
public void run() {
// if (config.getDebug().isEnable()) {
// fmcServer.getServer().getWorlds().forEach(world -> world.setFullTime(6000));
// }
}
};
freezeTimeRunnable.runTaskTimer(fmcServer, 0L, 200L);
// 踢出非维护人员
Collection<? extends Player> onlinePlayerList = fmcServer.getServer().getOnlinePlayers();
for (Player player : onlinePlayerList) {
if (!player.isOp()) {
player.kickPlayer("服务器正在维护，请稍后重试");
}
}
}
/** 禁用 */
private void disable() {
fmcServer.getConfig().set("debug.enable", false);
List<World> worldList = fmcServer.getServer().getWorlds();
for (int i = 0; i < worldList.size(); i++) {
World world = worldList.get(i);
// 启用天气
world.setStorm(false);
world.setThundering(false);
}
// 还原时间
if (freezeTimeRunnable != null) {
freezeTimeRunnable.cancel();
}
// config.getDebug().getWorldsTick().forEach((worldName, fullTick) -> fmcServer.getServer().getWorld(worldName).setFullTime(fullTick.longValue()));
}
}

99
src/main/java/cn/forevermc/server/spigot/command/StaffCommand.java
View File

@ -1,99 +0,0 @@
package cn.forevermc.server.spigot.command;
import cn.forevermc.server.spigot.FMCServer;
import cn.forevermc.server.spigot.util.Util;
import org.bukkit.command.Command;
import org.bukkit.command.CommandExecutor;
import org.bukkit.command.CommandSender;
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((commandSender, command, s, 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;
}
}

53
src/main/java/cn/forevermc/server/spigot/event/DebugEvent.java
View File

@ -1,53 +0,0 @@
package cn.forevermc.server.spigot.event;
import cn.forevermc.server.spigot.FMCServer;
import org.bukkit.World;
import org.bukkit.configuration.file.FileConfiguration;
import org.bukkit.event.EventHandler;
import org.bukkit.event.Listener;
import org.bukkit.event.player.PlayerJoinEvent;
import org.bukkit.event.weather.WeatherChangeEvent;
/**
* 调试事件
*
* @author 夜雨
* @since 2024-10-23 19:22
*/
public class DebugEvent implements Listener {
private final FileConfiguration config;
public DebugEvent() {
FMCServer fmcServer = FMCServer.getInstance();
config = fmcServer.getConfig();
if (config.getBoolean("debug.enable")) {
for (World world : fmcServer.getServer().getWorlds()) {
world.setStorm(false);
world.setThundering(false);
}
}
}
/** 保持晴天 */
@EventHandler
public void onWeatherChange(WeatherChangeEvent event) {
if (!config.getBoolean("debug.enable")) {
return;
}
if (event.toWeatherState()) {
event.setCancelled(true);
}
}
/** 踢出非维护人员 */
@EventHandler
public void onPlayerJoin(PlayerJoinEvent event) {
if (!config.getBoolean("debug.enable")) {
return;
}
if (!event.getPlayer().isOp()) {
event.getPlayer().kickPlayer("服务器正在维护，请稍后重试");
}
}
}

64
src/main/java/cn/forevermc/server/spigot/service/ReportService.java
View File

@ -1,23 +1,27 @@
package cn.forevermc.server.spigot.service;
import cn.forevermc.server.spigot.FMCServer;
import cn.forevermc.server.spigot.bean.Config;
import cn.forevermc.server.spigot.bean.ReportRequest;
import cn.forevermc.spigot.debug.FMCDebugInterface;
import com.google.gson.Gson;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import com.imyeyu.inject.annotation.Inject;
import com.imyeyu.inject.annotation.InvokeForInjected;
import com.imyeyu.inject.annotation.Service;
import com.sun.management.OperatingSystemMXBean;
import lombok.Getter;
import org.apache.commons.codec.binary.Base64;
import org.apache.commons.io.FileUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.hc.client5.http.fluent.Request;
import org.apache.hc.core5.http.ContentType;
import org.apache.hc.core5.util.Timeout;
import org.bukkit.Bukkit;
import org.bukkit.Server;
import org.bukkit.World;
import org.bukkit.configuration.file.FileConfiguration;
import org.bukkit.entity.Player;
import org.bukkit.plugin.Plugin;
import org.bukkit.scheduler.BukkitRunnable;
import java.io.File;
@ -35,12 +39,20 @@ import java.util.logging.Logger;
* @author 夜雨
* @since 2022-11-11 14:38
*/
@Service
public class ReportService extends BukkitRunnable {
private final Gson gson;
private final Logger log;
private final FMCServer fmcServer;
private final FileConfiguration config;
@Inject
private Config config;
@Inject
private Gson gson;
@Inject
private Logger log;
@Inject
private FMCServer fmcServer;
@Getter
private boolean isWorking = false;
@ -58,32 +70,27 @@ public class ReportService extends BukkitRunnable {
private long failAt = -1;
public ReportService() {
gson = new Gson();
bootAt = System.currentTimeMillis();
log = FMCServer.getInstance().getLogger();
config = FMCServer.getInstance().getConfig();
fmcServer = FMCServer.getInstance();
operatingSystemMXBean = ManagementFactory.getPlatformMXBean(OperatingSystemMXBean.class);
}
@InvokeForInjected
private void injected() {
try {
String api = config.getString("report.api");
if (StringUtils.isBlank(api)) {
if (config.getApi() == null || config.getApi().isEmpty()) {
throw new RuntimeException("not found report.api in config");
}
String token = config.getString("report.token");
if (StringUtils.isBlank(token)) {
if (config.getToken() == null || config.getToken().isEmpty()) {
throw new RuntimeException("not found report.token in config");
}
boolean isEnable = config.getBoolean("report.enable");
String reportId = config.getString("report.id");
log.info("report: " + isEnable);
log.info("report.id: " + reportId);
log.info("report: " + config.isEnable());
log.info("report.id: " + config.getId());
log.info("worlds: " + server.getWorlds());
if (!isEnable) {
if (!config.isEnable()) {
return;
}
reportReq.setId(reportId);
reportReq.setId(config.getId());
// TPS 计算
server.getScheduler().scheduleSyncRepeatingTask(fmcServer, new Runnable() {
@ -125,8 +132,12 @@ public class ReportService extends BukkitRunnable {
if (System.currentTimeMillis() - failAt < 1E3 * 15) {
return;
}
try {
Plugin fmcDebug = fmcServer.getServer().getPluginManager().getPlugin("FMCDebug");
if (fmcDebug instanceof FMCDebugInterface) {
FMCDebugInterface fmcDebugInterface = (FMCDebugInterface) fmcDebug;
reportReq.setIsDebugging(fmcDebugInterface.isDebugging());
}
reportReq.getOnlineList().clear();
Collection<? extends Player> players = server.getOnlinePlayers();
for (Player player : players) {
@ -134,10 +145,10 @@ public class ReportService extends BukkitRunnable {
}
reportReq.getWorldStatusList().clear();
List<String> worldList = config.getStringList("report.worlds");
List<String> worldList = config.getWorlds();
if (worldList != null) {
for (int i = 0; i < worldList.size(); i++) {
World world = fmcServer.getServer().getWorld(worldList.get(i));
for (String worldName : worldList) {
World world = fmcServer.getServer().getWorld(worldName);
ReportRequest.WorldStatus worldStatus = new ReportRequest.WorldStatus();
worldStatus.setName(world.getName());
worldStatus.setTicks(world.getFullTime());
@ -147,7 +158,6 @@ public class ReportService extends BukkitRunnable {
}
}
reportReq.setTps(tpsList);
reportReq.setDebugging(config.getBoolean("debug.enable"));
reportReq.setReportAt(System.currentTimeMillis());
reportReq.getJvm().setCpuUsed(operatingSystemMXBean.getProcessCpuLoad());
reportReq.getJvm().setName(System.getProperty("java.vm.name"));
@ -176,8 +186,8 @@ public class ReportService extends BukkitRunnable {
reportReq.setBaseInfo(null);
}
String respText = Request.post(config.getString("report.api"))
.addHeader("Token", config.getString("report.token"))
String respText = Request.post(config.getApi())
.addHeader("Token", config.getToken())
.bodyString(gson.toJson(reportReq), ContentType.APPLICATION_JSON)
.connectTimeout(Timeout.ofSeconds(60))
.execute()

252
src/main/java/cn/forevermc/server/spigot/util/HTTP.java
View File

@ -1,252 +0,0 @@
package cn.forevermc.server.spigot.util;
import cn.forevermc.server.spigot.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;
}
}

75
src/main/java/cn/forevermc/server/spigot/util/Util.java
View File

@ -1,75 +0,0 @@
package cn.forevermc.server.spigot.util;
import cn.forevermc.server.spigot.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();
}
}

16
src/main/resources/config.yml
View File

@ -1,10 +1,6 @@
report:
enable: false
id: ""
api: http://localhost:8091/fmc/server/report
token: qweqwe123
worlds:
- world
debug:
enable: false
worldsTick:
enable: false
id: ""
api: http://localhost:8091/fmc/server/report
token: qweqwe123
worlds:
- world

9
src/main/resources/plugin.yml
View File

@ -1,12 +1,9 @@
name: FMCServer
main: cn.forevermc.server.spigot.FMCServer
version: '0.0.2'
version: '0.0.1'
api-version: '1.9'
depend: [FMCCore]
author: Timi
website: forevermc.cn
description: This plugin is ForeverMC Server status reporter
commands:
debug:
description: Debug Command
usage: "/<command> [true|false|status]"