添加连接WS服务器，执行任意自定义指令和发送消息

Author: Gingmzmzx

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>center.xzy.qb</groupId>
     <artifactId>MessageSync</artifactId>
-    <version>1.8-SNAPSHOT</version>
+    <version>1.9-SNAPSHOT</version>
     <packaging>jar</packaging>
 
     <name>MessageSync</name>
@@ -86,5 +86,15 @@
             <artifactId>TitleManager</artifactId>
             <version>2.2.0</version>
         </dependency>
+        <dependency>
+            <groupId>org.java-websocket</groupId>
+            <artifactId>Java-WebSocket</artifactId>
+            <version>1.3.5</version>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.47</version>
+        </dependency>
     </dependencies>
 </project>

src/main/java/center/xzy/qb/messagesync/Main.java

@@ -1,16 +1,16 @@
 package center.xzy.qb.messagesync;
 
 import center.xzy.qb.messagesync.executor.*;
-import center.xzy.qb.messagesync.commands.*;
-import org.bukkit.GameMode;
 import org.bukkit.Material;
 import org.bukkit.inventory.ItemStack;
 import org.bukkit.inventory.meta.ItemMeta;
 import org.bukkit.plugin.java.JavaPlugin;
 import org.bukkit.ChatColor;
 import center.xzy.qb.messagesync.events.*;
 import org.bukkit.plugin.Plugin;
+import center.xzy.qb.messagesync.socket.SocketClient;
 
+import java.net.URISyntaxException;
 import java.security.MessageDigest;
 import java.security.NoSuchAlgorithmException;
 import java.util.Arrays;
@@ -21,7 +21,6 @@
 import java.sql.DriverManager;
 import java.sql.SQLException;
 import java.sql.Statement;
