04 EventGroup订阅流程：Client端SubscribeEventGroup与Server端响应实现

🧩订阅链路拆解：从Client请求到Server确认的完整闭环

在SOME/IP通信中，EventGroup的订阅是服务发现（Service Discovery）之后最关键的动态行为。Client端通过SubscribeEventGroup报文向Server请求接收特定事件组的数据，Server则根据权限和状态决定是否发送SubscribeEventGroupAck确认。这一过程如果出现报文丢失、确认超时或状态机错乱，将直接导致应用层收不到事件通知。本节围绕“Client发起订阅 → Server处理 → 抓包验证”这条主线，重点剖析SubscribeEventGroup报文的构造、Server端订阅管理逻辑，以及如何通过抓包和日志确认订阅是否成功

⭐EventGroup订阅流程

订阅流程的核心目标是：Client发送SubscribeEventGroup请求后，能在指定超时时间内收到Server回复的SubscribeEventGroupAck（确认）或SubscribeEventGroupNack（拒绝）。如果既无Ack也无Nack，Client应重试或进入错误处理。本节需要解决三个关键问题：

• 报文构造正确性：Client发送的SubscribeEventGroup报文必须包含有效的EventGroup ID、TTL（生存时间）以及可选的Option字段（如Endpoint Option用于指定接收端口）
• Server端订阅状态管理：Server收到订阅请求后，需要维护一个订阅表，记录每个Client的Client ID、EventGroup ID、订阅状态（已订阅/待确认/已过期）以及剩余TTL
• 抓包验证闭环：通过Wireshark或vsomeip自带的someip-analyzer工具，必须能清晰看到请求-确认的报文交换序列，并确认Message Type字段为0x06（SubscribeEventGroup）和0x07（SubscribeEventGroupAck）

💻对象配置与验证链路：Client端构造与Server端处理

Client端：构造SubscribeEventGroup请求

以vsomeip开源栈为例，Client端调用application->subscribe(service_id, instance_id, eventgroup_id, major_version, ttl)后，底层会组装SOME/IP头部并发送。关键字段如下：

• Service ID / Instance ID：标识目标服务实例
• EventGroup ID：订阅的事件组标识，必须与Server端发布的事件组一致
• TTL：订阅有效期（秒），0x00000000表示取消订阅，0xFFFFFFFE表示永久订阅
• Client ID：由vsomeip自动分配，用于Server端区分不同订阅者

在交付物integration_debug中，Client端应输出类似日志：[subscribe] Service:0x1234 Instance:0x5678 EventGroup:0x1001 TTL:30，便于与抓包报文关联

Server端：订阅管理逻辑

Server端收到SubscribeEventGroup后，需要执行以下步骤：

1. 校验Service ID、Instance ID、EventGroup ID是否在已注册的发布列表中
2. 检查Client是否已订阅该EventGroup，若已存在则更新TTL；否则新增订阅记录
3. 根据校验结果发送SubscribeEventGroupAck（Return Code: 0x00）或SubscribeEventGroupNack（Return Code: 0x01）
4. 启动TTL定时器，超时后自动移除订阅记录

以下为Server端订阅处理的核心示例片段片段：

void Server::on_subscribe(const std::shared_ptr<vsomeip::message> &request) {
    auto eventgroup_id = request->get_eventgroup_id();
    auto client_id = request->get_client();
    auto ttl = request->get_ttl();
    if (is_eventgroup_registered(eventgroup_id)) {
        // 更新或新增订阅记录
        subscription_table_[client_id][eventgroup_id] = {ttl, std::time(nullptr)};
        send_subscribe_ack(request);
        VSOMEIP_INFO << "Subscribed: Client=" << client_id
                     << " EventGroup=" << eventgroup_id;
    } else {
        send_subscribe_nack(request);
        VSOMEIP_WARNING << "Rejected: EventGroup not registered";
    }
}

这段配置属于“问题代码/原始配置”，核对键名、默认值、取值范围和修改后影响的行为。

这段代码的关键在于subscription_table_的维护：它决定了Server在事件发布时，应该将数据推送给哪些Client。如果订阅表未正确更新，即使Client收到了Ack，后续事件推送也会失败