add example

.gitignore

@@ -1 +1,2 @@
 node_modules
+dist

.vscode/launch.json

@@ -0,0 +1,30 @@
+{
+    // Use IntelliSense to learn about possible attributes.
+    // Hover to view descriptions of existing attributes.
+    // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+    "version": "0.2.0",
+    "configurations": [
+        {
+            "type": "node",
+            "name": "vscode-jest-tests",
+            "request": "launch",
+            "args": [
+                "--runInBand"
+            ],
+            "cwd": "${workspaceFolder}",
+            "console": "integratedTerminal",
+            "internalConsoleOptions": "neverOpen",
+            "program": "${workspaceFolder}/node_modules/jest/bin/jest"
+        },
+        {
+            "type": "node",
+            "request": "launch",
+            "name": "Launch Program",
+            "program": "${workspaceFolder}/index.js",
+            "preLaunchTask": "tsc: build - tsconfig.json",
+            "outFiles": [
+                "${workspaceFolder}/dist/**/*.js"
+            ]
+        }
+    ]
+}

.vscode/tasks.json

@@ -0,0 +1,15 @@
+{
+    // See https://go.microsoft.com/fwlink/?LinkId=733558
+    // for the documentation about the tasks.json format
+    "version": "2.0.0",
+    "tasks": [
+        {
+            "type": "typescript",
+            "tsconfig": "tsconfig.json",
+            "option": "watch",
+            "problemMatcher": [
+                "$tsc-watch"
+            ]
+        }
+    ]
+}

dist/callback.js

@@ -1,3 +0,0 @@
-"use strict";
-exports.__esModule = true;
-//# sourceMappingURL=callback.js.map

dist/callback.js.map

@@ -1 +0,0 @@
-{"version":3,"file":"callback.js","sourceRoot":"","sources":["../src/callback.ts"],"names":[],"mappings":""}

dist/constant.js

@@ -1,7 +0,0 @@
-"use strict";
-exports.__esModule = true;
-// 单个数据包能够传输的最大数据量
-exports.MAX_PAYLOAD = 1024 * 1024;
-// 版本
-exports.VERSION = '1.0';
-//# sourceMappingURL=constant.js.map

dist/constant.js.map

@@ -1 +0,0 @@
-{"version":3,"file":"constant.js","sourceRoot":"","sources":["../src/constant.ts"],"names":[],"mappings":";;AAAA,kBAAkB;AACL,QAAA,WAAW,GAAG,IAAI,GAAG,IAAI,CAAC;AAEvC,KAAK;AACQ,QAAA,OAAO,GAAG,KAAK,CAAC"}

dist/index.js

