微信小程序使用Stomp连接websockt

constStomp=require('./utils/stomp.js').Stomp;/**打开长连接*/onConnectSocket(){varsocketOpen=falsevarsocketMsgQueue=[]functionsendSocketMessage(msg){if(socketOpen){wx.sendSocketMessage({data:msg})}else{socketMsgQueue.push(msg)}}/**这是为了连接数据*/varwebsocketParams={send:sendSocketMessage,onopen:null,onmessage:null,close:()=>{if(this.client){this.client=null;}}}wx.connectSocket({url:'wss://123456789.com:9000'})wx.onSocketOpen(function(res){socketOpen=truefor(vari=0;i{/**在这里处理数据后台给我的数据是字符串，需要拦截start*/varbuffer=res.data;vardataview=newDataView(缓冲区);varints=newUint8Array(buffer.byteLength);变量str='';for(vari=0;i{/**queue/MD210001订阅队列*/this.client.subscribe(`/queue/MD210001`,function(txt){})//this.client.send("/queue/MD210002",{priority:9},"Hello,MD210002");})},/**Disconnect*/onCloseSocket(){if(this.client){this.client.disconnect(res=>{console.log("Disconnect",res)})this.client=null;}},