Linux上实现基于TCP和Unix domain Socket的本地IPC通信模型

    xiaoxiao2022-07-12  147

    功能:Linux上实现基于TCP和Unix domain Socket的本地IPC通信模型。类似安卓下的binder通信模式,可以自由定制service服务。

    概念: server (服务器); service(服务); client(客户);

    结构:采用CSS(client-server-service)模式,一个server负责管理client和service服务。可以在server上注册多个service,service是可以自定义添加的,一个Client在connet到server时可以指定绑定到某个service,这个service可以为client提供服务。一个service可以绑定多个client,一个client在运行的过程中也可以重绑定到其他service。Client和server建立的是Unix domain socket链接,log接受器和server建立的是TCP链接。

     

    代码仓库: https://github.com/fanchenxinok/IPC_Model.git

    目录说明:

    Server: server核心代码所在目录

    Services: service服务代码,用户可以自己添加service服务

    Log_recv: log接收器,可以在filters数组上添加过滤字段,过滤自己感兴趣的log。凡是通过Log.h头文件定义的LOG_OUTPUT输出的log都可以用Log_recv接收。

    Test: 测试例子

     

    Client请求的消息模式:

    带超时等待callback返回的请求不需要等待callback返回的请求异步执行callback的请求不需要callback的请求

    Message.h头文件中定义的结构体:

    typedef struct

    {

             call_back cb_func;

             int cb_async;

             int wait_time;  // // -1: wait forever, 0: not wait, > 0: wait ms

    }stCbInfo;

    *  如果cb_func要执行比较耗时的操作将影响service服务器处理其他client的请求

    *  因此需要将cb_async置为1, 使cb_func在client_connect的时候

    *  创建的线程中执行,这样可以避免service被一个client占用而影响其他client.

    *

    *  如果cb_async被置为0则可以分为两种情况:

             (1) 如果wait_time 大于0 则client 需要等待callback执行完才能继续,且超时时间为wait_time 毫秒。

             (2) 如果wait_time 等于0, 则client向服务器发送完命令后,不需要等待可直接执行

     

     

    环境搭建:

     

    (1)下载 waf工具:https://waf.io/ or $ curl -o waf-2.0.9.tar.bz2 https://waf.io/waf-2.0.9.tar.bz2

    (2) 解压

      $ tar xjvf waf-2.0.9.tar.bz2

      $ cd waf-2.0.9

      $ ./waf-light

      $  cd waf-2.0.9

      $ PATH=$PATH:$PWD

    (3) 编译

       $ waf configure build

    (4) 运行

         $ cd IPC_Model

         $ cp ./build/server/libserver.so /usr/lib  

         或者export LD_LIBRARY_PATH=$PWD/build/server

         $  ./build/test/server_test

     

    测试:

    最新回复(0)