@@ -1,284 +0,0 @@
-"use strict";
-var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
-    return new (P || (P = Promise))(function (resolve, reject) {
-        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
-        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
-        step((generator = generator.apply(thisArg, _arguments || [])).next());
-    });
-};
-var __generator = (this && this.__generator) || function (thisArg, body) {
-    var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
-    return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
-    function verb(n) { return function (v) { return step([n, v]); }; }
-    function step(op) {
-        if (f) throw new TypeError("Generator is already executing.");
-        while (_) try {
-            if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
-            if (y = 0, t) op = [op[0] & 2, t.value];
-            switch (op[0]) {
-                case 0: case 1: t = op; break;
-                case 4: _.label++; return { value: op[1], done: false };
-                case 5: _.label++; y = op[1]; op = [0]; continue;
-                case 7: op = _.ops.pop(); _.trys.pop(); continue;
-                default:
-                    if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
-                    if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
-                    if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
-                    if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
-                    if (t[2]) _.ops.pop();
-                    _.trys.pop(); continue;
-            }
-            op = body.call(thisArg, _);
-        } catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
-        if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
-    }
-};
-exports.__esModule = true;
-var constant = require("./constant");
-var packet_1 = require("./packet");
-var utils_1 = require("./utils");
-/**
- * Client ws client, 单例模式, 负责维护连接
- */
-var Client = /** @class */ (function () {
-    function Client(url, readyStateCallback) {
-        if (!('WebSocket' in window)) {
-            return;
-        }
-        this.requestHeader = '';
-        this.maxPayload = constant.MAX_PAYLOAD;
-        this.url = url;
-        this.readyStateCallback = readyStateCallback;
-        this.reconnectTimes = 0;
-        this.reconnectLock = false;
-        this.socket = this.connect();
-    }
-    // 向服务端发送ping包保持长连接
-    Client.prototype.ping = function (param, callback) {
-        if (param === void 0) { param = {}; }
-        if (callback === void 0) { callback = {}; }
-        if (typeof callback !== 'object') {
-            throw new Error('callback must be an object');
-        }
-        if (this.socket.readyState !== this.socket.OPEN) {
-            throw new Error('asyncSend: connection refuse');
-        }
-        var _this = this;
-        this.addMessageListener(0, function (data) {
-            var code = _this.getResponseProperty('code');
-            if (typeof code !== 'undefined') {
-                var message = _this.getResponseProperty('message');
-                if (this.callback.onError !== null) {
-                    this.callback.onError(code, message);
-                }
-            }
-            else {
-                this.callback.onSuccess(data);
-            }
-            this.callback.onEnd();
-        });
-        var p = new packet_1.Packet();
-        _this.send(p.pack(0, 0, _this.requestHeader, JSON.stringify(param)));
-    };
-    Client.prototype.send = function (data) {
-        if (this.socket.readyState !== this.socket.OPEN) {
-            console.error('WebSocket is already in CLOSING or CLOSED state.');
-            return;
-        }
-        try {
-            this.socket.send(data);
-        }
-        catch (e) {
-            console.log('send data error', e);
-        }
-    };
-    /**
-     * asyncSend
-     * @param {*} operator
-     * @param {*} param
-     * @param {*} callback 仅此次有效的callback
-     */
-    Client.prototype.asyncSend = function (operator, param, callback) {
-        console.info('websocket send data', operator, this.requestHeader, param);
-        if (typeof callback !== 'object') {
-            throw new Error('callback must be an object');
-        }
-        if (this.socket.readyState !== this.socket.OPEN) {
-            throw new Error('asyncSend: connection refuse');
-        }
-        if (callback.hasOwnProperty('onStart') &&
-            typeof callback.onStart === 'function') {
-            callback.onStart();
-        }
-        var _this = this;
-        var sequence = new Date().getTime();
-        var listener = utils_1.Utils.crc32(operator) + sequence;
-        this.callback[listener] = function (data) {
-            var code = _this.getResponseProperty('code');
-            if (typeof code !== 'undefined') {
-                var message = _this.getResponseProperty('message');
-                if (callback.hasOwnProperty('onError') &&
-                    typeof callback.onError === 'function') {
-                    callback.onError(code, message);
-                }
-            }
-            else {
-                if (callback.hasOwnProperty('onSuccess') &&
-                    typeof callback.onSuccess === 'function') {
-                    callback.onSuccess(data);
-                }
-            }
-            if (callback.hasOwnProperty('onEnd') &&
-                typeof callback.onEnd === 'function') {
-                callback.onEnd();
-            }
-            delete _this.callback[listener];
-        };
-        var p = new packet_1.Packet();
-        this.send(p.pack(utils_1.Utils.crc32(operator), sequence, this.requestHeader, JSON.stringify(param)));
-    };
-    // 同步请求服务端数据
-    Client.prototype.syncSend = function (operator, param, callback) {
-        return __awaiter(this, void 0, void 0, function () {
-            return __generator(this, function (_a) {
-                switch (_a.label) {
-                    case 0: return [4 /*yield*/, this.asyncSend(operator, param, callback)];
-                    case 1:
-                        _a.sent();
-                        return [2 /*return*/];
-                }
-            });
-        });
-    };
-    // 添加消息监听
-    Client.prototype.addMessageListener = function (operator, listener) {
-        this.callback[utils_1.Utils.crc32(operator)] = listener;
-    };
-    // 移除消息监听
-    Client.prototype.removeMessageListener = function (operator) {
-        delete this.callback[utils_1.Utils.crc32(operator)];
-    };
-    // 获取socket的链接状态
-    Client.prototype.getReadyState = function () {
-        return this.socket.readyState;
-    };
-    // 设置单个请求能够处理的最大字节数
-    Client.prototype.setMaxPayload = function (maxPayload) {
-        this.maxPayload = maxPayload;
-    };
-    // 设置请求属性
-    Client.prototype.setRequestProperty = function (key, value) {
-        var v = this.getRequestProperty(key);
-        this.requestHeader = this.requestHeader.replace(key + '=' + v + ';', '');
-        this.requestHeader = this.requestHeader + key + '=' + value + ';';
-    };
-    // 获取请求属性
-    Client.prototype.getRequestProperty = function (key) {
-        var values = this.requestHeader.split(';');
-        for (var index in values) {
-            var kv = values[index].split('=');
-            if (kv[0] === key) {
-                return kv[1];
-            }
-        }
-    };
-    // 设置Response属性
-    Client.prototype.setResponseProperty = function (key, value) {
-        var v = this.getResponseProperty(key);
-        this.responseHeader = this.responseHeader.replace(key + '=' + v + ';', '');
-        this.responseHeader = this.responseHeader + key + '=' + value + ';';
-    };
-    // 获取响应属性
-    Client.prototype.getResponseProperty = function (key) {
-        var values = this.responseHeader.split(';');
-        for (var index in values) {
-            var kv = values[index].split('=');
-            if (kv[0] === key) {
-                return kv[1];
-            }
-        }
-    };
-    // 创建连接
-    Client.prototype.connect = function () {
-        var url = this.url;
-        var readyStateCallback = this.readyStateCallback;
-        var ws = new WebSocket(url);
-        var _this = this;
-        ws.binaryType = 'blob';
-        ws.onopen = function (ev) {
-            console.info('websocket connected');
-            _this.reconnectTimes = 0;
-            if (readyStateCallback.hasOwnProperty('onopen') &&
-                typeof readyStateCallback.onopen === 'function') {
-                readyStateCallback.onopen(ev);
-            }
-        };
-        ws.onclose = function (ev) {
-            console.info('websocket disconnected');
-            _this.reconnect();
-            if (readyStateCallback.hasOwnProperty('onclose') &&
-                typeof readyStateCallback.onclose === 'function') {
-                readyStateCallback.onclose(ev);
-            }
-        };
-        ws.onerror = function (ev) {
-            console.info('websocket error disconnected');
-            _this.reconnect();
-            if (readyStateCallback.hasOwnProperty('onerror') &&
-                typeof readyStateCallback.onerror === 'function') {
-                readyStateCallback.onerror(ev);
-            }
-        };
-        ws.onmessage = function (ev) {
-            if (ev.data instanceof Blob) {
-                var reader = new FileReader();
-                reader.readAsArrayBuffer(ev.data);
-                reader.onload = function () {
-                    try {
-                        var packet = new packet_1.Packet().unPack(this.result);
-                        var packetLength = packet.headerLength + packet.bodyLength + 20;
-                        if (packetLength > constant.MAX_PAYLOAD) {
-                            throw new Error('the packet is big than ' + constant.MAX_PAYLOAD);
-                        }
-                        var operator = Number(packet.operator) + Number(packet.sequence);
-                        if (_this.callback.hasOwnProperty(operator)) {
-                            if (packet.body === '') {
-                                packet.body = '{}';
-                            }
-                            _this.responseHeader = packet.header;
-                            _this.callback[operator](JSON.parse(packet.body));
-                        }
-                        if (operator !== 0 && packet.body !== 'null') {
-                            console.info('receive data', packet.body);
-                        }
-                    }
-                    catch (e) {
-                        console.info(e);
-                        throw new Error(e);
-                    }
-                };
-            }
-            else {
-                throw new Error('websocket unsupported data format');
-            }
-        };
-        return ws;
-    };
-    Client.prototype.reconnect = function () {
-        var _this_1 = this;
-        if (!this.reconnectLock) {
-            this.reconnectLock = true;
-            console.info('websocket reconnect in ' + this.reconnectTimes + 's');
-            // 尝试重连
-            setTimeout(function () {
-                _this_1.reconnectTimes++;
-                _this_1.socket = _this_1.connect();
-                _this_1.reconnectLock = false;
-            }, this.reconnectTimes * 1000);
-        }
-    };
-    return Client;
-}());
-exports.Client = Client;
-//# sourceMappingURL=index.js.map

