add eventemmit

example/main.ts

@@ -1,7 +1,7 @@
 import { Client } from '../src/';
 import { WebsocketError, WebSocketResp } from '../src/types';
 
-const url = 'ws://127.0.0.1:8081';
+const url = 'ws://127.0.0.1:8085';
 const client = Client.getInstance(url, {
   onOpen(): void {
     client

package.json

@@ -1,6 +1,6 @@
 {
   "name": "ts-linker-sdk",
-  "version": "1.0.6",
+  "version": "1.0.7",
   "description": "linker's ts sdk",
   "main": "dist/index.js",
   "types": "dist/types/index.d.ts",
@@ -22,6 +22,7 @@
   "license": "private",
   "dependencies": {
     "crypto-js": "^3.1.9-1",
+    "eventemitter3": "^4.0.0",
     "node-int64": "^0.4.0"
   },
   "devDependencies": {
@@ -47,12 +48,12 @@
     "eslint-loader": "^2.1.2",
     "html-webpack-plugin": "^3.2.0",
     "jest": "^24.5.0",
-    "webpack-dev-server": "^3.3.1",
     "rimraf": "^2.6.3",
     "ts-jest": "^24.0.0",
     "typescript": "3.5",
     "webpack": "^4.30.0",
-    "webpack-cli": "^3.3.2"
+    "webpack-cli": "^3.3.2",
+    "webpack-dev-server": "^3.3.1"
   },
   "files": [
     "dist/"

src/index.ts

@@ -5,6 +5,7 @@ import {
   WebSocketResp,
   ReadyStateCallback,
 } from './types/index';
+import EventEmitter from 'eventemitter3';
 
 const clientError = 400;
 
@@ -15,7 +16,7 @@ class Client {
   private _maxPayload: number;
   private _enableLogger: boolean;
   private static instance: Client;
-  private listeners: Map<number, (data: WebSocketResp) => void>;
+  private listeners: EventEmitter;
   private requestHeader: string;
   private responseHeader: string;
   private url: string;
@@ -30,7 +31,7 @@ class Client {
    * @param readyStateCallback 链接状态回调，可以处理onOpen、onClose、onError
    */
   private constructor(url: string, readyStateCallback: ReadyStateCallback) {
-    this.listeners = new Map<number, (data: WebSocketResp) => void>();
+    this.listeners = new EventEmitter();
     this.requestHeader = '';
     this.requestHeader = '';
     this._maxPayload = 1024 * 1024;
@@ -103,8 +104,8 @@ class Client {
 
         const heartbeatOperator = 0;
 
-        this.listeners.set(
-          heartbeatOperator,
+        this.listeners.addListener(
+          heartbeatOperator.toString(),
           (data: WebSocketResp): void => {
             const code = this.getResponseProperty('code');
             if (code !== '') {
@@ -162,7 +163,7 @@ class Client {
     operator: string,
     listener: (data: WebSocketResp) => void,
   ): void {
-    this.listeners.set(Utils.crc32(operator), listener);
+    this.listeners.addListener(Utils.crc32(operator).toString(), listener);
   }
 
   /**
@@ -170,7 +171,7 @@ class Client {
    * @param operator 消息监听地址
    */
   public removeMessageListener(operator: string): void {
-    delete this.listeners[Utils.crc32(operator)];
+    this.listeners.removeListener(Utils.crc32(operator).toString());
   }
 
   /**
@@ -298,17 +299,17 @@ class Client {
             }
 
             let operator = Number(packet.operator) + Number(packet.sequence);
-            if (this.listeners.has(operator)) {
+            let listener = operator.toString();
+
+            this.listeners.listeners(listener).forEach((param): void => {
               if (packet.body === '') {
                 packet.body = '{}';
               }
 
               this.responseHeader = packet.header;
 
-              (this.listeners.get(operator) as (data: WebSocketResp) => void)(
-                JSON.parse(packet.body),
-              );
-            }
+              (param as (data: WebSocketResp) => void)(JSON.parse(packet.body));
+            });
 
             if (this._enableLogger) {
               if (operator !== 0 && packet.body !== 'null') {
@@ -392,8 +393,8 @@ class Client {
 
         const sequence = new Date().getTime();
         const listener = Utils.crc32(operator) + sequence;
-        this.listeners.set(
-          listener,
+        this.listeners.addListener(
+          listener.toString(),
           (data: WebSocketResp): void => {
             const code = this.getResponseProperty('code');
             if (code !== '') {

yarn.lock

@@ -2919,6 +2919,10 @@ eventemitter3@^3.0.0:
   version "3.1.2"
   resolved "https://registry.npm.taobao.org/eventemitter3/download/eventemitter3-3.1.2.tgz#2d3d48f9c346698fce83a85d7d664e98535df6e7"
 
+eventemitter3@^4.0.0:
+  version "4.0.0"
+  resolved "https://registry.yarnpkg.com/eventemitter3/-/eventemitter3-4.0.0.tgz#d65176163887ee59f386d64c82610b696a4a74eb"
+
 events@^3.0.0:
   version "3.0.0"
   resolved "https://registry.npm.taobao.org/events/download/events-3.0.0.tgz#9a0a0dfaf62893d92b875b8f2698ca4114973e88"