rt-sim-training-client/static/workertest/driverWebWorker.js

// importScripts('sockjs.js');
// import { getToken } from '@/utils/auth';
// import SockJS from 'sockjs-client';

// const websocketUrl = 'ws://test.joylink.club/jlcloud/joylink-websocket?token=';
// const websocketUrl = `http://192.168.3.6:9000/joylink-websocket?token=`;
let websocketUrl = null;
let token = null;
var StompClient = function (headers, token) {
    const scope = this;
    this.url = websocketUrl + token;
    this.headers = headers || {};
    this.connect();
};

StompClient.prototype = {
    socket: null,

    clientIns: null,

    subscribeMap: null,

    url: '',

    status: false,

    sockStatus: 0,

    headers: {
        // 'X-Token': getToken()
    },

    count: 0,

    topic: '',

    onmessage: null,

    checkTimer: null,

    // 连接服务端
    connect() {
        return new Promise((resolve, reject) => {
            try {
                // 断开已有连接
                if (this.clientIns && this.clientIns.connected) {
                    this.clientIns.disconnect();
                    this.clientIns = null;
                }

                // // 建立连接对象（还未发起连接）
                // this.socket = new SockJS(websocketUrl + token);
                //
                // // 获取 STOMP 子协议的客户端对象
                // this.clientIns = Stomp.over(this.socket);

                this.websocket = new WebSocket(this.url.replace(/https/, 'wss').replace(/http/, 'ws'));

                this.clientIns = Stomp.over(this.websocket);

                this.closeStompDebug();

                // 向服务器发起websocket连接并发送CONNECT帧
                this.clientIns.connect({ 'X-Token': token }, () => {
                    console.info('连接成功.');
                    this.count = 0;
                    this.status = true;

                    // 恢复订阅
                    if (this.topic && this.onmessage) {
                        this.unsubscribe(this.topic);
                        this.subscribe(this.topic, this.onmessage, this.headers);
                    }

                    resolve(this);
                }, () => {
                    if (this.checkTimer) {
                        clearInterval(this.checkTimer);
                        this.checkTimer = null;
                    }

                });
            } catch (err) {
                reject(err);
            }
        });

    },
    logOut(err) {
        if (err.code == 50008 || err.code == 50014) {
            this.url = websocketUrl + token;
            this.status = false;
            this.count++;
            this.reconnect(this.count);
        }
    },
    // 恢复链接
    reconnect(count) {
        console.info(`尝试第${count || 1}次连接.`);
        this.connect().then(() => { }).catch(() => {
            this.count++;
            this.reconnect(this.count);
        });
    },

    closeStompDebug() {
        if (this.clientIns) {
            this.clientIns.debug = undefined;

        }
    },

    // 订阅指定的topic
    subscribe(topic, onmessage, headers) {
        this.topic = topic;
        this.onmessage = onmessage;
        this.headers = headers;
        if (this.status) {
            if (!this.subscribeMap) {
                this.subscribeMap = new Map();
            }

            try {
                var subscription = this.subscribeMap.get(topic);
                if (!subscription) {
                    subscription = this.clientIns.subscribe(topic, onmessage, headers); // 接收消息通过 subscribe() 方法实现
                    this.subscribeMap.set(topic, subscription);
                }
            } catch (err) {
                setTimeout(() => {
                    this.subscribe(topic, onmessage, headers);
                }, 300);
            }

        } else {
            setTimeout(() => {
                this.subscribe(topic, onmessage, headers);
            }, 300);
        }
    },

    unsubscribe(topic) {
        if (this.subscribeMap) {
            const subscription = this.subscribeMap.get(topic);
            if (subscription) {
                subscription.unsubscribe();
                this.subscribeMap.delete(topic);
                console.log('取消订阅');
            }
        }
    },

    // 发送消息
    send(url, msg) {
        if (this.status) {
            if (msg) {
                msg = JSON.stringify(msg);
            }
            try {
                this.clientIns.send(url, {}, msg);
            } catch (err) {
                this.status = false;
                this.send(url, msg);
            }
        } else {
            setTimeout(() => {
                this.send(url, msg);
            }, 300);
        }
    },

    disconnect() {
        if (this.checkTimer) {
            clearInterval(this.checkTimer);
            this.checkTimer = null;
        }

        if (this.clientIns && this.clientIns.connected) {
            this.clientIns.disconnect();
            this.clientIns = null;
        }
        this.status = false;
        console.log('断开连接');
    }

};