-import java.sql.ResultSet;
 
 public final class Main extends JavaPlugin {
     public static boolean pluginStatus = true;
@@ -31,6 +30,7 @@ public final class Main extends JavaPlugin {
     public static Map<String, List<String>> regData = new HashMap<>();  // 注册（二次输入密码）储存的玩家数据
     public static Map<String, String> regIpData = new HashMap<>();  // prelogin储存的登录IP数据
     public static Connection dbConn;  // 数据库连接，在`onEnable`方法中初始化
+    public static SocketClient socket;
 
     @Override
     public void onEnable() {
@@ -59,6 +59,18 @@ public void onEnable() {
         // check TitleManager
         // more code...
 
+        // WebSocket
+        if (getConfig().getBoolean("enable-socket")){
+            try {
+                socket = new SocketClient(plugin.getConfig().getString("socket-uri"));
+                socket.connect();
+//                socket.send("{\"type\":\"init\",\"client_id\":\"" +plugin.getConfig().getString("socket-client_id")+ "\",\"client_secret\":\"" +plugin.getConfig().getString("socket-client_secret")+ "\",\"data\":{}}");
+                getLogger().info(ChatColor.GREEN + "已连接WebSocket服务器");
+            } catch (URISyntaxException e) {
+                getLogger().warning(ChatColor.RED + "连接WebSocket服务器失败：" + e.getMessage());
+            }
+        }
+
         // log information
         getLogger().info(ChatColor.GREEN + "More info on " + ChatColor.BLUE + "https://minept.top");
         getLogger().info(ChatColor.GREEN + "Enabled MessageSync Plugin for PBF!");

src/main/java/center/xzy/qb/messagesync/events/customEventHandler.java

@@ -100,7 +100,7 @@ public void PlayerLogin(PlayerJoinEvent event) {
 
             PlayerLogin playerLogin = new PlayerLogin();
             playerLogin.setPlayer(event.getPlayer());
-            playerLogin.runTaskLater(Main.instance, timeout);
+            playerLogin.runTaskLater(Main.getPlugin(Main.class), timeout);
             Player player = event.getPlayer();
             if (Main.gmData.containsKey(player.getName())){
                 Main.gmData.replace(player.getName(), player.getGameMode().toString());

src/main/java/center/xzy/qb/messagesync/executor/sayHandler.java

@@ -2,7 +2,6 @@
 
 import center.xzy.qb.messagesync.Main;
 import org.bukkit.ChatColor;
-import org.bukkit.Bukkit;
 import org.bukkit.command.Command;
 import org.bukkit.command.CommandExecutor;
 import org.bukkit.command.CommandSender;
@@ -19,9 +18,9 @@ public boolean onCommand(CommandSender sender, Command command, String label, St
             msg += args[i] +" ";
         }
         if (sender instanceof Player){
-            Bukkit.broadcastMessage("<" + sender.getName() + "> " + msg);
+            Main.instance.getServer().broadcastMessage("<" + sender.getName() + "> " + msg);
         }else {
-            Bukkit.broadcastMessage(plugin.getConfig().getString("say-prefix") + " " + msg);
+            Main.instance.getServer().broadcastMessage(plugin.getConfig().getString("say-prefix") + " " + msg);
         }
         return true;
     }

src/main/java/center/xzy/qb/messagesync/socket/SocketClient.java

@@ -0,0 +1,59 @@
+package center.xzy.qb.messagesync.socket;
+
+import java.net.URI;
+import java.net.URISyntaxException;
+
+import com.alibaba.fastjson.JSONObject;
+import org.bukkit.Bukkit;
+import org.bukkit.ChatColor;
+import org.bukkit.plugin.Plugin;
+import org.bukkit.scheduler.BukkitRunnable;
+import org.java_websocket.client.WebSocketClient;
+import org.java_websocket.handshake.ServerHandshake;
+
+import center.xzy.qb.messagesync.Main;
+
+public class SocketClient extends WebSocketClient{
+    Plugin plugin = Main.getPlugin(Main.class);
+
+    public SocketClient(String url) throws URISyntaxException {
+        super(new URI(url));
+        // TODO Auto-generated constructor stub
+    }
+
+    @Override
+    public void onOpen(ServerHandshake shake) {
+        // 发送init请求
+        send("{\"type\":\"init\",\"client_id\":\"" +plugin.getConfig().getString("socket-client_id")+ "\",\"client_secret\":\"" +plugin.getConfig().getString("socket-client_secret")+ "\",\"data\":{}}");
+    }
+
+    @Override
+    public void onMessage(String paramString) {
+        // TODO Auto-generated method stub
+        Main.instance.getLogger().warning(ChatColor.BLUE + "WebSocket收到消息：" + paramString);
+        JSONObject object = JSONObject.parseObject(paramString);
+        switch (object.getString("type")){
+            case "command":
+                Bukkit.getScheduler().runTask(Main.instance, () -> {
+                    Main.instance.getServer().dispatchCommand(Main.instance.getServer().getConsoleSender(), object.getJSONObject("data").getString("cmd"));
+                });
+                break;
+
+            case "message":
+                Main.instance.getServer().broadcastMessage(plugin.getConfig().getString("say-prefix") + " " + object.getJSONObject("data").getString("msg"));
+                break;
+        }
+    }
+
+    @Override
+    public void onClose(int paramInt, String paramString, boolean paramBoolean) {
+        // TODO Auto-generated method stub
+        Main.instance.getLogger().warning(ChatColor.RED + "WebSocket被关闭：" + paramString);
+    }
+
+    @Override
+    public void onError(Exception e) {
+        // TODO Auto-generated method stub
+        Main.instance.getLogger().warning(ChatColor.RED + "WebSocket异常：" + e.getMessage());
+    }
+}

src/main/resources/config.yml

@@ -20,4 +20,10 @@ reg-ip-max-fail-msg: "当前IP注册ID数量已达上限！"  # 当IP注册数
 login-allow-tick: 600  # 指定tick后还未登录就踢出玩家
 login-allow-tick-msg: "登录已超时，请重新进入"  # 登录超时时提示的消息
 reg-allow-tick: 1200  # 指定tick后还未注册就踢出玩家
-reg-allow-tick-msg: "注册已超时，请重新进入"  # 注册超时时提示的消息
+reg-allow-tick-msg: "注册已超时，请重新进入"  # 注册超时时提示的消息
+
+# socket设置
+enable-socket: true  # 是否启用socket通信（见 https://socket.xzy.center）
+socket-client_id: "123"  # client_id
+socket-client_secret: "123"  # client_secret
+socket-uri: "wss://socket.xzy.center/ws"  # SocketURI 正常情况下请不要修改