当前位置：首页 > news >正文

VSOMEIP主要流程的时序

news 2025/7/22 10:49:42

请求服务:

client应用：

application_impl::request_service

routing_manager_client::request_service (老版本是routing_manager_proxy)

routing_manager_client::send_request_services

protocol::request_service_command its_command; // 创建订阅cmd

local_uds_client_endpoint_impl::send // 将订阅cmd发送给routingmanagerd

routingmanagerd:

local_uds_server_endpoint_impl::connection::receive_cbk // UnixDomainSocket /tmp/vsomeip-0 收到应用发来的request service命令

routing_manager_stub::on_message

routing_manager_impl::request_service

endpoint_manager_impl::find_or_create_remote_client // 从remote_service_info_中查找远端服务的配置，创建client_endpoint

tcp_client_endpoint_impl::start // 启动线程进行connect操作 (创建并且打开asio socket，设置socket属性，最后async_connect)

udp_client_endpoint_impl::start // 同上

在vsomeip中，每一个服务只占用一个端口（TCP/UDP/BOTH），无论method还是event都在这个端口上通信。

client发给routingmanagerd的cmd中，包含了client的端的clientid

请求事件：

client应用：

application_impl::request_event (service, instance, event, eventgroup事件组集合, 事件类型, reliable) //事件类型event/field/select_event

routing_manager_client::register_event

routing_manager_client::send_register_event

protocol::register_events_command its_command; // 注册event的cmd

local_uds_client_endpoint_impl::send // 将注册event的cmd发送给routingmanagerd

routingmanagerd:

local_uds_server_endpoint_impl::connection::receive_cbk // UnixDomainSocket /tmp/vsomeip-0 收到应用发来的request event命令

routing_manager_stub::on_message

轮询protocol::register_events_command中的每一个register event项目

routing_manager_impl::register_shadow_event

routing_manager_base::register_event //将事件和事件组注册到内部的events_ 和eventgroups_ 中

// routing_manager_base内部events_ 和eventgroups_ 的作用

primitive_types.hpp

...
typedef uint32_t message_t;
typedef uint16_t service_t;
typedef uint16_t method_t;
typedef uint16_t event_t;typedef uint16_t instance_t;
typedef uint16_t eventgroup_t;
...

event.hpp

...
class event {...
private:...// 记录了每个eventgroup有哪些本地client订阅了// 每个event可以属于一个或者多个eventgroupstd::map<eventgroup_t, std::set<client_t> > eventgroups_;...
};
...

eventgroupinfo.hpp

class eventgroupinfo {
...
private:...std::set<std::shared_ptr<event> > events_;    // 记录了该eventgroup中的所有event(event中可以找到订阅该eventgroup的client)...std::map<remote_subscription_id_t,std::shared_ptr<remote_subscription>> subscriptions_;    // 保存对其他域的服务的订阅者的信息remote_subscription_id_t id_;  // 每增加一个对其他域的服务的订阅者(非域内), id_ 加一...
};

routing_manager_base.hpp

std::map<service_t,    			// 服务IDstd::map<instance_t,    // 实例IDstd::map<event_t,   // 事件IDstd::shared_ptr<event> > > > events_;    // 事件所属的组和每个组的订阅客户端std::map<service_t,				// 服务IDstd::map<instance_t,// 实例IDstd::map<eventgroup_t, std::shared_ptr<eventgroupinfo> > > > eventgroups_;  // 事件组中的事件和每个事件的订阅者信息

发布服务：

client应用:

application_impl::offer_service

routing_manager_client::offer_service // 参数中带着clientid以及service的信息

routing_manager_base::offer_service // 判断一下是否可以发布service (例如局域网中已经有别的client发布了相同的service/instance)

routing_manager_client::send_offer_service

protocol::offer_service_command its_offer; // 创建发布服务的cmd

local_uds_client_endpoint_impl::send // 将offer service的cmd发送给routingmanagerd

routingmanagerd:

local_uds_server_endpoint_impl::connection::receive_cbk // UnixDomainSocket /tmp/vsomeip-0 收到应用发来的offer service命令

routing_manager_impl::offer_service

routing_manager_impl::insert_offer_command // 插入OFFER队列 (个人理解用于后期定周期发送)

routing_manager_impl::handle_local_offer_service // 判断是否可以Offer Service (是否存在冲突)，可以offer的情况下插入local_services_中

service_discovery_impl::offer_service // 如果collected_offers_中不存在要发布的service，则添加进去