var Byte; var Client; var Frame; var Stomp;
var __hasProp = {}.hasOwnProperty;
var __slice = [].slice;

Byte = {
    LF: '\x0A',
    NULL: '\x00'
};

Frame = (function() {
    var unmarshallSingle;

    function Frame(command, headers, body) {
        this.command = command;
        this.headers = headers != null ? headers : {};
        this.body = body != null ? body : '';
    }

    Frame.prototype.toString = function() {
        var lines, name, skipContentLength, value, _ref;
        lines = [this.command];
        skipContentLength = this.headers['content-length'] === false;
        if (skipContentLength) {
            delete this.headers['content-length'];
        }
        _ref = this.headers;
        for (name in _ref) {
            if (!__hasProp.call(_ref, name)) continue;
            value = _ref[name];
            lines.push('' + name + ':' + value);
        }
        if (this.body && !skipContentLength) {
            lines.push('content-length:' + (Frame.sizeOfUTF8(this.body)));
        }
        lines.push(Byte.LF + this.body);
        return lines.join(Byte.LF);
    };

    Frame.sizeOfUTF8 = function(s) {
        if (s) {
            return encodeURI(s).match(/%..|./g).length;
        } else {
            return 0;
        }
    };

    unmarshallSingle = function(data) {
        var body, chr, command, divider, headerLines, headers, i, idx, len, line, start, trim, _i, _j, _len, _ref, _ref1;
        divider = data.search(RegExp('' + Byte.LF + Byte.LF));
        headerLines = data.substring(0, divider).split(Byte.LF);
        command = headerLines.shift();
        headers = {};
        trim = function(str) {
            return str.replace(/^\s+|\s+$/g, '');
        };
        _ref = headerLines.reverse();
        for (_i = 0, _len = _ref.length; _i < _len; _i++) {
            line = _ref[_i];
            idx = line.indexOf(':');
            headers[trim(line.substring(0, idx))] = trim(line.substring(idx + 1));
        }
        body = '';
        start = divider + 2;
        if (headers['content-length']) {
            len = parseInt(headers['content-length']);
            body = ('' + data).substring(start, start + len);
        } else {
            chr = null;
            for (i = _j = start, _ref1 = data.length; start <= _ref1 ? _j < _ref1 : _j > _ref1; i = start <= _ref1 ? ++_j : --_j) {
                chr = data.charAt(i);
                if (chr === Byte.NULL) {
                    break;
                }
                body += chr;
            }
        }
        return new Frame(command, headers, body);
    };

    Frame.unmarshall = function(datas) {
        var data;
        return (function() {
            var _i, _len, _ref, _results;
            _ref = datas.split(RegExp('' + Byte.NULL + Byte.LF + '*'));
            _results = [];
            for (_i = 0, _len = _ref.length; _i < _len; _i++) {
                data = _ref[_i];
                if ((data != null ? data.length : void 0) > 0) {
                    _results.push(unmarshallSingle(data));
                }
            }
            return _results;
        })();
    };

    Frame.marshall = function(command, headers, body) {
        var frame;
        frame = new Frame(command, headers, body);
        return frame.toString() + Byte.NULL;
    };

    return Frame;

})();

