第六步：网络初始化

以下内容为系统启动过程中，每一步骤的详细分析。

第6步，网络初始化（`src/init.cpp::AppInitMain()`）

生成智能指针对象 g_connman，类型为 CConnman。

g_connman = std::unique_ptr<CConnman>(new CConnman(GetRand(std::numeric_limits<uint64_t>::max()), GetRand(std::numeric_limits<uint64_t>::max())));
CConnman& connman = *g_connman;

生成智能指针对象 peerLogic，类型为 PeerLogicValidation。
```
peerLogic.reset(new PeerLogicValidation(&connman, scheduler, gArgs.GetBoolArg("-enablebip61", DEFAULT_ENABLE_BIP61)));
```
PeerLogicValidation 继承了 CValidationInterface、NetEventsInterface 两个类。实现 CValidationInterface 这个类可以订阅验证过程中产生的事件。实现 NetEventsInterface 这个类可以处理消息网络消息。

注册各种验证处理器，即信号处理器，在发送信号时会调用这些处理器。

RegisterValidationInterface(peerLogic.get());

方法具体实现如下：

void RegisterValidationInterface(CValidationInterface* pwalletIn) {
    g_signals.m_internals->UpdatedBlockTip.connect(boost::bind(&CValidationInterface::UpdatedBlockTip, pwalletIn, _1, _2, _3));
    g_signals.m_internals->TransactionAddedToMempool.connect(boost::bind(&CValidationInterface::TransactionAddedToMempool, pwalletIn, _1));
    g_signals.m_internals->BlockConnected.connect(boost::bind(&CValidationInterface::BlockConnected, pwalletIn, _1, _2, _3));
    g_signals.m_internals->BlockDisconnected.connect(boost::bind(&CValidationInterface::BlockDisconnected, pwalletIn, _1));
    g_signals.m_internals->TransactionRemovedFromMempool.connect(boost::bind(&CValidationInterface::TransactionRemovedFromMempool, pwalletIn, _1));
    g_signals.m_internals->ChainStateFlushed.connect(boost::bind(&CValidationInterface::ChainStateFlushed, pwalletIn, _1));
    g_signals.m_internals->Broadcast.connect(boost::bind(&CValidationInterface::ResendWalletTransactions, pwalletIn, _1, _2));
    g_signals.m_internals->BlockChecked.connect(boost::bind(&CValidationInterface::BlockChecked, pwalletIn, _1, _2));
    g_signals.m_internals->NewPoWValidBlock.connect(boost::bind(&CValidationInterface::NewPoWValidBlock, pwalletIn, _1, _2));
}

静态变量 g_signals 在程序启动前生成，m_internals 在第4a 步应用程序初始化过程中生成。

根据命令行参数 -uacomment，处理追加到用户代理的字符串。

std::vector<std::string> uacomments;
for (const std::string& cmt : gArgs.GetArgs("-uacomment")) {
    if (cmt != SanitizeString(cmt, SAFE_CHARS_UA_COMMENT))
        return InitError(strprintf(_("User Agent comment (%s) contains unsafe characters."), cmt));
    uacomments.push_back(cmt);
}

构造并检查版本字符串长度是否大于 version 消息中版本的最大长度。

strSubVersion = FormatSubVersion(CLIENT_NAME, CLIENT_VERSION, uacomments);
if (strSubVersion.size() > MAX_SUBVERSION_LENGTH) {
    return InitError(strprintf(_("Total length of network version string (%i) exceeds maximum length (%i). Reduce the number or size of uacomments."),
        strSubVersion.size(), MAX_SUBVERSION_LENGTH));
}

如果指定了 onlynet 参数，则设置可以对接进行连接的类型，比如：ipv4、ipv6、onion。

if (gArgs.IsArgSet("-onlynet")) {
    std::set<enum Network> nets;
    for (const std::string& snet : gArgs.GetArgs("-onlynet")) {
        enum Network net = ParseNetwork(snet);
        if (net == NET_UNROUTABLE)
            return InitError(strprintf(_("Unknown network specified in -onlynet: '%s'"), snet));
        nets.insert(net);
    }
    for (int n = 0; n < NET_MAX; n++) {
        enum Network net = (enum Network)n;
        if (!nets.count(net))
            SetLimited(net);
    }
}

