微信小程序开发 专题
专题目录
您的位置:微信小程序开发 > 微信小程序开发专题 > 微信小程序API Websocket
微信小程序API Websocket
作者:--    发布时间:2019-11-20

wx.connectsocket(object)


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

object参数说明:

参数 类型 必填 说明 最低版本
url string 开发者服务器接口地址,必须是 wss 协议,且域名必须是后台配置的合法域名  
data object 请求的数据  
header object http header , header 中不能设置 referer  
method string 默认是get,有效值: options, get, head, post, put, delete, trace, connect  
protocols stringarray 子协议数组 1.4.0
success function 接口调用成功的回调函数  
fail function 接口调用失败的回调函数  
complete function 接口调用结束的回调函数(调用成功、失败都会执行)  

示例代码:
wx.connectsocket({  
  url: 'test.php',
  data:{
    x: '',
    y: ''
  },
  header:{ 
    'content-type': 'application/json'
  },  protocols: ['protocol1'],
  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参数说明:

参数 类型 必填 说明
data string/arraybuffer 需要发送的内容
success function 接口调用成功的回调函数
fail function 接口调用失败的回调函数
complete function 接口调用结束的回调函数(调用成功、失败都会执行)

示例代码:

var socketopen = false
var socketmsgqueue = []
wx.connectsocket({
  url: 'test.php'
})

wx.onsocketopen(function(res) {
  socketopen = true
  for (var i = 0; i < socketmsgqueue.length; i++){
     sendsocketmessage(socketmsgqueue[i])
  }
  socketmsgqueue = []
})

function sendsocketmessage(msg) {
  if (socketopen) {
    wx.sendsocketmessage({
      data:msg
    })
  } else {
     socketmsgqueue.push(msg)
  }
}

wx.onsocketmessage(callback)


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

callback返回参数:

参数 类型 说明
data string/arraybuffer 服务器返回的消息

示例代码:

wx.connectsocket({
  url: 'test.php'
})

wx.onsocketmessage(function(res) {
  console.log('收到服务器内容:' + res.data)
})

wx.closesocket(object)


关闭websocket连接。

参数 类型 必填 说明 最低版本
code number 一个数字值表示关闭连接的状态号,表示连接被关闭的原因。如果这个参数没有被指定,默认的取值是1000 (表示正常连接关闭) 1.4.0
reason string 一个可读的字符串,表示连接被关闭的原因。这个字符串必须是不长于123字节的utf-8 文本(不是字符) 1.4.0
success function 接口调用成功的回调函数  
fail function 接口调用失败的回调函数  
complete function 接口调用结束的回调函数(调用成功、失败都会执行)  

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 已关闭!')
})

返回值:

基础库 1.7.0 开始支持,低版本需做兼容处理

返回一个 sockettask。

bug & tip

  1. tip: createsocket 链接默认和最大超时时间都是 60s
  2. tip: 网络请求的 referer 是不可以设置的,格式固定为 https://servicewechat.com/{appid}/{version}/page-frame.html,其中{appid}为小程序的 appid,{version}为小程序的版本号,版本号为 0 表示为开发版。

sockettask

基础库 1.7.0 开始支持,低版本需做兼容处理

websocket 任务,可通过 wx.connectsocket() 接口创建返回。

方法

sockettask.send(object)

通过 websocket 连接发送数据。

object参数说明:

参数 类型 必填 说明
data string/arraybuffer 需要发送的内容
success function 接口调用成功的回调函数
fail function 接口调用失败的回调函数
complete function 接口调用结束的回调函数(调用成功、失败都会执行)
sockettask.close(object)

关闭 websocket 连接。

object参数说明:

参数 类型 必填 说明
code number 一个数字值表示关闭连接的状态号,表示连接被关闭的原因。如果这个参数没有被指定,默认的取值是1000 (表示正常连接关闭)
reason string 一个可读的字符串,表示连接被关闭的原因。这个字符串必须是不长于123字节的utf-8 文本(不是字符)
success function 接口调用成功的回调函数
fail function 接口调用失败的回调函数
complete function 接口调用结束的回调函数(调用成功、失败都会执行)
sockettask.onopen(callback)

监听 websocket 连接打开事件。

sockettask.onopen(callback)

监听 websocket 连接关闭事件。

sockettask.onerror(callback)

监听 websocket 错误。

callback返回参数:

参数 类型 说明
errmsg string 错误信息
sockettask.onmessage(callback)

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

callback返回参数:

参数 类型 说明
data string/arraybuffer 服务器返回的消息
网站声明:
本站部分内容来自网络,如您发现本站内容
侵害到您的利益,请联系本站管理员处理。
联系站长
373515719@qq.com
关于本站:
编程参考手册