perf: break change: socketio传输效率优化

使用msgpack协议增加网络传输效率

Author: moonrailgun

client/shared/api/socket.ts

@@ -5,6 +5,7 @@ import { isDevelopment } from '../utils/environment';
 import { showErrorToasts, showGlobalLoading, showToasts } from '../manager/ui';
 import { t } from '../i18n';
 import { sharedEvent } from '../event';
+import msgpackParser from 'socket.io-msgpack-parser';
 
 class SocketEventError extends Error {
   name = 'SocketEventError';
@@ -211,6 +212,7 @@ export function createSocket(token: string): Promise<AppSocket> {
         token,
       },
       forceNew: true,
+      parser: msgpackParser,
     });
     _socket.once('connect', () => {
       // 连接成功

client/shared/package.json

@@ -24,6 +24,7 @@
     "react-redux": "^8.0.2",
     "regenerator-runtime": "^0.13.9",
     "socket.io-client": "^4.1.2",
+    "socket.io-msgpack-parser": "^3.0.2",
     "url-regex": "^5.0.0",
     "yup": "^0.32.9"
   },

pnpm-lock.yaml

@@ -18,6 +18,7 @@ import _ from 'lodash';
 import { ServiceUnavailableError } from 'tailchat-server-sdk';
 import { isValidStr } from '../lib/utils';
 import bcrypt from 'bcryptjs';
+import msgpackParser from 'socket.io-msgpack-parser';
 
 const blacklist: (string | RegExp)[] = ['gateway.*'];
 
@@ -476,7 +477,7 @@ export const TcSocketIOService = (
       initSocketIO() {
         if (!this.server) {
           throw new Errors.ServiceNotAvailableError(
-            '需要和 [moleculer-web] 一起使用'
+            '需要和 [ApiGatewayMixin] 一起使用'
           );
         }
         this.io = new SocketServer(this.server, {
@@ -486,6 +487,7 @@ export const TcSocketIOService = (
             origin: '*',
             methods: ['GET', 'POST'],
           },
+          parser: msgpackParser,
         });
 
         if (

server/mixins/socketio.mixin.ts

@@ -71,6 +71,7 @@
     "send": "^0.18.0",
     "serve-static": "^1.15.0",
     "socket.io": "^4.2.0",
+    "socket.io-msgpack-parser": "^3.0.2",
     "tailchat-server-sdk": "workspace:*",
     "ts-node": "^10.0.0",
     "typescript": "^4.3.3"

server/package.json

@@ -48,7 +48,7 @@ export * from './const';
 export { Utils, Errors } from 'moleculer';
 
 /**
- * 统一处理未捕获的错误
+ * 统一处理未捕获的错误, 防止直接把应用打崩
  * NOTICE: 未经测试
  */
 process.on('unhandledRejection', (reason, promise) => {