nodejs addon實作回調函數事件

封裝nodejs的addon接口，在處理回調函數這塊走了很多彎路，在此提供一個簡單的測試程式，有興趣的可以研究下。

安裝nan子產品

npm install nan
           

binding.gyp檔案内容如下：

{
    'targets': [
    {
        "target_name": "bjcast_project_addon", 
        "sources": ["./bjcast_project_addon.cc"],
        
        "include_dirs": [
            "<!(node -e \"require('nan')\")",
        ],            
    }
    ]  
}
           

bjcast_project_addon.cc内容如下：

#include <iostream>
#include <string>

#include <v8.h>
#include <nan.h>
#include<windows.h>
using namespace v8;

struct OnStartSessionData {
  Nan::Callback *callback;    //回調函數
  int reason;                 //需要回調到js層的資料
  uv_async_t handle;          //異步句柄
};

OnStartSessionData *on_start_session_data = new OnStartSessionData();

static void OnBJCastStartSession(const int reason) {    
  on_start_session_data->reason = reason;
  on_start_session_data->handle.data = (void *)on_start_session_data; //資料類型的一些轉換
  uv_async_send(&on_start_session_data->handle);                      //喚醒事件循環中的事件  
}

void OnStartSessionEvent(uv_async_t *handle) {                  //具體執行的事件
  Nan::HandleScope scope;
  OnStartSessionData *data = (OnStartSessionData *)handle->data;
  v8::Local<v8::Value> argv[1] = {Nan::New((int)data->reason)};//資料類型的一些轉換
  data->callback->Call(1, argv);                               //資料回調到js層
}

NAN_METHOD(bjcast_session) {
  Local<String> ip_value = Local<String>::Cast(info[0]);
  String::Utf8Value ip(ip_value);
  std::string ip_str = std::string(*ip);

  Local<Number> port_value = Local<Number>::Cast(info[1]);
  double port = port_value->NumberValue();

  Local<String> pin_value = Local<String>::Cast(info[2]);
  String::Utf8Value pin(pin_value);
  std::string pin_str = std::string(*pin);

  Nan::Callback *start_session_callback = new Nan::Callback(info[3].As<Function>());
   
  on_start_session_data->callback = start_session_callback;  //擷取回調函數 
  uv_async_init(uv_default_loop(), &on_start_session_data->handle,OnStartSessionEvent);  //加入事件循環中，等待喚醒，uv_default_loop()擷取libuv預設建立的事件循環句柄

//   int32_t value = BJCastProjectLib::GetInstance().StartBJCastSession(
//       ip_str.c_str(), (uint16_t)port, pin_str.c_str(),start_session_callback);
  
  int value = 0;
  Local<Value> argv[1] = {Nan::New((int)value)};
  info.GetReturnValue().Set(Nan::New((int)value));

  OnBJCastStartSession(5);   
}


NAN_MODULE_INIT(init) {
  Nan::Export(target, "startBJCastSession", bjcast_session);
}

NODE_MODULE(bjcast_project_addon_win, init)
           

index.js的内容如下：

var BJLib = require('./build/Release/bjcast_project_addon.node');

var serverIp = '192.168.9.155';
var serverPort = 8188;
var pin = '';


onStartSessionResult =function(result) {  
  console.log('result =  ', result);
}

var ret_value = BJLib.startBJCastSession(
    serverIp, serverPort, pin, onStartSessionResult);  

console.log(ret_value);

           

運作

node index.js
0
result =   5