Method CreateClientService

src/plugin/net/src/AFCNetServiceManagerModule.cpp:282–308

}

bool AFCNetServiceManagerModule::CreateClientService(const AFBusAddr& bus_addr, const std::string& ip, uint16_t port)
{
    ARK_APP_TYPE app_type = ARK_APP_TYPE(bus_addr.app_type);
    auto pClient = client_services_.find_value(app_type);
    if (pClient == nullptr)
    {
        pClient = std::make_shared<AFCNetClientService>(GetPluginManager());
        client_services_.insert(app_type, pClient);
    }

    AFEndpoint target_ep;
    target_ep.SetIsV6(false);
    target_ep.SetProtocol(proto_type::tcp);
    target_ep.SetIP(ip);
    target_ep.SetPort(port);
    bool ret = pClient->StartClient(AFHeadLength::SS_HEAD_LENGTH, bus_addr.bus_id, target_ep);
    if (!ret)
    {
        ARK_LOG_ERROR("start net client failed, self_bus_id={} target_url={}", m_pBusModule->GetSelfBusName(),
            target_ep.ToString());
        return ret;
    }

    ARK_LOG_INFO("start net client successful, self_bus_id={} target_url={}", m_pBusModule->GetSelfBusName(),
        target_ep.ToString());
    return true;
}

bool AFCNetServiceManagerModule::CheckConnectedTargetServer(const AFBusAddr& bus_addr)
{