dist/packet.js

@@ -1,47 +0,0 @@
-"use strict";
-exports.__esModule = true;
-var utils_1 = require("./utils");
-var Int64 = require("node-int64");
-var Packet = /** @class */ (function () {
-    function Packet() {
-        this.key = 'b8ca9aa66def05ff3f24919274bb4a66';
-    }
-    Packet.prototype.pack = function (operator, sequence, header, body) {
-        header = utils_1.Utils.encrypt(header, this.key, this.key);
-        body = utils_1.Utils.encrypt(body, this.key, this.key);
-        var headerLength = header.length;
-        var bodyLength = body.length;
-        var buf = new ArrayBuffer(20 + headerLength + bodyLength);
-        var dataView = new DataView(buf);
-        var nsBuf = new Int64(sequence).toBuffer();
-        dataView.setUint32(0, operator);
-        dataView.setUint32(12, headerLength);
-        dataView.setUint32(16, bodyLength);
-        var bufView = new Uint8Array(buf);
-        for (var i = 0; i < 8; i++) {
-            bufView[4 + i] = nsBuf[i];
-        }
-        for (var i_1 = 0; i_1 < headerLength; i_1++) {
-            bufView[20 + i_1] = header.charCodeAt(i_1);
-        }
-        for (var i_2 = 0; i_2 < bodyLength; i_2++) {
-            bufView[20 + headerLength + i_2] = body.charCodeAt(i_2);
-        }
-        return buf;
-    };
-    Packet.prototype.unPack = function (data) {
-        var dataView = new DataView(data);
-        this.operator = dataView.getUint32(0, false);
-        this.sequence = new Int64(new Uint8Array(dataView.buffer.slice(4, 12))).toNumber();
-        this.headerLength = dataView.getUint32(12, false);
-        this.bodyLength = dataView.getUint32(16, false);
-        var header = utils_1.Utils.ab2str(dataView.buffer.slice(20, 20 + this.headerLength));
-        var body = utils_1.Utils.ab2str(dataView.buffer.slice(20 + this.headerLength));
-        this.header = utils_1.Utils.decrypt(header, this.key, this.key);
-        this.body = utils_1.Utils.decrypt(body, this.key, this.key);
-        return this;
-    };
-    return Packet;
-}());
-exports.Packet = Packet;
-//# sourceMappingURL=packet.js.map