service_discovery_impl::on_offer_debounce_timer_expired // debounce定时器触发，将collected_offers_的offerentry倒出来后清空

std::shared_ptr<message_impl> its_message(std::make_shared<message_impl>()); // 创建要发送出去的Offer报文

service_discovery_impl::insert_offer_entries //将要offer的所有service entry加入Offer报文

service_discovery_impl::insert_offer_service // 添加单个service entry (service的entry以及option，option中包含了用于通信的endpoint信息)

service_discovery_impl::add_entry_data

service_discovery_impl::send // 发送Offer报文

offerservice有三种冲突的情况下，会offer失败：1. local存在相同服务 2. remote发布过相同服务 3. 当前应用本次offer的服务和之前offer的服务存在冲突

处理收到的Offer报文:

routingmanagerd:

routing_manager_impl::on_message

service_discovery_impl::on_message // 需要是SD报文才会给SD模块处理

service_discovery_impl::process_serviceentry // 判断entry’类型是service还是eventgroup的条件是type <= 2

service_discovery_impl::process_offerservice_serviceentry // service entry条目中type=1 (offer Service)

service_discovery_impl::update_request // 如果目前处于repetition阶段，则停止对该service发送FIND报文(因为已经收到了offer了)

if (_received_via_mcast) { // 如果是从组播地址收到的OFFER报文

auto found_service = subscribed_ .find(_service); // 从 subscribed_ 成员中查找本域中是否有client对该服务中事件组的订阅

更新每一条订阅记录的状态

ST_ACKNOWLEDGED -> ST_RESUBSCRIBING

非ST_ACKNOWLEDGED -> ST_RESUBSCRIBING_NOT_ACKNOWLEDGED

}

routing_manager_impl::add_routing_info // 新增/更新serviceinfo信息到services_remote_和services_两个内部容器

std::shared_ptr<serviceinfo> its_info(find_service(_service, _instance)); // 判断是否收到过该service的offer

if (!its_info) { // 没有是收到过该service的offer

routing_manager_base::create_service_info // 创建新的serviceinfo信息，添加到services_以及services_remote_中

}

endpoint_manager_impl::is_remote_service_known // 判断是否在该service上创建endpoint(reliable/unreliable)

if (_reliable_port != ILLEGAL_PORT && !is_reliable_known) { // service提供了tcp端口，对应的endpoint没有创建

for (const client_t its_client : get_requesters_unlocked(

endpoint_manager_impl::find_or_create_remote_client // 创建和service的tcp连接

its_info->add_client(its_client); // 将请求该service的client添加到上面create_service_info创建的serviceinfo中

}

if (_unreliable_port != ILLEGAL_PORT && !is_unreliable_known) { // service提供了udp端口，对应的endpoint没有创建

// 逻辑同TCP

}

if (!_reliable_address.is_unspecified() || !_unreliable_address.is_unspecified()) {

// 记录每个远端地址上发布的服务信息和收到的Offer报文数量并且打印

}

client应用:

无：

entry条目类型的枚举值： (enumeration_types.hpp)

enum class entry_type_e: uint8_t {FIND_SERVICE = 0x00,OFFER_SERVICE = 0x01,STOP_OFFER_SERVICE = 0x01,REQUEST_SERVICE = 0x2,FIND_EVENT_GROUP = 0x4,PUBLISH_EVENTGROUP = 0x5,STOP_PUBLISH_EVENTGROUP = 0x5,SUBSCRIBE_EVENTGROUP = 0x06,STOP_SUBSCRIBE_EVENTGROUP = 0x06,SUBSCRIBE_EVENTGROUP_ACK = 0x07,STOP_SUBSCRIBE_EVENTGROUP_ACK = 0x07,UNKNOWN = 0xFF
};

service_discovery_impl中保存的事件组订阅情况的类Subscription主要结构如下：

class subscription {
...
private:std::shared_ptr<endpoint> reliable_;std::shared_ptr<endpoint> unreliable_;bool tcp_connection_established_;bool udp_connection_established_;std::map<client_t, subscription_state_e> clients_; // client-> is acknowledged?  // 每个client的订阅状态std::weak_ptr<eventgroupinfo> eg_info_;    // 订阅的事件组信息
};

routing_manager_impl中保存的收到的service信息的类serviceinfo主要结构如下：

class serviceinfo {
...
private:service_t service_;instance_t instance_;major_version_t major_;minor_version_t minor_;std::shared_ptr<endpoint> reliable_;std::shared_ptr<endpoint> unreliable_;std::set<client_t> requesters_;   // 请求过该服务的本地client
};