Autoware.ai人机交互模块的架构设计与性能优化实战

1次阅读

没有评论

共计 1991 个字符，预计需要花费 5 分钟才能阅读完成。

在使用 Autoware.ai 进行自动驾驶开发时，原生的人机交互 (Human-Machine Interface, HMI) 模块存在几个明显问题：

高延迟问题：基于 ROS 1 的同步通信机制导致指令响应延迟经常超过 200ms，在紧急制动等场景下会直接影响行车安全
扩展性差：交互消息类型硬编码在代码中，添加新指令需要重新编译整个模块
多模态支持不足：难以同时处理语音、触控等多种输入方式

一个典型场景是：当驾驶员通过触摸屏发送变道指令时，由于系统繁忙导致响应延迟，车辆可能错过最佳变道时机甚至引发危险。

我们选择 ROS 2 作为基础架构，主要考虑以下优势：

异步通信：ROS 2 默认采用基于 DDS 的异步发布 / 订阅模型，避免了 ROS 1 中同步等待的问题
QoS 策略(Quality of Service)：可以针对不同消息类型设置优先级，确保关键指令优先处理
去中心化发现：节点之间直接通信，不需要通过 roscore 中转

核心通信流程如下图所示（以变道指令为例）：

@startuml
participant "HMI Panel" as panel
participant "Control Node" as control

group 异步消息流程
panel -> control : LaneChangeCommand (异步发布)
activate control
control --> panel : CommandAck (QoS=HIGH)
deactivate control
@end
@enduml

关键配置参数：

使用 RELIABLE 可靠性模式确保消息必达
设置 DEADLINE 策略检测超时
为 ACK 响应配置 HIGH 优先级 QoS

对于大尺寸消息（如地图片段），我们集成 Protocol Buffers 进行压缩：

定义 .proto 消息格式
编译生成 C ++ 序列化代码
在 ROS 2 消息回调中自动解压

测试显示，对于 1MB 的地图数据，压缩后传输大小减少 62%。

通过 ROS 2 IDL 定义交互协议：

// 自定义交互消息
module autoware_auto_hmi_msgs {
  struct LaneChangeCommand {
    uint8 lane_id;
    @default(value=0.5)
    float urgency;  // 紧急程度
  };
};

使用 rclcpp 的线程安全队列处理高优先级消息：

class PriorityQueue : public rclcpp::Waitable {
public:
  void push(const Message::SharedPtr msg, Priority prio) {std::lock_guard<std::mutex> lock(mutex_);
    queues_[static_cast<int>(prio)].push(msg);
    cv_.notify_one();}

  // ... 其他实现
private:
  std::array<std::queue<Message::SharedPtr>, 3> queues_;
  std::mutex mutex_;
  std::condition_variable cv_;
};

关键点：

使用 std::mutex 保证多线程安全
按优先级分队列存储
通过条件变量实现高效等待

使用 LTTng 工具分析端到端延迟：

安装 LTTng 工具链

注入追踪点：

lttng create autoware-session
lttng enable-event -u 'ros2:*'
lttng start

使用 babeltrace 分析结果

实测数据显示，优化后 95% 的指令延迟控制在 120ms 以内。

在不同消息大小下的性能对比（单位：msg/s）：

消息大小	ROS 1	ROS 2 优化版
1KB	850	2100
10KB	120	980
100KB	15	210

在 fastdds.xml 配置中添加：

<participant>
  <rtps>
    <builtin>
      <discovery_config>
        <initialAnnouncements count="5" period="0.1"/>
      </discovery_config>
    </builtin>
  </rtps>
</participant>

当 Python 节点与 C ++ 节点通信时：