美文网首页
libuv的典型应用——CTP的Node.js封装

libuv的典型应用——CTP的Node.js封装

作者: 一个灰 | 来源:发表于2018-10-09 11:38 被阅读0次

    写过CTP的同学可能不多,这是一个期货接口。没听说过的也无妨。

    C++多线程回调

    CTP 提供了若干个父类供开发者继承,里面的回调都是通过覆盖父类的纯虚函数实现。
    当SDK有事件发生的时候,就会调用这些定义的回调函数。

    class CThostFtdcTraderSpi
    {
    public:
        virtual void OnFrontConnected(){};
        virtual void OnFrontDisconnected(int nReason){};
    

    编写一个这样的程序是十分痛苦的,因为回调函数的执行是在某个工作线程中。所以很容易引起并发读写的问题。代码会变得十分复杂。

    编写过Node.js的同学一定以及十分习惯Node的单线程模式,回调函数执行的时候虽然有点“不同步”,但好歹是在一个线程中,所以定义域里面的变量可以随便使用。用惯这种方便的编程方式的同学,如果去接触一下C++那种多线程回调,一定会抓狂的。

    那么如何让CTP开发也能很舒服呢?或者干脆将CTP封装成Node的原生模块,然后在Node中调用,岂不妙哉。

    这时候协调C++多线程和Nodejs单线程的关键角色就登场了,这就是libuv。

    #include <uv.h>
    uv_async_t async_t;
    uv_async_init(uv_default_loop(),&async_t,NULL);
    

    我们可以初始化一个默认的事件循环。
    然后我们可以把所有的回调虚函数都用下面的方式去实现

    void uv_trader::OnFrontConnected() {        
        CbRtnField* field = new CbRtnField();
        field->eFlag = T_ON_CONNECT;//FrontConnected
        field->work.data = field;
        uv_queue_work(uv_default_loop(), &field->work, _on_async, _on_completed);
    }
    

    其中_on_async是个空函数,忽略。_on_completed函数回在事件循环的时候触发,保证在主线程中调用。然后我们在这个函数再去调用js的函数。

    void uv_trader::_on_completed(uv_work_t * work,int){
        CbRtnField* cbTrnField = static_cast<CbRtnField*>(work->data);
        std::map<int, WrapTrader*>::iterator it = cb_map.find(cbTrnField->eFlag);
        if (it != cb_map.end()) {
            cb_map[cbTrnField->eFlag]->FunCallback(cbTrnField);
        }
        if (cbTrnField->rtnField)
            delete cbTrnField->rtnField;
        if (cbTrnField->rspInfo)
            delete cbTrnField->rspInfo;
        delete cbTrnField;
    }
    

    除了释放资源,上面代码就是从一个存储着js回调函数的map中找到对应的js函数进行调用。

    这些js函数都是在事先注册好的,就在nodejs中。

    trader.on("connect",function(result){
        console.log("on connected");
        trader.reqUserLogin('','','',function(result,iRequestID){
            console.log('login return val is '+result);
        });
    });
    

    js代码写起来就舒服多了。

    https://github.com/langhuihui/node-ctp

    相关文章

      网友评论

          本文标题:libuv的典型应用——CTP的Node.js封装

          本文链接:https://www.haomeiwen.com/subject/jfjeaftx.html