使用asio2库进行进程间通信-创新互联-成都快上网建站

使用asio2库进行进程间通信-创新互联

一,asio2 网络库 介绍

创新互联公司是一家专业提供龙华企业网站建设,专注与成都网站设计、做网站成都h5网站建设、小程序制作等业务。10年已为龙华众多企业、政府机构等服务。创新互联专业网站制作公司优惠进行中。

简单理解 asio2 是一个支持 tcp, udp, http, websocket, rpc, ssl, icmp, serial_port的c++第三方库。项目需要,目前我仅仅用到了rpc 这部分功能,使用它来替换QtRo 实现进程间通信,QtRo 用起来太麻烦,需要接口文件,并称生成对应的代码,还要去继承,实现。这个相对简单点。

https://github.com/zhllxt/asio2

二,使用

甭管是客户端还是服务端,定义好 函数后,通过bind 绑定,之后 对端 就可以异步调用了(async_call)。

(1),客户端

//连接服务端
bool RPCClient::run(std::string_view host,std::string_view port)
{
    client.set_default_timeout(std::chrono::seconds(20));

    client.bind_connect([&]()
    {
        if (asio2::get_last_error())
            return;
        if (client.is_started())
        {
            ASIO2_ASSERT(asio2::get_last_error() == rpc::error::in_progress);
        }
        else
        {
            ASIO2_ASSERT(asio2::get_last_error() == rpc::error::not_connected);
        }
    });
    bind();
    return client.start(host, port);
}
//绑定需要提供给服务端的函数
void RPCClient::bind()
{
    client.bind("receiveCloudNormal",&RPCClient::receiveCloudNormal,this);
    client.bind("receiveRun",&RPCClient::receiveRun,this);
    client.bind("receiveStop",&RPCClient::receiveStop,this);
    client.bind("receiveImg",&RPCClient::receiveImg,this);
}

//处理具体的业务
void RPCClient::receiveRun()
{
    std::cout<<"receiveRun "<<" time:"<

(2)服务端

//监听 ip 端口
bool RPCServer::run(std::string_view host,std::string_view port)
{
    server.bind_connect([&](auto & session_ptr)
    {
        std::cout<<"client enter : "<remote_address().c_str()<<" "<< session_ptr->remote_port()<<" "<local_address().c_str()<<" "<< session_ptr->local_port()<

三, 注意

(1),如何发送图片,比如opencv Mat

这个库 只支持c++ 内置类型,因此所有自定义类型,最好都要转成c++ 内置类型,发送图片是将mat 编码到了 string里。

//自定义图片 结构体
struct Img
{
    std::string piexl;
    templatevoid serialize(Archive & ar)
    {
        ar(piexl);
    }
};

//发送图片进行编码
void Widget::on_sendImg_clicked()
{
    if(!imgFile.isEmpty()){
        cv::Mat image = imread(imgFile.toStdString().c_str());

        RPCData::Img img;

        std::vectorbuff;
        cv::imencode(".png", image, buff);
        img.piexl.resize(buff.size());
        memcpy(&img.piexl[0], buff.data(), buff.size());

        server->sedImg(img);
    }
}


//收到图片进行解码
void RPCClient::receiveImg(RPCData::Img img)
{
    std::cout<<"receiveImg  "<< img.piexl.size()<< " time:"<

(2),如何发送点云 

//自定义点云 结构体
struct Point{
    Point(){
        x=0.0;
        y=0.0;
        z=0.0;
    }
    Point(float _x,float _y,float _z){
        x=_x;
        y=_y;
        z=_z;
    };

    float x;
    float y;
    float z;
    templatevoid serialize(Archive & ar)
    {
        ar(x);
        ar(y);
        ar(z);
    }
};

struct CloudNormal{
    std::vectorpoints;

    templatevoid serialize(Archive & ar)
    {
        ar(points);
    }
};

你是否还在寻找稳定的海外服务器提供商?创新互联www.cdcxhl.cn海外机房具备T级流量清洗系统配攻击溯源,准确流量调度确保服务器高可用性,企业级服务器适合批量采购,新人活动首月15元起,快前往官网查看详情吧


分享标题:使用asio2库进行进程间通信-创新互联
URL地址:http://kswjz.com/article/doiods.html
扫二维码与项目经理沟通

我们在微信上24小时期待你的声音

解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流