Client = (function() {
    var now;

    function Client(ws) {
        this.ws = ws;
        this.ws.binaryType = 'arraybuffer';
        this.counter = 0;
        this.connected = false;
        this.heartbeat = {
            outgoing: 10000,
            incoming: 10000
        };
        this.maxWebSocketFrameSize = 16 * 1024;
        this.subscriptions = {};
    }

    Client.prototype.debug = function(message) {
        var _ref;
        return typeof window !== 'undefined' && window !== null ? (_ref = window.console) != null ? _ref.log(message) : void 0 : void 0;
    };

    now = function() {
        if (Date.now) {
            return Date.now();
        } else {
            return new Date().valueOf;
        }
    };

    Client.prototype._transmit = function(command, headers, body) {
        var out;
        out = Frame.marshall(command, headers, body);
        if (typeof this.debug === 'function') {
            this.debug('>>> ' + out);
        }
        while (true) {
            if (out.length > this.maxWebSocketFrameSize) {
                this.ws.send(out.substring(0, this.maxWebSocketFrameSize));
                out = out.substring(this.maxWebSocketFrameSize);
                if (typeof this.debug === 'function') {
                    this.debug('remaining = ' + out.length);
                }
            } else {
                return this.ws.send(out);
            }
        }
    };

    Client.prototype._setupHeartbeat = function(headers) {
        var serverIncoming, serverOutgoing, ttl, v, _ref, _ref1;
        if ((_ref = headers.version) !== Stomp.VERSIONS.V1_1 && _ref !== Stomp.VERSIONS.V1_2) {
            return;
        }
        _ref1 = (function() {
            var _i, _len, _ref1, _results;
            _ref1 = headers['heart-beat'].split(',');
            _results = [];
            for (_i = 0, _len = _ref1.length; _i < _len; _i++) {
                v = _ref1[_i];
                _results.push(parseInt(v));
            }
            return _results;
        })(), serverOutgoing = _ref1[0], serverIncoming = _ref1[1];
        if (!(this.heartbeat.outgoing === 0 || serverIncoming === 0)) {
            ttl = Math.max(this.heartbeat.outgoing, serverIncoming);
            if (typeof this.debug === 'function') {
                this.debug('send PING every ' + ttl + 'ms');
            }
            this.pinger = Stomp.setInterval(ttl, (function(_this) {
                return function() {
                    _this.ws.send(Byte.LF);
                    return typeof _this.debug === 'function' ? _this.debug('>>> PING') : void 0;
                };
            })(this));
        }
        if (!(this.heartbeat.incoming === 0 || serverOutgoing === 0)) {
            ttl = Math.max(this.heartbeat.incoming, serverOutgoing);
            if (typeof this.debug === 'function') {
                this.debug('check PONG every ' + ttl + 'ms');
            }
            return this.ponger = Stomp.setInterval(ttl, (function(_this) {
                return function() {
                    var delta;
                    delta = now() - _this.serverActivity;
                    if (delta > ttl * 2) {
                        if (typeof _this.debug === 'function') {
                            _this.debug('did not receive server activity for the last ' + delta + 'ms');
                        }
                        return _this.ws.close();
                    }
                };
            })(this));
        }
    };

    Client.prototype._parseConnect = function() {
        var args, connectCallback, errorCallback, headers;
        args = arguments.length >= 1 ? __slice.call(arguments, 0) : [];
        headers = {};
        switch (args.length) {
        case 2:
            headers = args[0], connectCallback = args[1];
            break;
        case 3:
            if (args[1] instanceof Function) {
                headers = args[0], connectCallback = args[1], errorCallback = args[2];
            } else {
                headers.login = args[0], headers.passcode = args[1], connectCallback = args[2];
            }
            break;
        case 4:
            headers.login = args[0], headers.passcode = args[1], connectCallback = args[2], errorCallback = args[3];
            break;
        default:
            headers.login = args[0], headers.passcode = args[1], connectCallback = args[2], errorCallback = args[3], headers.host = args[4];
        }
        return [headers, connectCallback, errorCallback];
    };

    Client.prototype.connect = function() {
        var args, errorCallback, headers, out;
        args = arguments.length >= 1 ? __slice.call(arguments, 0) : [];
        out = this._parseConnect.apply(this, args);
        headers = out[0], this.connectCallback = out[1], errorCallback = out[2];
        if (typeof this.debug === 'function') {
            this.debug('Opening Web Socket...');
        }
        this.ws.onmessage = (function(_this) {
            return function(evt) {
                var arr, c, client, data, frame, messageID, onreceive, subscription, _i, _len, _ref, _results;
                data = typeof ArrayBuffer !== 'undefined' && evt.data instanceof ArrayBuffer ? (arr = new Uint8Array(evt.data), typeof _this.debug === 'function' ? _this.debug('--- got data length: ' + arr.length) : void 0, ((function() {
                    var _i, _len, _results;
                    _results = [];
                    for (_i = 0, _len = arr.length; _i < _len; _i++) {
                        c = arr[_i];
                        _results.push(String.fromCharCode(c));
                    }
                    return _results;
                })()).join('')) : evt.data;
                _this.serverActivity = now();
                if (data === Byte.LF) {
                    if (typeof _this.debug === 'function') {
                        _this.debug('<<< PONG');
                    }
                    return;
                }
                if (typeof _this.debug === 'function') {
                    _this.debug('<<< ' + data);
                }
                _ref = Frame.unmarshall(data);
                _results = [];
                for (_i = 0, _len = _ref.length; _i < _len; _i++) {
                    frame = _ref[_i];
                    switch (frame.command) {
                    case 'CONNECTED':
                        if (typeof _this.debug === 'function') {
                            _this.debug('connected to server ' + frame.headers.server);
                        }
                        _this.connected = true;
                        _this._setupHeartbeat(frame.headers);
                        _results.push(typeof _this.connectCallback === 'function' ? _this.connectCallback(frame) : void 0);
                        break;
                    case 'MESSAGE':
                        subscription = frame.headers.subscription;
                        onreceive = _this.subscriptions[subscription] || _this.onreceive;
                        if (onreceive) {
                            client = _this;
                            messageID = frame.headers['message-id'];
                            frame.ack = function(headers) {
                                if (headers == null) {
                                    headers = {};
                                }
                                return client.ack(messageID, subscription, headers);
                            };
                            frame.nack = function(headers) {
                                if (headers == null) {
                                    headers = {};
                                }
                                return client.nack(messageID, subscription, headers);
                            };
                            _results.push(onreceive(frame));
                        } else {
                            _results.push(typeof _this.debug === 'function' ? _this.debug('Unhandled received MESSAGE: ' + frame) : void 0);
                        }
                        break;
                    case 'RECEIPT':
                        _results.push(typeof _this.onreceipt === 'function' ? _this.onreceipt(frame) : void 0);
                        break;
                    case 'ERROR':
                        _results.push(typeof errorCallback === 'function' ? errorCallback(frame) : void 0);
                        break;
                    default:
                        _results.push(typeof _this.debug === 'function' ? _this.debug('Unhandled frame: ' + frame) : void 0);
                    }
                }
                return _results;
            };
        })(this);
        this.ws.onclose = (function(_this) {
            return function() {
                var msg;
                msg = 'Whoops! Lost connection to ' + _this.ws.url;
                if (typeof _this.debug === 'function') {
                    _this.debug(msg);
                }
                _this._cleanUp();
                return typeof errorCallback === 'function' ? errorCallback(msg) : void 0;
            };
        })(this);
        return this.ws.onopen = (function(_this) {
            return function() {
                if (typeof _this.debug === 'function') {
                    _this.debug('Web Socket Opened...');
                }
                headers['accept-version'] = Stomp.VERSIONS.supportedVersions();
                headers['heart-beat'] = [_this.heartbeat.outgoing, _this.heartbeat.incoming].join(',');
                return _this._transmit('CONNECT', headers);
            };
        })(this);
    };

    Client.prototype.disconnect = function(disconnectCallback, headers) {
        if (headers == null) {
            headers = {};
        }
        this._transmit('DISCONNECT', headers);
        this.ws.onclose = null;
        this.ws.close();
        this._cleanUp();
        return typeof disconnectCallback === 'function' ? disconnectCallback() : void 0;
    };

    Client.prototype._cleanUp = function() {
        this.connected = false;
        if (this.pinger) {
            Stomp.clearInterval(this.pinger);
        }
        if (this.ponger) {
            return Stomp.clearInterval(this.ponger);
        }
    };

    Client.prototype.send = function(destination, headers, body) {
        if (headers == null) {
            headers = {};
        }
        if (body == null) {
            body = '';
        }
        headers.destination = destination;
        return this._transmit('SEND', headers, body);
    };

    Client.prototype.subscribe = function(destination, callback, headers) {
        var client;
        if (headers == null) {
            headers = {};
        }
        if (!headers.id) {
            headers.id = 'sub-' + this.counter++;
        }
        headers.destination = destination;
        this.subscriptions[headers.id] = callback;
        this._transmit('SUBSCRIBE', headers);
        client = this;
        return {
            id: headers.id,
            unsubscribe: function() {
                return client.unsubscribe(headers.id);
            }
        };
    };

    Client.prototype.unsubscribe = function(id) {
        delete this.subscriptions[id];
        return this._transmit('UNSUBSCRIBE', {
            id: id
        });
    };

    Client.prototype.begin = function(transaction) {
        var client, txid;
        txid = transaction || 'tx-' + this.counter++;
        this._transmit('BEGIN', {
            transaction: txid
        });
        client = this;
        return {
            id: txid,
            commit: function() {
                return client.commit(txid);
            },
            abort: function() {
                return client.abort(txid);
            }
        };
    };

    Client.prototype.commit = function(transaction) {
        return this._transmit('COMMIT', {
            transaction: transaction
        });
    };

    Client.prototype.abort = function(transaction) {
        return this._transmit('ABORT', {
            transaction: transaction
        });
    };

    Client.prototype.ack = function(messageID, subscription, headers) {
        if (headers == null) {
            headers = {};
        }
        headers['message-id'] = messageID;
        headers.subscription = subscription;
        return this._transmit('ACK', headers);
    };

    Client.prototype.nack = function(messageID, subscription, headers) {
        if (headers == null) {
            headers = {};
        }
        headers['message-id'] = messageID;
        headers.subscription = subscription;
        return this._transmit('NACK', headers);
    };

    return Client;

})();