上面的代码首先把 -onlynet 参数指定的只允许对外连接的网络类型加入集合中，然后进行 for 遍历，如果当前的类型不在允许的集合中，则调用 SetLimited 方法，设置这些类型为受限的。

获取是否允许进行 DNS 查找，是否进行代理随机

fNameLookup = gArgs.GetBoolArg("-dns", DEFAULT_NAME_LOOKUP);
bool proxyRandomize = gArgs.GetBoolArg("-proxyrandomize", DEFAULT_PROXYRANDOMIZE);

两者默认都为真。

处理网络代理。

如果指定了 -proxy，且不等于 0，即指定了代理地址，进行下面的处理：

调用 Lookup 方法，根据指定的代理，通过 DNS查找，发现代理服务器的地址。
生成 proxyType 对象。
设置 IPv4、IPv6、Tor 网络的代理。
设置命名（域名）代理。
设置不限制连接到 Tor 网络。

具体代码如下：

std::string proxyArg = gArgs.GetArg("-proxy", "");
SetLimited(NET_ONION);
if (proxyArg != "" && proxyArg != "0") {
    CService proxyAddr;
    if (!Lookup(proxyArg.c_str(), proxyAddr, 9050, fNameLookup)) {
        return InitError(strprintf(_("Invalid -proxy address or hostname: '%s'"), proxyArg));
    }

    proxyType addrProxy = proxyType(proxyAddr, proxyRandomize);
    if (!addrProxy.IsValid())
        return InitError(strprintf(_("Invalid -proxy address or hostname: '%s'"), proxyArg));

    SetProxy(NET_IPV4, addrProxy);
    SetProxy(NET_IPV6, addrProxy);
    SetProxy(NET_ONION, addrProxy);
    SetNameProxy(addrProxy);
    SetLimited(NET_ONION, false); // by default, -proxy sets onion as reachable, unless -noonion later
}

处理洋葱网络。如果指定了 onion 参数，则处理洋葱网络的相关设置。

如果指定了 -onion，且不等于空字符串，即指定了洋葱代理地址，进行下面的处理：

如果参数等于 0，设置洋葱网络受限，即不可达。否则，进行下面的处理。
调用 Lookup 方法，根据指定的代理，通过 DNS查找，发现代理服务器的地址。
生成 proxyType 对象。
设置 Tor 网络的代理。
设置不限制连接到 Tor 网络。

具体代码如下：

std::string onionArg = gArgs.GetArg("-onion", "");
if (onionArg != "") {
    if (onionArg == "0") { // Handle -noonion/-onion=0
        SetLimited(NET_ONION); // set onions as unreachable
    } else {
        CService onionProxy;
        if (!Lookup(onionArg.c_str(), onionProxy, 9050, fNameLookup)) {
            return InitError(strprintf(_("Invalid -onion address or hostname: '%s'"), onionArg));
        }
        proxyType addrOnion = proxyType(onionProxy, proxyRandomize);
        if (!addrOnion.IsValid())
            return InitError(strprintf(_("Invalid -onion address or hostname: '%s'"), onionArg));
        SetProxy(NET_ONION, addrOnion);
        SetLimited(NET_ONION, false);
    }
}

处理通过 -externalip 参数设置的外部 IP地址。

获取并遍历所有指定的外部地址，进行如下处理：调用 Lookup 方法进行DNS 查找。如果成功则调用 AddLocal 方法，保存新的地址。否则，抛出初始化错误。

   for (const std::string& strAddr : gArgs.GetArgs("-externalip")) {
       CService addrLocal;
       if (Lookup(strAddr.c_str(), addrLocal, GetListenPort(), fNameLookup) && addrLocal.IsValid())
           AddLocal(addrLocal, LOCAL_MANUAL);
       else
           return InitError(ResolveErrMsg("externalip", strAddr));
   }

如果设置了 maxuploadtarget 参数，则设置最大出站限制。

   if (gArgs.IsArgSet("-maxuploadtarget")) {
       nMaxOutboundLimit = gArgs.GetArg("-maxuploadtarget", DEFAULT_MAX_UPLOAD_TARGET)*1024*1024;
   }

Previous第五步：钱包完整性验证 Next第七步：加载区块链

Last updated 7 years ago

hashtag第6步，网络初始化（src/init.cpp::AppInitMain()）

第6步，网络初始化（`src/init.cpp::AppInitMain()`）