dist/packet.js.map

@@ -1 +0,0 @@
-{"version":3,"file":"packet.js","sourceRoot":"","sources":["../src/packet.ts"],"names":[],"mappings":";;AAAA,iCAAgC;AAChC,kCAAoC;AAEpC;IAAA;QACU,QAAG,GAAW,kCAAkC,CAAC;IA+D3D,CAAC;IAvDQ,qBAAI,GAAX,UACE,QAAgB,EAChB,QAAgB,EAChB,MAAc,EACd,IAAY;QAEZ,MAAM,GAAG,aAAK,CAAC,OAAO,CAAC,MAAM,EAAE,IAAI,CAAC,GAAG,EAAE,IAAI,CAAC,GAAG,CAAC,CAAC;QACnD,IAAI,GAAG,aAAK,CAAC,OAAO,CAAC,IAAI,EAAE,IAAI,CAAC,GAAG,EAAE,IAAI,CAAC,GAAG,CAAC,CAAC;QAE/C,IAAM,YAAY,GAAG,MAAM,CAAC,MAAM,CAAC;QACnC,IAAM,UAAU,GAAG,IAAI,CAAC,MAAM,CAAC;QAE/B,IAAM,GAAG,GAAG,IAAI,WAAW,CAAC,EAAE,GAAG,YAAY,GAAG,UAAU,CAAC,CAAC;QAC5D,IAAM,QAAQ,GAAG,IAAI,QAAQ,CAAC,GAAG,CAAC,CAAC;QACnC,IAAM,KAAK,GAAG,IAAI,KAAK,CAAC,QAAQ,CAAC,CAAC,QAAQ,EAAE,CAAC;QAE7C,QAAQ,CAAC,SAAS,CAAC,CAAC,EAAE,QAAQ,CAAC,CAAC;QAChC,QAAQ,CAAC,SAAS,CAAC,EAAE,EAAE,YAAY,CAAC,CAAC;QACrC,QAAQ,CAAC,SAAS,CAAC,EAAE,EAAE,UAAU,CAAC,CAAC;QAEnC,IAAI,OAAO,GAAG,IAAI,UAAU,CAAC,GAAG,CAAC,CAAC;QAClC,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,CAAC,EAAE,CAAC,EAAE,EAAE;YAC1B,OAAO,CAAC,CAAC,GAAG,CAAC,CAAC,GAAG,KAAK,CAAC,CAAC,CAAC,CAAC;SAC3B;QACD,KAAK,IAAI,GAAC,GAAG,CAAC,EAAE,GAAC,GAAG,YAAY,EAAE,GAAC,EAAE,EAAE;YACrC,OAAO,CAAC,EAAE,GAAG,GAAC,CAAC,GAAG,MAAM,CAAC,UAAU,CAAC,GAAC,CAAC,CAAC;SACxC;QAED,KAAK,IAAI,GAAC,GAAG,CAAC,EAAE,GAAC,GAAG,UAAU,EAAE,GAAC,EAAE,EAAE;YACnC,OAAO,CAAC,EAAE,GAAG,YAAY,GAAG,GAAC,CAAC,GAAG,IAAI,CAAC,UAAU,CAAC,GAAC,CAAC,CAAC;SACrD;QAED,OAAO,GAAG,CAAC;IACb,CAAC;IAEM,uBAAM,GAAb,UAAc,IAAS;QACrB,IAAM,QAAQ,GAAG,IAAI,QAAQ,CAAC,IAAI,CAAC,CAAC;QAEpC,IAAI,CAAC,QAAQ,GAAG,QAAQ,CAAC,SAAS,CAAC,CAAC,EAAE,KAAK,CAAC,CAAC;QAC7C,IAAI,CAAC,QAAQ,GAAG,IAAI,KAAK,CACvB,IAAI,UAAU,CAAC,QAAQ,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC,CAC7C,CAAC,QAAQ,EAAE,CAAC;QACb,IAAI,CAAC,YAAY,GAAG,QAAQ,CAAC,SAAS,CAAC,EAAE,EAAE,KAAK,CAAC,CAAC;QAClD,IAAI,CAAC,UAAU,GAAG,QAAQ,CAAC,SAAS,CAAC,EAAE,EAAE,KAAK,CAAC,CAAC;QAEhD,IAAM,MAAM,GAAG,aAAK,CAAC,MAAM,CACzB,QAAQ,CAAC,MAAM,CAAC,KAAK,CAAC,EAAE,EAAE,EAAE,GAAG,IAAI,CAAC,YAAY,CAAC,CAClD,CAAC;QACF,IAAM,IAAI,GAAG,aAAK,CAAC,MAAM,CAAC,QAAQ,CAAC,MAAM,CAAC,KAAK,CAAC,EAAE,GAAG,IAAI,CAAC,YAAY,CAAC,CAAC,CAAC;QAEzE,IAAI,CAAC,MAAM,GAAG,aAAK,CAAC,OAAO,CAAC,MAAM,EAAE,IAAI,CAAC,GAAG,EAAE,IAAI,CAAC,GAAG,CAAC,CAAC;QACxD,IAAI,CAAC,IAAI,GAAG,aAAK,CAAC,OAAO,CAAC,IAAI,EAAE,IAAI,CAAC,GAAG,EAAE,IAAI,CAAC,GAAG,CAAC,CAAC;QAEpD,OAAO,IAAI,CAAC;IACd,CAAC;IACH,aAAC;AAAD,CAAC,AAhED,IAgEC;AAhEY,wBAAM"}

