如何让微信小程序链接websocket

关于websocket的设置，API里边已经给了，

wx.connectSocket(OBJECT)

创建一个 WebSocket 连接；一个微信小程序同时只能有一个 WebSocket 连接，如果当前已存在一个 WebSocket 连接，会自动关闭该连接，并重新创建一个 WebSocket 连接。

OBJECT参数说明：

参数

类型

必填

说明

urlString是开发者服务器接口地址，必须是 wss 协议，且域名必须是后台配置的合法念磨域名

dataObject否请求的数据

headerObject否HTTP Header , header 中不能设置 Referer

methodString否默认是GET，有效值为： OPTIONS, GET, HEAD, POST, PUT, DELETE, TRACE, CONNECT

successFunction否接口调用成功的回调函数

failFunction否接口调用失败的回调函数

completeFunction否接口调用结束的回调函数（调用成功、失败都会执行）

示例代码：

wx.connectSocket({

url: 'test.php',

data:{

x: '',

y: ''

},

header:{

'content-type': 'application/json'

},

method:"GET"

})

wx.onSocketOpen(CALLBACK)

监听WebSocket连接打开事件。

示例代码：

wx.connectSocket({

url: 'test.php'

})

wx.onSocketOpen(function(res) {

console.log('WebSocket连接已打开！')

})

wx.onSocketError(CALLBACK)

监听WebSocket错误。

示例代码：

wx.connectSocket({

url: 'test.php'

})

wx.onSocketOpen(function(res){

console.log('WebSocket连接已打开！')

})

wx.onSocketError(function(res){

console.log('WebSocket连接打开失败，请检查！')

})

wx.sendSocketMessage(OBJECT)

通过 WebSocket 连接发送数据，需要先 wx.connectSocket，并在 wx.onSocketOpen 回调之后才能发送。

OBJECT参数说明：

参数

类型

必填

说明

dataString/ArrayBuffer是需要发送的内容

successFunction否接口调用成功的回调函数

failFunction否接口调用失败的回调函数

completeFunction否接口调用世高行结束的回调函数（调用搜哗成功、失败都会执行）

示例代码：

var socketOpen = false

var socketMsgQueue = []

wx.connectSocket({

url: 'test.php'

})

wx.onSocketOpen(function(res) {

socketOpen = true

for (var i = 0i <socketMsgQueue.lengthi++){

sendSocketMessage(socketMsgQueue[i])

}

socketMsgQueue = []

})

function sendSocketMessage(msg) {

if (socketOpen) {

wx.sendSocketMessage({

data:msg

})

} else {

socketMsgQueue.push(msg)

}

}

wx.onSocketMessage(CALLBACK)

监听WebSocket接受到服务器的消息事件。

CALLBACK返回参数：

参数

类型

说明

dataString/ArrayBuffer服务器返回的消息

示例代码：

wx.connectSocket({

url: 'test.php'

})

wx.onSocketMessage(function(res) {

console.log('收到服务器内容：' + res.data)

})

wx.closeSocket()

关闭WebSocket连接。

wx.onSocketClose(CALLBACK)

监听WebSocket关闭。

wx.connectSocket({

url: 'test.php'

})

//注意这里有时序问题，

//如果 wx.connectSocket 还没回调 wx.onSocketOpen，而先调用 wx.closeSocket，那么就做不到关闭 WebSocket 的目的。

//必须在 WebSocket 打开期间调用 wx.closeSocket 才能关闭。

wx.onSocketOpen(function() {

wx.closeSocket()

})

wx.onSocketClose(function(res) {

console.log('WebSocket 已关闭！')

})

Bug &Tip

tip: createSocket 链接默认和最大超时时间都是 60s

tip: 网络请求的 referer 是不可以设置的，格式固定为 https://servicewechat.com/{appid}/{version}/page-frame.html，其中 {appid} 为小程序的 appid，{version} 为小程序的版本号，版本号为 0 表示为开发版。

在app.js的onshow中打开websocket，并设置在错误和失败的监听，当连接断开了的时候需要进行重新连接

在app.js的onhide的关闭websocket

