电子说
在说vsomeip之前,先介绍一下它的贡献者——GENIVI,是一个非营利汽车行业联盟。这个联盟成立于2009年,已经成功地完成了最初的使命,提供了一个开放的、基于linux的车载信息娱乐(IVI)平台,并扩大了其范围,帮助汽车制造商及其供应商开发标准方法。
在汽车行业,GENIVI的项目被非常广泛地应用,比如:vsomeip,CommonAPI C++,DLT…没见用过的就不列出来了,感兴趣可以到官网了解更多。
vsomeip是一个开源C++库,它实现了SOME/IP协议栈。接下来,我们通过一个demo,感受一下SOME/IP的通信过程,以及如何使用vsomeip,废话不多说,让我们开始吧~
首先,需要搭建环境(这里以Ubuntu16.04为例),vsomeip依赖Boost(1.55以上版本),因此我们需要先编译和安装Boost:
接着,编译和安装vsomeip:
上面这个配色,着实让人匪夷所思(还是我用的有问题?),总之,我不喜欢,所以以后不再插入bash代码,环境配置相关内容尽可能写进README里,放到Github上,关注公众号,回复“演示代码”,就可以看到全部文章里涉及到的工程地址啦~
官方的helloworld,稍微有点简单,demo的思路是这样的:
实现一个服务端,可以:1. 响应请求,内容为请求的反转;2. 触发事件
实现一个客户端,可以:1. 发送请求;2. 订阅、接收事件
首先,服务端和客户端需要约定一些ID,包括:
对于服务端,主要代码如下:
// 创建应用对象
app = vsomeip::runtime::get()->create_application("World");
// 创建事件组,并添加事件组SAMPLE_EVENTGROUP_ID
std::set
其中,请求消息的回调函数:
void on_message(const std::shared_ptr {
std::shared_ptr
对于客户端,主要代码如下:
// 同样地,创建应用对象
app = vsomeip::runtime::get()->create_application("Hello");
// 初始化应用
app->init();
// 注册服务是否可用的回调
app->register_availability_handler(SAMPLE_SERVICE_ID, SAMPLE_INSTANCE_ID, on_availability);
// 请求服务
app->request_service(SAMPLE_SERVICE_ID, SAMPLE_INSTANCE_ID);
// 注册接收所有消息的回调
app->register_message_handler(vsomeip::ANY_SERVICE, vsomeip::ANY_INSTANCE, vsomeip::ANY_METHOD, on_message);
// 发送请求线程
std::thread sender(run);
// 启动应用
app->start();
其中,监听服务是否可用的回调函数:
void on_availability(vsomeip::service_t _service, vsomeip::instance_t _instance, bool _is_available) {
std::cout << "CLIENT: Service ["
<< std::setw(4) << std::setfill('0') << std::hex << _service << "." << _instance
<< "] is "
<< (_is_available ? "available." : "NOT available.")
<< std::endl;
// 服务可用了,可以去发送请求啦:)
if (_is_available) { condition.notify_one(); }
}
接收所有消息的回调函数:
void on_message(const std::shared_ptr {
std::stringstream its_message;
its_message << "CLIENT: received a notification for event ["
<< std::setw(4) << std::setfill('0') << std::hex
<< _response->get_service() << "."
<< std::setw(4) << std::setfill('0') << std::hex
<< _response->get_instance() << "."
<< std::setw(4) << std::setfill('0') << std::hex
<< _response->get_method() << "] to Client/Session ["
<< std::setw(4) << std::setfill('0') << std::hex
<< _response->get_client() << "/"
<< std::setw(4) << std::setfill('0') << std::hex
<< _response->get_session()
<< "] = ";
std::shared_ptr
客户端发送请求线程函数:
void run() {
std::unique_lock
编译,运行结果如下:
通过打印出来的日志,我们可以比较清晰地看到整个通信的过程,并且实现了预期的效果。这个例子只能说明如何快速地上手vsomeip,其实,还有很多东西可以挖掘,比如vsomeip怎么配置,routing manager怎么配置,和dlt怎么联动等等,真是学无止境呀,今天就先到这儿吧~
审核编辑:刘清
全部0条评论
快来发表一下你的评论吧 !