uniapp连接websocket报错? _Websocket

黄沙百战穿金甲，不破楼兰终不还。这篇文章主要讲述uniapp连接websocket报错?相关的知识，希望能为你提供帮助。
论坛问题: https://ask.dcloud.net.cn/question/74505
使用: uni.connectSocket(OBJECT) 和 SocketTask.onOpen(CALLBACK) 在安卓手机无法触发websocket的open方法
解决办法使用plus-websocket插件
https://ext.dcloud.net.cn/plugin?id=647
注意方法使用:
socket.connectSocket(OBJECT)

socket.onSocketOpen(CALLBACK)
socket.onSocketError(CALLBACK)
socket.sendSocketMessage(OBJECT)
socket.onSocketMessage(CALLBACK)
socket.closeSocket(OBJECT)
socket.onSocketClose(CALLBACK)

转载大佬的插件案例: https://www.jianshu.com/p/241fd3a81c3f

文章图片

/**uni websocket工具类*/ //npm i plus-websocket --save import socket from ‘plus-websocket‘ export default class websocket { constructor({ heartCheck, isReconnection }) { // 是否连接 this._isLogin = false; // 当前网络状态 this._netWork = true; // 是否人为退出 this._isClosed = false; // 心跳检测频率 this._timeout = 3000; this._timeoutObj = null; // 当前重连次数 this._connectNum = 0; // 心跳检测和断线重连开关，true为启用，false为关闭 this._heartCheck = heartCheck; this._isReconnection = isReconnection; // this._onSocketOpened(); } // 心跳重置 _reset() { clearTimeout(this._timeoutObj); return this; } // 心跳开始 _start() { let _this = this; this._timeoutObj = setInterval(() => { //发送心跳 _this.sendHeartbeatData(); }, this._timeout); } // 监听websocket连接关闭 onSocketClosed(options) { socket.onSocketClose(err => { console.log(‘当前websocket连接已关闭,错误信息为:‘ + JSON.stringify(err)); // 停止心跳连接 if (this._heartCheck) { this._reset(); } // 关闭已登录开关 this._isLogin = false; // 检测是否是用户自己退出小程序 if (!this._isClosed) { // 进行重连 if (this._isReconnection) { this._reConnect(options) } }}) } // 检测网络变化 onNetworkChange(options) {uni.onNetworkStatusChange(res => { console.log(‘当前网络状态:‘ + res.isConnected); if (!this._netWork) { this._isLogin = false; // 进行重连 if (this._isReconnection) { this._reConnect(options) } } }) } _onSocketOpened() { socket.onSocketOpen(res => { console.log(‘【websocket】已打开‘); // 打开已登录开关 this._isLogin = true; // 发送心跳 if (this._heartCheck) { this._reset()._start(); } // 发送登录信息 this.sendLoginData(); // 打开网络开关 this._netWork = true; }) } // 接收服务器返回的消息 onReceivedMsg(callBack) { socket.onSocketMessage(event => { let msg = this.socketEventDataToStr(event) // console.log(msg); if (typeof callBack == "function") { callBack(msg) } else { console.log(‘参数的类型必须为函数‘) } }) }// 建立websocket连接 initWebSocket(options) {let _this = this; if (this._isLogin) { console.log("您已经登录了"); } else { // 检查网络 uni.getNetworkType({ success(result) { if (result.networkType != ‘none‘) { // 开始建立连接 console.log(‘建立websocket连接‘ + options.url); socket.connectSocket({ url: options.url, success(res) { if (typeof options.success == "function") { options.success(res) _this._onSocketOpened(); } else { console.log(‘参数的类型必须为函数‘) } }, fail(err) { if (typeof options.fail == "function") { options.fail(err) } else { console.log(‘参数的类型必须为函数‘) } } }) } else { console.log(‘网络已断开‘); _this._netWork = false; // 网络断开后显示model uni.showModal({ title: ‘网络错误‘, content: ‘请重新打开网络‘, showCancel: false, success: function(res) { if (res.confirm) { console.log(‘用户点击确定‘) } } }) } } }) } } // 发送websocket消息 sendWebSocketMsg(options) { this.sendBinary(1,options); }//发送心跳连接 sendHeartbeatData() { this.sendBinary(99, { data: {}, success(res) { console.log(‘【websocket】心跳连接成功‘) }, fail(err) { console.log(‘【websocket】心跳连接失败‘) console.log(err) } }); }//发送第一次连接数据 sendLoginData() { this.sendBinary(99, { data: {}, success(res) { console.log(‘【websocket】第一次连接成功‘) }, fail(err) { console.log(‘【websocket】第一次连接失败‘) console.log(err) } }); // this.sendBinary(99, {}); // socket.sendSocketMessage({ //// 这里是第一次建立连接所发送的信息，应由前后端商量后决定 //data: JSON.stringify({ //"key": ‘value‘ //}) // }) }// 重连方法，会根据时间频率越来越慢 _reConnect(options) { let timer, _this = this; if (this._connectNum < 20) { timer = setTimeout(() => { this.initWebSocket(options) }, 3000) this._connectNum += 1; } else if (this._connectNum < 50) { timer = setTimeout(() => { this.initWebSocket(options) }, 10000) this._connectNum += 1; } else { timer = setTimeout(() => { this.initWebSocket(options) }, 450000) this._connectNum += 1; } } // 关闭websocket连接 closeWebSocket() { socket.closeSocket(); this._isClosed = true; }//发送二进制 sendBinary(commendType, options) { let sendMsg = options.data let uint8Array = new TextEncoder().encode(JSON.stringify(sendMsg)); let byteArr = new ArrayBuffer(4 + uint8Array.length); //DataView有三个参数，后两个可以缺省；每一个要是ArrayBuffer对象或SharedArrayBuffer对象 let dv = new DataView(byteArr); dv.setUint32(0, commendType, false); for (let i = 0; i < uint8Array.length; i++) { dv.setUint8(4 + i, uint8Array[i]); } // console.log(dv); socket.sendSocketMessage({ data: dv.buffer, success(res) {if (typeof options.success == "function") { options.success(res) } else { console.log(‘参数的类型必须为函数‘) } }, fail(err) { if (typeof options.fail == "function") { options.fail(err) } else { console.log(‘参数的类型必须为函数‘) } } }); }//转化方法 socketEventDataToStr(event) { let dv = new DataView(event.data); let commendType = dv.getUint32(0, true); let slice = event.data.slice(4, event.data.length); let unit8Arr = new Uint8Array(slice); let s = new TextDecoder("utf-8").decode(unit8Arr); console.log("【websocket】标志位:" + commendType); console.log("【websocket】返回信息:" + s); return s; }}

转载简书大佬的案例【uniapp连接websocket报错?】