1.所有监听事件先在装载监听。

//page/index/to _ news/to _ news。射流研究…

var app=GetApp()；

var socketOpen=false

var SocketTask=false

var URL=' ws ://192。168 .0 .120:7011 ';

页面({

数据： {

输入值： ' ',

返回值： ' ',

},

在线加载：函数（选项){

},

onReady:函数(){

//创建窝

SocketTask=wx.connectSocket({

url: url，

数据： '数据，

header: {

内容类型' : '应用程序/json '

},

方法： '发布，

成功：功能(res) {

console.log('WebSocket连接创建，res)

},

fail:函数(错误){

wx.showToast({

标题： '网络异常!',

})

console.log(错误)

},

})

if (SocketTask) {

SocketTask.onOpen(res={

console.log('监听WebSocket连接打开事件，res)

})

SocketTask.onClose(onClose={

console.log('监听WebSocket连接关闭事件，onClose)

})

SocketTask.onError(onError={

console.log('监听WebSocket错误。错误信息，onError)

})

套接字任务。Onmessage(Onmessage={

console.log('监听WebSocket接受到服务器的消息事件。服务器返回的消息，onMessage)

})

}

},

//提交文字

提交至：功能(e) {

让那个=这个；

那个。数据。AllContentList。Push({ ThAT。数据。input value })；

that.setData({

所有内容列表：数据。所有内容列表

})

定义变量数据={

文本：

}

if (socketOpen) {

//如果打开了窝就发送数据给服务器

发送套接字消息（数据)

}

},

bindKeyInput:函数(e) {

this.setData({

inputValue: e.detail.value

})

},

在线：函数(){

SocketTask.close(函数(关闭){

console.log('关闭WebSocket连接","关闭)

})

},

})

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

函数发送套接字消息(数据){

console.log('通过WebSocket连接发送数据)

if (socketOpen) {

套接字任务。发送({ data : JSON。stringify(数据)

},函数(res) {

console.log('已发送，res)

})

} else {

socketMsgQueue.push(msg)

}

}

超文本标记语言

输入类型=' text '绑定输入=' BindKeyInput '值=' { { InputValue } } '占位符=' ' ' '/

按钮绑定点击='提交给'类='用户输入文本'发送/按钮