dist/types/callback.d.ts

@@ -1,11 +0,0 @@
-export interface readyStateCallback {
-    onopen(ev: Event): any;
-    onerror(ev: Event): any;
-    onclose(ev: Event): any;
-}
-export interface callback {
-    onStart(): any;
-    onSuccess(data: string): any;
-    onError(code: number, message: string): any;
-    onEnd(): any;
-}

dist/types/constant.d.ts

@@ -1,2 +0,0 @@
-export declare const MAX_PAYLOAD: number;
-export declare const VERSION = "1.0";

dist/types/index.d.ts

@@ -1,36 +0,0 @@
-import { readyStateCallback, callback } from './callback';
-/**
- * Client ws client, 单例模式, 负责维护连接
- */
-export declare class Client {
-    callback: callback;
-    requestHeader: string;
-    responseHeader: string;
-    maxPayload: number;
-    url: string;
-    reconnectTimes: number;
-    reconnectLock: boolean;
-    socket: WebSocket;
-    readyStateCallback: readyStateCallback;
-    constructor(url: string, readyStateCallback: readyStateCallback);
-    ping(param?: {}, callback?: {}): void;
-    send(data: any): void;
-    /**
-     * asyncSend
-     * @param {*} operator
-     * @param {*} param
-     * @param {*} callback 仅此次有效的callback
-     */
-    asyncSend(operator: any, param: any, callback: any): void;
-    syncSend(operator: any, param: any, callback: any): Promise<void>;
-    addMessageListener(operator: any, listener: any): void;
-    removeMessageListener(operator: any): void;
-    getReadyState(): number;
-    setMaxPayload(maxPayload: any): void;
-    setRequestProperty(key: any, value: any): void;
-    getRequestProperty(key: any): string;
-    setResponseProperty(key: any, value: any): void;
-    getResponseProperty(key: any): string;
-    connect(): WebSocket;
-    reconnect(): void;
-}

