feat: 可将 wss error 加入重连

Author: Kloping

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>io.github.kloping</groupId>
     <artifactId>bot-qqpd-java</artifactId>
-    <version>1.5.1-R3</version>
+    <version>1.5.1-R4</version>
 
     <packaging>jar</packaging>
     <name>bot-qqpd-java</name>
@@ -49,7 +49,7 @@
         <dependency>
             <groupId>io.github.Kloping</groupId>
             <artifactId>SpringTool</artifactId>
-            <version>0.6.3-L1</version>
+            <version>0.6.3-L2</version>
             <exclusions>
                 <exclusion>
                     <groupId>io.github.Kloping</groupId>

src/main/java/io/github/kloping/qqbot/Starter.java

@@ -11,6 +11,7 @@
 import io.github.kloping.qqbot.utils.LoggerImpl;
 import io.github.kloping.spt.StarterObjectApplication;
 import io.github.kloping.spt.annotations.Entity;
+import io.github.kloping.spt.interfaces.AutomaticWiringValue;
 import io.github.kloping.spt.interfaces.component.ContextManager;
 import io.github.kloping.spt.interfaces.component.HttpClientManager;
 import lombok.Data;
@@ -149,6 +150,14 @@ protected void after() {
     }
 
     protected void wssWork() {
+        AutomaticWiringValue automaticWiringValue = contextManager.getContextEntity(AutomaticWiringValue.class);
+        if (config.getWebSocketListener() != null) {
+            try {
+                automaticWiringValue.wiring(config.getWebSocketListener(), contextManager);
+            } catch (Exception e) {
+                APPLICATION.logger.error(e.getMessage() + "\n\tat " + getExceptionLine(e));
+            }
+        }
         Future future = Public.EXECUTOR_SERVICE.submit(wssWorker);
         APPLICATION.INSTANCE.getContextManager().append(future, MAIN_FUTURE_ID);
     }

src/main/java/io/github/kloping/qqbot/impl/BaseConnectedEvent.java

@@ -41,7 +41,7 @@ public String getClassName() {
 
     @Override
     public String toString() {
-        return String.format("Bot(%s) Connected! By author kloping of bot-qqpd-java for version 1.5.1-R3", bot.getConfig().getAppid());
+        return String.format("Bot(%s) Connected! By author kloping of bot-qqpd-java for version 1.5.1-R4", bot.getConfig().getAppid());
     }
 
     @Override

src/main/java/io/github/kloping/qqbot/network/AuthAndHeartbeat.java

@@ -77,7 +77,7 @@ public void onClose(int code, WebSocketClient wss) {
     @AutoStand
     Config config;
 
-    private void identifyConnect(int code, WebSocketClient wss) {
+    public void identifyConnect(int code, WebSocketClient wss) {
         if (!config.getReconnect()) return;
         Future future = contextManager.getContextEntity(Future.class, Starter.MAIN_FUTURE_ID);
         if (future != null && !future.isCancelled()) {

src/test/java/test_onError.java

@@ -0,0 +1,36 @@
+import io.github.kloping.qqbot.Starter;
+import io.github.kloping.qqbot.api.Intents;
+import io.github.kloping.qqbot.network.AuthAndHeartbeat;
+import io.github.kloping.qqbot.network.WebSocketListener;
+import io.github.kloping.spt.annotations.AutoStand;
+import org.java_websocket.client.WebSocketClient;
+
+/**
+ * 将 wss error 加入重连
+ * @author github.kloping
+ */
+public class test_onError implements WebSocketListener {
+
+    @AutoStand
+    AuthAndHeartbeat authAndHeartbeat;
+
+    @AutoStand
+    Starter starter;
+
+    @Override
+    public boolean onError(WebSocketClient client, Exception e) {
+        //尝试重连
+        authAndHeartbeat.identifyConnect(0, client);
+        return WebSocketListener.super.onError(client, e);
+    }
+
+    public static void main(String[] args) throws Exception {
+        Starter starter = new Starter("xxx", "xxx");
+        starter.getConfig().setCode(Intents.PRIVATE_INTENTS.getCode());
+        //设置websocket 监听
+        starter.getConfig().setWebSocketListener(new test_onError());
+        //切换沙盒
+        starter.getConfig().sandbox();
+        starter.run();
+    }
+}