这样避免用户打开小程序之后通过Home键退出的时候防止websocket的断开

第一步：

参考此库官方说数或州明：https://github.com/mqttjs/MQTT.js#browserify

npm install -g webpack // install webpack

cd node_modules/mqtt

npm install . // install dev dependencies

webpack mqtt.js ./my_mqtt.js --output-library-target commonjs2

第二步：

将生成的薯蔽my_mqtt.js文件里所有的：

(function() { return this}())

替换为：

window

第三步：

在my_mqtt.js文件顶部加上代码：团裂

var setImmediate = setTimeout

var clearImmediate = clearTimeout

var socketOpen = false

var socketMsgQueue = []

function sendSocketMessage(msg) {

console.log('send msg:', typeof msg)

console.log(msg)

if (socketOpen) {

wx.sendSocketMessage({

data: msg

})

} else {

socketMsgQueue.push(msg)

}

}

var document = {

URL: ''

}

var window = {

setTimeout: setTimeout,

clearTimeout: clearTimeout,

WebSocket: function (url) {

console.log('call window WebSocket', arguments)

var ws = {

send: sendSocketMessage,

close: wx.closeSocket,

onopen: null,

onmessage: null,

onclose: null,

onerror: null

}

wx.connectSocket({ url: url })

wx.onSocketOpen(function (res) {

console.log('收到onopen事件:', arguments)

socketOpen = true

for (var i = 0i <socketMsgQueue.lengthi++) {

sendSocketMessage(socketMsgQueue[i])

}

socketMsgQueue = []

ws.onopen &&ws.onopen.apply(ws, arguments)

})

wx.onSocketMessage(function (res) {

console.log('收到onmessage事件:', arguments)

console.log(res.data)

ws.onmessage &&ws.onmessage.apply(ws, arguments)

})

wx.onSocketClose(function () {

console.log('收到onclose事件:', arguments)

ws.onclose &&ws.onclose.apply(ws, arguments)

})

wx.onSocketError(function () {

console.log('收到onerror事件:', arguments)

ws.onerror &&ws.onerror.apply(ws, arguments)

})

return ws

}

}

if(!handle){MessageBox(_T("绑定端口失陵握败或者监听失败！"))return}sockaddr fromint fromlen=15flag=TRUEwhile(flag){HANDLE handlefrom=winSocketaccept(handle,&from,&fromlen)//fromlen值小于16就能接收初始化成功。 if(!handlefrom){//MessageBox(_T("启动接受失败！"))continue}BYTE buffer[1024]int sendlen=0sendlen=::winSocketRec(handle,buffer,fromlen,MSG_PEEK)//虚让接收语句一直无法接收数据。 if(sendlen<=0){//MessageBox(_T("接受信息失败！"))int error=0error=::WSAGetLastError()// WSAECONNRESETcontinue}sendlen=::winSocketSend(handle,buffer,fromlen)if(sendlen<=0){//MessageBox(_T("发送差汪局信息失败！"))continue}}::winSocketClose(handle)HANDLE winSocketbind(const TCHAR* szIp,unsigned short nPort,UINT connet)//根据ip和端口启动socket连接，最多连接数{LPSOCKET handle=new ENUMSOCKET()handle->skt=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP)//连接socket，使用tcp发送字符流 //socket(AF_INET,SOCK_STREAM,IPPROTO_TCP)if(handle->skt==INVALID_SOCKET)//连接成功{delete handlereturn NULL}//赋值ip值至socket char ip[64]={0}#ifdef _UNICODE size_t convert=0::wcstombs_s(&convert,ip,64,szIp,63)#else_strcpy_s(ip,64,szIp,63)#endifsockaddr_in addr={0}addr.sin_addr.S_un.S_addr=::inet_addr(ip)//设置ip addr.sin_family=AF_INET//设置网络服务 addr.sin_port=nPort//设置端口//建立连接if(bind(handle->skt,(sockaddr*)&addr,sizeof(addr))==SOCKET_ERROR)//连接失败{delete handleclosesocket(handle->skt)return NULL}::listen(handle->skt,connet)//连接至网络，返回改socket

---