dist/types/packet.d.ts

@@ -1,11 +0,0 @@
-export declare class Packet {
-    private key;
-    operator: number;
-    sequence: number;
-    headerLength: number;
-    bodyLength: number;
-    header: string;
-    body: string;
-    pack(operator: number, sequence: number, header: string, body: string): ArrayBuffer;
-    unPack(data: any): Packet;
-}

dist/types/utils.d.ts

@@ -1,19 +0,0 @@
-declare global {
-    interface Window {
-        crcTable: number[];
-    }
-}
-declare class Utils {
-    private static code;
-    static crc32(str: string): number;
-    static ab2str(buf: ArrayBuffer): string;
-    static str2ab(str: string): ArrayBuffer;
-    static decrypt(data: string, key: string, iv: string): string;
-    static encrypt(data: string, key: string, iv: string): string;
-    static binToBase64(bitString: string): string;
-    static base64ToBin(str: string): string;
-    static stringToBin(str: string): string;
-    static binToString(bin: string): string;
-    private static makeCRCTable;
-}
-export { Utils };

dist/utils.js

@@ -1,123 +0,0 @@
-"use strict";
-exports.__esModule = true;
-var crypto_js_1 = require("crypto-js");
-var Utils = /** @class */ (function () {
-    function Utils() {
-    }
-    Utils.crc32 = function (str) {
-        var crcTable = window.crcTable || (window.crcTable = Utils.makeCRCTable());
-        var crc = 0 ^ -1;
-        for (var i = 0; i < str.length; i++) {
-            crc = (crc >>> 8) ^ crcTable[(crc ^ str.charCodeAt(i)) & 0xff];
-        }
-        return (crc ^ -1) >>> 0;
-    };
-    // ArrayBuffer 转为字符串，参数为 ArrayBuffer 对象
-    Utils.ab2str = function (buf) {
-        // 注意，如果是大型二进制数组，为了避免溢出，必须一个一个字符地转
-        if (buf && buf.byteLength < 1024) {
-            return String.fromCharCode.apply(null, new Uint8Array(buf));
-        }
-        var bufView = new Uint8Array(buf);
-        var len = bufView.length;
-        var byteStr = new Array(len);
-        for (var i = 0; i < len; i++) {
-            byteStr[i] = String.fromCharCode.call(null, bufView[i]);
-        }
-        return byteStr.join('');
-    };
-    // 字符串转为 ArrayBuffer 对象，参数为字符串
-    Utils.str2ab = function (str) {
-        var buf = new ArrayBuffer(str.length); // 每个字符占用2个字节
-        var bufView = new Uint8Array(buf);
-        for (var i = 0, strLen = str.length; i < strLen; i++) {
-            bufView[i] = str.charCodeAt(i);
-        }
-        return buf;
-    };
-    // 解密服务端传递过来的字符串
-    Utils.decrypt = function (data, key, iv) {
-        var binData = Utils.stringToBin(data);
-        var base64Data = Utils.binToBase64(binData);
-        var bytes = crypto_js_1.AES.decrypt(base64Data, crypto_js_1.enc.Latin1.parse(key), {
-            iv: crypto_js_1.enc.Latin1.parse(iv),
-            mode: crypto_js_1.mode.CBC,
-            padding: crypto_js_1.pad.Pkcs7
-        });
-        return bytes.toString(crypto_js_1.enc.Utf8);
-    };
-    // 加密字符串以后传递到服务端
-    Utils.encrypt = function (data, key, iv) {
-        var result = crypto_js_1.AES.encrypt(data, crypto_js_1.enc.Latin1.parse(key), {
-            iv: crypto_js_1.enc.Latin1.parse(iv),
-            mode: crypto_js_1.mode.CBC,
-            padding: crypto_js_1.pad.Pkcs7
-        });
-        return Utils.binToString(Utils.base64ToBin(result.toString()));
-    };
-    // 字节数组转换为base64编码
-    Utils.binToBase64 = function (bitString) {
-        var result = '';
-        var tail = bitString.length % 6;
-        var bitStringTemp1 = bitString.substr(0, bitString.length - tail);
-        var bitStringTemp2 = bitString.substr(bitString.length - tail, tail);
-        for (var i = 0; i < bitStringTemp1.length; i += 6) {
-            var index = parseInt(bitStringTemp1.substr(i, 6), 2);
-            result += Utils.code[index];
-        }
-        bitStringTemp2 += new Array(7 - tail).join('0');
-        if (tail) {
-            result += Utils.code[parseInt(bitStringTemp2, 2)];
-            result += new Array((6 - tail) / 2 + 1).join('=');
-        }
-        return result;
-    };
-    // base64编码转换为字节数组
-    Utils.base64ToBin = function (str) {
-        var bitString = '';
-        var tail = 0;
-        for (var i = 0; i < str.length; i++) {
-            if (str[i] !== '=') {
-                var decode = this.code.indexOf(str[i]).toString(2);
-                bitString += new Array(7 - decode.length).join('0') + decode;
-            }
-            else {
-                tail++;
-            }
-        }
-        return bitString.substr(0, bitString.length - tail * 2);
-    };
-    // 字符串转换为字节数组
-    Utils.stringToBin = function (str) {
-        var result = '';
-        for (var i = 0; i < str.length; i++) {
-            var charCode = str.charCodeAt(i).toString(2);
-            result += new Array(9 - charCode.length).join('0') + charCode;
-        }
-        return result;
-    };
-    // 字节数组转化为字符串
-    Utils.binToString = function (bin) {
-        var result = '';
-        for (var i = 0; i < bin.length; i += 8) {
-            result += String.fromCharCode(parseInt(bin.substr(i, 8), 2));
-        }
-        return result;
-    };
-    Utils.makeCRCTable = function () {
-        var c;
-        var crcTable = [];
-        for (var n = 0; n < 256; n++) {
-            c = n;
-            for (var k = 0; k < 8; k++) {
-                c = c & 1 ? 0xedb88320 ^ (c >>> 1) : c >>> 1;
-            }
-            crcTable[n] = c;
-        }
-        return crcTable;
-    };
-    Utils.code = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/'.split('');
-    return Utils;
-}());
-exports.Utils = Utils;
-//# sourceMappingURL=utils.js.map

public/index.html

@@ -0,0 +1,7 @@
+<!DOCTYPE html>
+
+<htm>
+  <head>
+    <script src="../dist/example/main.js" type="text/javascript"></script>
+  </head>
+</htm>

src/example/main.ts

@@ -0,0 +1,6 @@
+import { Client } from "../index";
+
+console.log("Start")
+const client = new Client("ws://127.0.0.1:8081", null)
+
+console.log("client")

tsconfig.json

@@ -1,6 +1,7 @@
 {
   "compileOnSave": true,
   "compilerOptions": {
+    "module": "system",
     "alwaysStrict": true,
     "sourceMap": true,
     "declaration": true,