这里是基于事件发射器(EventEmitter)概念的代码片段,它模拟从本地层(C/C++)读取传感器数据并将其推送到 Node.js (JavaScript) 层。在这个例子中,我们使用的是
node-addon-api,一个只有头文件的 C++ 包装器。在这个例子中,我们使用了一个 for 循环(仅五次迭代),实际上它可以是一个无限循环,不断读取传感器输出,并将数据推送到 JS 层。本地层可以决定何时向 JS 层报告从传感器收集到的数据。JS 将异步接收订阅事件的数据。
#include <napi.h>
#include <thread>
Napi::Value CallEmit(const Napi::CallbackInfo &info)
{
char buff1[128];
char buff2[128];
int sensor1 = 0;
int sensor2 = 0;
Napi::Env env = info.Env();
Napi::Function emit = info[0].As<Napi::Function>();
emit.Call( {Napi::String::New(env, "start")} );
for (int i = 0; i < 5; i++)
{
std::this_thread::sleep_for(std::chrono::seconds(2));
sprintf(buff1, "sensor1 data %d ...", ++sensor1);
emit.Call( { Napi::String::New(env, "sensor1"),
Napi::String::New(env, buff1 ) } );
if (i % 2)
{
sprintf(buff2, "sensor2 data %d ...", ++sensor2);
emit.Call({ Napi::String::New(env, "sensor2"),
Napi::String::New(env, buff2) });
}
}
emit.Call( {Napi::String::New(env, "end")} );
return Napi::String::New( env, "OK" );
}
模块注册片段如下:
#include <napi.h>
Napi::Object Init( Napi::Env env, Napi::Object exports )
{
exports.Set(Napi::String::New(env, "callEmit"), Napi::Function::New(env, CallEmit));
return exports;
}
NODE_API_MODULE( myncpp1, Init )
编译上述本地代码,一旦成功构建,则可以运行以下node.js JavaScript代码进行测试。
'use strict'
const EventEmitter = require('events').EventEmitter
const addon = require('bindings')('myncpp1')
function Main() {
const emitter = new EventEmitter()
emitter.on('start', () => {
console.log( '### Sensor reading started ...');
})
emitter.on('sensor1', (evt) => {
console.log(evt);
})
emitter.on('sensor2', (evt) => {
console.log(evt);
})
emitter.on('end', () => {
console.log('### Sensor reading Ended');
})
addon.callEmit( emitter.emit.bind(emitter) )
}
Main();
代码段应产生以下输出。
sensor1 data 1 ...
sensor1 data 2 ...
sensor2 data 1 ...
sensor1 data 3 ...
sensor1 data 4 ...
sensor2 data 2 ...
sensor1 data 5 ...