update

src/controller/basicController.js

@@ -1,23 +1,24 @@
-import { pubClient } from "../connection/redis.js";
-import { ROLES, CODEMEG, EVENT, FROMTYPE } from "../enum/index.js";
-
-import { logger } from "../core/logger.js";
-import { getSig } from "../core/getSig.js";
-
-export class BasicController {
-  constructor(io, socket, pubClient) {
-    this.io = io;
-    this.socket = socket;
-    this.redisCli = pubClient;
-    this.logger = logger;
-    this.getSig = getSig;
-  }
-
-  isHoster = (role) => {
-    return String(role).toLowerCase() === ROLES.LEADER;
-  };
-  issAssistant = (role) => {
-    return String(role).toLowerCase() === ROLES.ASSISTANT;
-  };
-  run() {}
-}
+import { pubClient, subClient } from "../connection/redis.js";
+import { ROLES, CODEMEG, EVENT, FROMTYPE } from "../enum/index.js";
+
+import { logger } from "../core/logger.js";
+import { getSig } from "../core/getSig.js";
+
+export class BasicController {
+  constructor(io, socket, pubClient) {
+    this.io = io;
+    this.socket = socket;
+    this.redisCli = pubClient;
+    this.redisSubClient = subClient;
+    this.logger = logger;
+    this.getSig = getSig;
+  }
+
+  isHoster = (role) => {
+    return String(role).toLowerCase() === ROLES.LEADER;
+  };
+  issAssistant = (role) => {
+    return String(role).toLowerCase() === ROLES.ASSISTANT;
+  };
+  run() {}
+}

src/controller/connectController.js

@@ -14,6 +14,11 @@ export class ConnectController extends BasicController {
     await this.roomController.run();
     await this.syncDeviceController.run();
 
+    this.redisSubClient.subscribe("dismissRoom", (message) => {
+      console.log(message); // 'message'
+      this.roomController.logger("subscribe-订阅", JSON.stringify(message));
+    });
+
     this.socket.on("disconnect", async (reason) => {
       const res = String(reason).split(" ");
       console.log("disconnect-reason", res);