From 9d1e0ab09ebc056d61571ecbd53e4811a8406002 Mon Sep 17 00:00:00 2001 From: Shuiling <1668589925@qq.com> Date: Fri, 12 Jul 2024 05:13:23 -0700 Subject: [PATCH] =?UTF-8?q?feat(Communication):=20=E8=B0=83=E6=95=B4?= =?UTF-8?q?=E4=BB=A3=E7=A0=81=E7=BB=93=E6=9E=84=EF=BC=8C=E4=BC=98=E5=8C=96?= =?UTF-8?q?=E8=AF=B7=E6=B1=82=E5=A4=84=E7=90=86=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../catseedlogin/bukkit/Communication.java | 54 ++++++++++--------- 1 file changed, 30 insertions(+), 24 deletions(-) diff --git a/src/main/java/cc/baka9/catseedlogin/bukkit/Communication.java b/src/main/java/cc/baka9/catseedlogin/bukkit/Communication.java index 59c031a..ce68aa1 100644 --- a/src/main/java/cc/baka9/catseedlogin/bukkit/Communication.java +++ b/src/main/java/cc/baka9/catseedlogin/bukkit/Communication.java @@ -1,12 +1,5 @@ package cc.baka9.catseedlogin.bukkit; -import cc.baka9.catseedlogin.bukkit.database.Cache; -import cc.baka9.catseedlogin.bukkit.object.LoginPlayer; -import cc.baka9.catseedlogin.bukkit.object.LoginPlayerHelper; -import cc.baka9.catseedlogin.util.CommunicationAuth; -import org.bukkit.Bukkit; -import org.bukkit.entity.Player; - import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; @@ -15,6 +8,14 @@ import java.net.Socket; import java.net.UnknownHostException; +import org.bukkit.Bukkit; +import org.bukkit.entity.Player; + +import cc.baka9.catseedlogin.bukkit.database.Cache; +import cc.baka9.catseedlogin.bukkit.object.LoginPlayer; +import cc.baka9.catseedlogin.bukkit.object.LoginPlayerHelper; +import cc.baka9.catseedlogin.util.CommunicationAuth; + /** * bukkit 与 bc 的通讯交流 */ @@ -75,24 +76,29 @@ private static void socketServerStart() { /** * 处理请求 */ - private static void handleRequest(Socket socket) throws IOException { - BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream())); - String requestType = bufferedReader.readLine(); - String playerName = bufferedReader.readLine(); - switch (requestType) { - case "Connect": - handleConnectRequest(socket, playerName); - break; - case "KeepLoggedIn": - String time = bufferedReader.readLine(); - String sign = bufferedReader.readLine(); - handleKeepLoggedInRequest(playerName, time, sign); - socket.close(); - break; - default: - break; - } +private static void handleRequest(Socket socket) throws IOException { + BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream())); + String requestType = bufferedReader.readLine(); + String playerName = bufferedReader.readLine(); + switch (requestType) { + case "Connect": + handleConnectRequest(socket, playerName); + break; + case "KeepLoggedIn": + String time = bufferedReader.readLine(); + String sign = bufferedReader.readLine(); + handleKeepLoggedInRequest(playerName, time, sign); + socket.close(); + break; + default: + break; + } + + if (playerName != null) { + playerName.hashCode(); + } else { } +} private static void handleKeepLoggedInRequest(String playerName, String time, String sign) { // 验证请求的合法性