1,封装 websocket,创建websocket.js ,websocket 代码如下
import config from './config';
var app = getApp();
const host = 'ws://192.168.2.101:8080/websocket'
console.log(host)
let sotk = null;
let socketOpen = false;
function ws_connect(reMsg){
sotk = wx.connectSocket({
url: host,
header: {
'content-type': 'application/json'
}
})
console.log(sotk)
sotk.onOpen(res => {
socketOpen = true;
console.log('监听 WebSocket 连接打开事件。', res);
})
sotk.onClose(onClose => {
socketOpen = false;
console.log('监听 WebSocket 连接关闭事件。', onClose)
})
sotk.onError(onError => {
socketOpen = true;
console.log('监听 WebSocket 错误。错误信息', onError)
})
// 收到消息
sotk.onMessage(onMessage => {
// var data = JSON.parse(onMessage.data);
reMsg(onMessage.data);
})
}
function sendMsg(msg,success){
if (socketOpen) {
// console.log('通过 WebSocket 连接发送数据', JSON.stringify(msg))
sotk.send({
data: JSON.stringify(msg)
}, function (res) {
success(res)
})
}
}
module.exports.ws_connect = ws_connect;
module.exports.sendMsg = sendMsg;
2,首先在使用 websocket 的地方导入,并调用
var websocket = require('../js/websocket.js')
// 连接websocket
websocket.ws_connect((data)=>{
console.log(data)
})