在一个nodejs module顶层把数据保存在this的自定义属性里：

然而在回调函数的上下文里，this发生了变化：


要获取更多Jerry的原创文章，请关注公众号"汪子熙":

基于 websocket使用
需求
例：发送登录请求后及时获取返回值，然后根据返回值处理接下来的事件，类似http请求，不过需求是要用websocket做到这一点。
思考
我们在websocket 介绍上能够充分认知到websocket的所有回调函数都是异步执行的，也就是说我发送send(msg)之后我要读取信息是在onmessage()里面读取，这显然不符合我们的要求。
解决
dispatch.js
//作为get获取数据的回调对象存储
this.messageList = {};
//自定义Ws消息接收函数：服务器向前端推送消息时触发
this.onmessage = ((e) => {
    //处理各种推送消息
    const message = JSON.parse(e.data);
    const eventName = message.action.splice('Rsp','')
    //执行回调
    this.messageList[eventName](message);
})     

//发送消息后回调
WBT.prototype.sendMsg = function(obj, callback) {    
	const name = obj.action.replace('Req','');
	//存储事件
	this.messageList[name] = callback;
	this.socket.send(JSON.stringify(obj));
}

index.html
let loginParam = {
    action: "loginReq",
    tsxId: "1",
    params: {
    dc: {
        id: "admin",
        passwd: "21232f297a57a5a743894a0e4a801fc3",
        version: "UDT-0.3.0"
       }
    }
}
function test() {
   WS.sendMsg(loginParam, function (data) {
        console.log(data)
    })
}

最后
到这一步就是可以类似ajax发起http请求并及时回调数据过来。

不过还有最新的 async可以做成类同步形式，更加方便调用，不过因为受限浏览器版本和我项目实际情况，我就不赘述了，有兴趣的可以看一下这篇博客:es6使用websocket同步等待方法

pybind 调用c++

开始的时候不报错，但是程序退出了，解决方法，返回值强转void *

aa=binddemo.start_server(self.server_callback)

WebSocket_server *start_server(py::function callback_f) {

	WebSocket_server *server_instance1;
		server_instance1 = &server_instance;
		callback_f((void *)server_instance1);

}

也可以这样：

WebSocket_server *start_server(py::function callback_f) {
        WebSocket_server server_instance;
		callback_f((void *)&server_instance);
}

 

 

m.def("start_server", &start_server, "start_server");

1.7.0 及以上版本，最多可以同时存在 5（小游戏）/2（小程序）个 WebSocket 连接。

小程序需要在页面onload时开启监听websocket事件（重点）（防止监听函数被多次调用），不然多次监听将会多次调用监听事件。

  onLoad: function (options) {


    wx.onSocketMessage((res) => {
      console.log('WebSocket收到消息')
    })
    wx.onSocketOpen(() => {
      console.log('WebSocket连接打开')
   })
    wx.onSocketError(function (res) {
      console.log('WebSocket连接打开失败')
    })

    wx.onSocketClose(function (res) {
      console.log('WebSocket 已关闭！')
    })

}

连接websocket，首先需要在服务器域名中设置socket合法域名



wx.connectSocket({
  url: 'wss://example.qq.com',
  data:{
    x: '',
    y: ''
  },
  header:{
    'content-type': 'application/json'
  },
  protocols: ['protocol1'],
  method:"GET"
})

当连接成功时将会在

    wx.onSocketOpen(() => {

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

   })

函数中回调

当成功连接时就可以与websocket服务进行交互发送消息

    wx.sendSocketMessage({
      data:msg
    })

websocket回应的消息将会在

 wx.onSocketMessage((res) => {

      console.log('WebSocket收到消息')

    })

函数中回调

 




关闭websocket

wx.closeSocket()

 

小程序调试工具