feat: 修改Communication类以优化Socket处理

zhinghu · Sep 7, 2024 · 980825c · 980825c
1 parent 7d193a9
commit 980825c
Showing 1 changed file with 16 additions and 14 deletions.
diff --git a/src/main/java/cc/baka9/catseedlogin/bukkit/Communication.java b/src/main/java/cc/baka9/catseedlogin/bukkit/Communication.java
@@ -108,22 +108,24 @@ private static void handleKeepLoggedInRequest(String playerName, String time, St
         }
     }
 
-    private static void handleConnectRequest(Socket socket, String playerName) {
-        CatScheduler.runTask(() -> {
-            boolean result = LoginPlayerHelper.isLogin(playerName);
-            CatSeedLogin.instance.runTaskAsync(() -> {
+private static void handleConnectRequest(Socket socket, String playerName) {
+    CatScheduler.runTask(() -> {
+        boolean result = LoginPlayerHelper.isLogin(playerName);
+        CatSeedLogin.instance.runTaskAsync(() -> {
+            try {
+                socket.getOutputStream().write(result ? 1 : 0);
+                socket.getOutputStream().flush(); // 确保数据发送
+            } catch (IOException e) {
+                CatSeedLogin.instance.getLogger().warning("发送连接结果时发生错误: " + e.getMessage());
+            } finally {
                 try {
-                    socket.getOutputStream().write(result ? 1 : 0);
+                    socket.close();
                 } catch (IOException e) {
-                    CatSeedLogin.instance.getLogger().warning("发送连接结果时发生错误: " + e.getMessage());
-                } finally {
-                    try {
-                        socket.close();
-                    } catch (IOException e) {
-                        CatSeedLogin.instance.getLogger().warning("关闭Socket时发生错误: " + e.getMessage());
-                    }
+                    CatSeedLogin.instance.getLogger().warning("关闭Socket时发生错误: " + e.getMessage());
                 }
-            });
+            }
         });
-    }
+    });
+}
+
 }