阿波罗Cyber RT框架是基于组件概念构建的。作为阿波罗Cyber RT框架的基本组成模块,每个组件都包含一个特定的算法模块,该模块处理一组输入数据并产生一组输出数据。
为了成功的创建和启动一个新组件,需要执行四个步骤:
- 建立组件文件结构
- 实现组件类
- 设置配置文件
- 启动组件
下面的示例演示了如何创建一个简单的组件,然后构建、运行并在屏幕上看到最终的输出。如果您想进一步探索阿波罗Cyber RT,您可以在**/apollo/cyber/examples/**目录下找到几个展示了如何使用框架的不同功能的示例。
**注:**示例必须在阿波罗的docker环境中运行,它是用Bazel编译的。
请创建以下文件,假定在以下路径:
/apollo/cyber/example/common_component_example/
- 头文件:common_component_example.h
- 源文件:common_component_example.cc
- 构建文件:BUILD
- DAG依赖文件:common.dag
- 启动文件:common.launch
实现common_component_example.h需要:
- 继承组件的类
- 定义您自己的Init和Proc函数,Proc函数需要指定其输入数据类型
- 使用CYBER_REGISTER_COMPONENT将您的组件类注册为全局类
#include <memory>
#include "cyber/class_loader/class_loader.h"
#include "cyber/component/component.h"
#include "cyber/examples/proto/examples.pb.h"
using apollo::cyber::examples::proto::Driver;
using apollo::cyber::Component;
using apollo::cyber::ComponentBase;
class CommonComponentSample : public Component<Driver, Driver> {
public:
bool Init() override;
bool Proc(const std::shared_ptr<Driver>& msg0,
const std::shared_ptr<Driver>& msg1) override;
};
CYBER_REGISTER_COMPONENT(CommonComponentSample)
在common_component_example.cc中,Init函数和Proc函数需要被实现。
#include "cyber/examples/common_component_example/common_component_example.h"
#include "cyber/class_loader/class_loader.h"
#include "cyber/component/component.h"
bool CommonComponentSample::Init() {
AINFO << "Commontest component init";
return true;
}
bool CommonComponentSample::Proc(const std::shared_ptr<Driver>& msg0,
const std::shared_ptr<Driver>& msg1) {
AINFO << "Start common component Proc [" << msg0->msg_id() << "] ["
<< msg1->msg_id() << "]";
return true;
}
创建Bazel构建文件。
load("//tools:cpplint.bzl", "cpplint")
package(default_visibility = ["//visibility:public"])
cc_binary(
name = "libcommon_component_example.so",
deps = [":common_component_example_lib"],
linkopts = ["-shared"],
linkstatic = False,
)
cc_library(
name = "common_component_example_lib",
srcs = [
"common_component_example.cc",
],
hdrs = [
"common_component_example.h",
],
deps = [
"//cyber",
"//cyber/examples/proto:examples_cc_proto",
],
)
cpplint()
要配置DAG依赖文件(common.dag),请指定以下项目:
- 通道名称(name):用于数据的输入输出
- 库路径(component_library):从组件类生成的库
- 类名称(class_name):组件的类名称
# Define all coms in DAG streaming.
component_config {
component_library : "/apollo/bazel-bin/cyber/examples/common_component_example/libcommon_component_example.so"
components {
class_name : "CommonComponentSample"
config {
name : "common"
readers {
channel: "/apollo/prediction"
}
readers {
channel: "/apollo/test"
}
}
}
}
要配置启动文件(common.launch),请指定以下项目:
- 组件名称
- 前面步骤中创建的DAG依赖文件
- 组件中运行的进程的名称
<cyber>
<component>
<name>common</name>
<dag_conf>/apollo/cyber/examples/common_component_example/common.dag</dag_conf>
<process_name>common</process_name>
</component>
</cyber>
运行以下命令来构建组件:
bash /apollo/apollo.sh build
注:确保示例组件构建完好
然后配置环境:
cd /apollo/cyber
source setup.bash
有两种方式启动组件:
-
通过启动文件来启动组件(推荐):
cyber_launch start /apollo/cyber/examples/common_component_example/common.launch
-
通过DAG依赖文件来启动组件:
mainboard -d /apollo/cyber/examples/common_component_example/common.dag
开启另一个终端
source cyber/setup.bash
export GLOG_alsologtostderr=1
/apollo/bazel-bin/cyber/examples/common_component_example/channel_test_writer
开启第三个终端
source cyber/setup.bash
export GLOG_alsologtostderr=1
/apollo/bazel-bin/cyber/examples/common_component_example/channel_prediction_writer
您将会在第一个终端中看到类似下列输出
I0331 16:49:34.736016 1774773 common_component_example.cc:25] [mainboard]Start common component Proc [1094] [766]
I0331 16:49:35.069005 1774775 common_component_example.cc:25] [mainboard]Start common component Proc [1095] [767]
I0331 16:49:35.402289 1774783 common_component_example.cc:25] [mainboard]Start common component Proc [1096] [768]