perf: 优化与go-cqhttp的通信

2023-04-26 14:52:09 +08:00
parent 9887cae43c
commit a78984376f
1 changed files with 18 additions and 5 deletions
@@ -91,16 +91,29 @@ qqchan_loop = None
 # QQ机器人
 gocq_bot = None
 PLATFORM_GOCQ = 'gocq'
-gocq_app = CQHTTP(
-    host="127.0.0.1",
-    port=6700,
-    http_port=5700,
-)
+gocq_app = None
+
 gocq_loop = None
 nick_qq = "ai "

 bing_cache_loop = None

+def gocq_runner():
+    global gocq_app
+    ok = False
+    while not ok:
+        try:
+            gocq_app = CQHTTP(
+                host="127.0.0.1",
+                port=6700,
+                http_port=5700,
+            )
+            ok = True
+        except BaseException as e:
+            print("[System-err] 连接到go-cqhttp异常, 5秒后重试。"+str(e))
+
+threading.Thread(target=gocq_runner, daemon=True).start()
+

 def new_sub_thread(func, args=()):
    thread = threading.Thread(target=func, args=args, daemon=True)