Stomp = {
    VERSIONS: {
        V1_0: '1.0',
        V1_1: '1.1',
        V1_2: '1.2',
        supportedVersions: function() {
            return '1.1,1.0';
        }
    },
    client: function(url, protocols) {
        var klass, ws;
        if (protocols == null) {
            protocols = ['v10.stomp', 'v11.stomp'];
        }
        klass = Stomp.WebSocketClass || WebSocket;
        ws = new klass(url, protocols);
        return new Client(ws);
    },
    over: function(ws) {
        return new Client(ws);
    },
    Frame: Frame
};

if (typeof exports !== 'undefined' && exports !== null) {
    exports.Stomp = Stomp;
}
Stomp.setInterval = function(interval, f) {
    return setInterval(f, interval);
};
Stomp.clearInterval = function(id) {
    return clearInterval(id);
};

let data = null;

let topic = null;
let header = null;
let teststomp = null;
function timedCount() {

  onmessage = (e) => {

      if (e.data.type == 'init') {
      	topic = e.data.topic;
      	header = {'X-Token': e.data.token };
          token = e.data.token;
          websocketUrl = e.data.baseurl + '/joylink-websocket?token=';

      }

      if (e.data == 'connect') {
          teststomp = new StompClient(header, token);
          teststomp.subscribe(topic, callback, header);
      }

      if (e.data == 'off') {
          teststomp.unsubscribe(topic);
      }

  };
  function callback(Response) {

    data = JSON.parse(Response.body);
    if(data.type == "Train_Position"){
			postMessage(data);
			return;
		}

		if(data.type == "Train_Position_3D"){
			postMessage(data);
			return;
		}
		if(data.type == "Train_Hmi_3D"){

			postMessage(data);
			return;
		}

    if(data.type == 'TDT_3D'){
      postMessage(data);
      return;
    }

		if(data.type == "DeviceCtrl_3D"){
			if (data.body.type== 'SIGNAL') {
				postMessage(data);
				return;
			}

			if (data.body.type== "PSD") {
				postMessage(data);
				return;
			}
			if (data.body.type == "SWITCH") {
				postMessage(data);
				return;
			}
			if (data.body.type == 'TRAIN_DOOR') {
				postMessage(data);
				return;
			}
		}

		if(data.type == "Device_Load_Destroy_3D"){
			postMessage(data);
		}

    if(data.type == "Simulation_Reset"){
      postMessage(data);
    }

  }

}

timedCount();