在一个nodejs module顶层把数据保存在this的自定义属性里：
 
 
然而在回调函数的上下文里，this发生了变化：
 
 
 
要获取更多Jerry的原创文章，请关注公众号"汪子熙":
 

背景：设备与相机链接作为服务器给前端界面传送图片。相机采图后将图片传递给前端界面展示。
 
相机提供的SDK中是以回调函数的形式进行采图，我们在回调函数中直接调用websocket提供的write_message()方法将采集的图片传递给前端。此时会报如下错误：
 
There is no current event loop in thread 'Thread-1'
 
翻译过来，线程中没有当前事件循环，即当进入回调函数后丢失了event loop，看了一些资料，此时可以在回调函数中创建新的even loop给write_message()方法使用。如下：
 
loop =  asyncio.new_event_loop()
asyncio.set_event_loop(loop)
 
但此时会出现新的错误，猜测是新的event loop与此前分配给当前方法的loop之间可能存在冲突。
 
因此，不创建新的event loop，而是在回调函数所在的py中定义一个全局变量获得当前被分配的event loop。即，
 
# get current loop
loop = asyncio.get_event_loop()
 
然后在回调函数中调用write_message()方法前使用如下代码，即可解决。
 
# set a loop to this method
asyncio.set_event_loop(loop)
 
对这块的理解还不够清楚，如有问题，欢迎大家指出。

JavaScript支持函数作为参数传递，当作为参数传递至另一个函数的内部时，该参数就是一个可调用的函数。
 
调用方法，参数名后直接加括号，如：callbak()。
 
设置回调函数内的上下文，即在回调函数内访问 this，方法：callback.apply(this) ，如果不设置，则 this 默认指向 windows 。
 
完整代码如下：
 
fun1 : function (callback , content) {
         callback();        
         callback.apply( content );
     }
 
 

 

基于 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同步等待方法