自学教程：C++ CommandLineRPC函数代码示例

int main(int argc, char* argv[]){    SetupEnvironment();    try    {        if(!AppInitRPC(argc, argv))            return abs(RPC_MISC_ERROR);    }    catch (std::exception& e) {        PrintExceptionContinue(&e, "AppInitRPC()");        return abs(RPC_MISC_ERROR);    } catch (...) {        PrintExceptionContinue(NULL, "AppInitRPC()");        return abs(RPC_MISC_ERROR);    }    int ret = abs(RPC_MISC_ERROR);    try    {        ret = CommandLineRPC(argc, argv);    }    catch (std::exception& e) {        PrintExceptionContinue(&e, "CommandLineRPC()");    } catch (...) {        PrintExceptionContinue(NULL, "CommandLineRPC()");    }    return ret;}

int main(int argc, char* argv[]){    try    {        if(!AppInitRPC(argc, argv))            return 1;    }    catch (std::exception& e) {        PrintExceptionContinue(&e, "AppInitRPC()");    } catch (...) {        PrintExceptionContinue(NULL, "AppInitRPC()");    }    try    {        if(!CommandLineRPC(argc, argv))            return 1;    }    catch (std::exception& e) {        PrintExceptionContinue(&e, "CommandLineRPC()");    } catch (...) {        PrintExceptionContinue(NULL, "CommandLineRPC()");    }    return 0;}

int main(int argc, char* argv[]){    SetupEnvironment();    if (!SetupNetworking()) {        fprintf(stderr, "Error: Initializing networking failed/n");        return EXIT_FAILURE;    }    event_set_log_callback(&libevent_log_cb);    try {        int ret = AppInitRPC(argc, argv);        if (ret != CONTINUE_EXECUTION)            return ret;    }    catch (const std::exception& e) {        PrintExceptionContinue(&e, "AppInitRPC()");        return EXIT_FAILURE;    } catch (...) {        PrintExceptionContinue(nullptr, "AppInitRPC()");        return EXIT_FAILURE;    }    int ret = EXIT_FAILURE;    try {        ret = CommandLineRPC(argc, argv);    }    catch (const std::exception& e) {        PrintExceptionContinue(&e, "CommandLineRPC()");    } catch (...) {        PrintExceptionContinue(nullptr, "CommandLineRPC()");    }    return ret;}

bool AppInit(int argc, char* argv[],boost::thread_group &threadGroup) {	bool fRet = false;	try {		CBaseParams::IntialParams(argc, argv);		SysCfg().InitalConfig();		PrintTestNotSetPara();		if (SysCfg().IsArgCount("-?") || SysCfg().IsArgCount("--help")) {			// First part of help message is specific to Dacrsd / RPC client			std::string strUsage = _("Bitcoin Core Daemon") + " " + _("version") + " " + FormatFullVersion() + "/n/n"					+ _("Usage:") + "/n" + "  Dacrsd [options]                     " + _("Start Bitcoin Core Daemon")					+ "/n" + _("Usage (deprecated, use Dacrs-cli):") + "/n"					+ "  Dacrsd [options] <command> [params]  " + _("Send command to Bitcoin Core") + "/n"					+ "  Dacrsd [options] help                " + _("List commands") + "/n"					+ "  Dacrsd [options] help <command>      " + _("Get help for a command") + "/n";			strUsage += "/n" + HelpMessage(HMM_BITCOIND);			strUsage += "/n" + HelpMessageCli(false);			fprintf(stdout, "%s", strUsage.c_str());			return false;		}		// Command-line RPC		bool fCommandLine = false;		for (int i = 1; i < argc; i++)			if (!IsSwitchChar(argv[i][0]) && !boost::algorithm::istarts_with(argv[i], "Dacrs:"))				fCommandLine = true;		if (fCommandLine) {			int ret = CommandLineRPC(argc, argv);			exit(ret);		}		SysCfg().SoftSetBoolArg("-server", true);		fRet = AppInit2(threadGroup);	} catch (std::exception& e) {		PrintExceptionContinue(&e, "AppInit()");	} catch (...) {		PrintExceptionContinue(NULL, "AppInit()");	}	return fRet;}

////////////////////////////////////////////////////////////////////////////////// Start//bool AppInit(int argc, char* argv[]){    boost::thread_group threadGroup;    bool fRet = false;    try    {        //        // Parameters        //        // If Qt is used, parameters/bitcoin.conf are parsed in qt/bitcoin.cpp's main()        ParseParameters(argc, argv);        if (!boost::filesystem::is_directory(GetDataDir(false)))        {            fprintf(stderr, "Error: Specified directory does not exist/n");            Shutdown();        }        ReadConfigFile(mapArgs, mapMultiArgs);        if (mapArgs.count("-?") || mapArgs.count("--help"))        {            // First part of help message is specific to bitcoind / RPC client            std::string strUsage = _("FlappyCoin version") + " " + FormatFullVersion() + "/n/n" +                _("Usage:") + "/n" +                  "  FlappyCoind [options]                     " + "/n" +                  "  FlappyCoind [options] <command> [params]  " + _("Send command to -server or FlappyCoind") + "/n" +                  "  FlappyCoind [options] help                " + _("List commands") + "/n" +                  "  FlappyCoind [options] help <command>      " + _("Get help for a command") + "/n";            strUsage += "/n" + HelpMessage();            fprintf(stdout, "%s", strUsage.c_str());            return false;        }        // Command-line RPC        for (int i = 1; i < argc; i++)            if (!IsSwitchChar(argv[i][0]) && !boost::algorithm::istarts_with(argv[i], "FlappyCoin:"))                fCommandLine = true;        if (fCommandLine)        {            if (!SelectParamsFromCommandLine()) {                fprintf(stderr, "Error: invalid combination of -regtest and -testnet./n");                return false;            }            int ret = CommandLineRPC(argc, argv);            exit(ret);        }#if !defined(WIN32)        fDaemon = GetBoolArg("-daemon", false);        if (fDaemon)        {            // Daemonize            pid_t pid = fork();            if (pid < 0)            {                fprintf(stderr, "Error: fork() returned %d errno %d/n", pid, errno);                return false;            }            if (pid > 0) // Parent process, pid is child process id            {                CreatePidFile(GetPidFile(), pid);                return true;            }            // Child process falls through to rest of initialization            pid_t sid = setsid();            if (sid < 0)                fprintf(stderr, "Error: setsid() returned %d errno %d/n", sid, errno);        }#endif        fRet = AppInit2(threadGroup);    }    catch (std::exception& e) {        PrintException(&e, "AppInit()");    } catch (...) {        PrintException(NULL, "AppInit()");    }    if (!fRet)    {        threadGroup.interrupt_all();        // threadGroup.join_all(); was left out intentionally here, because we didn't re-test all of        // the startup-failure cases to make sure they don't result in a hang due to some        // thread-blocking-waiting-for-another-thread-during-startup case    } else {        WaitForShutdown(&threadGroup);    }    Shutdown();    return fRet;}

////////////////////////////////////////////////////////////////////////////////// Start//bool AppInit(int argc, char* argv[]){    boost::thread_group threadGroup;    boost::thread* detectShutdownThread = NULL;    bool fRet = false;    try    {        //        // Parameters        //        // If Qt is used, parameters/bonus.conf are parsed in qt/bitcoin.cpp's main()        ParseParameters(argc, argv);        if (!boost::filesystem::is_directory(GetDataDir(false)))        {            fprintf(stderr, "Error: Specified directory does not exist/n");            Shutdown();        }        ReadConfigFile(mapArgs, mapMultiArgs);        if (mapArgs.count("-?") || mapArgs.count("--help"))        {            // First part of help message is specific to bonusd / RPC client            std::string strUsage = _("Bonus version") + " " + FormatFullVersion() + "/n/n" +                _("Usage:") + "/n" +                  "  bonusd [options]                     " + "/n" +                  "  bonusd [options] <command> [params]  " + _("Send command to -server or bonusd") + "/n" +                  "  bonusd [options] help                " + _("List commands") + "/n" +                  "  bonusd [options] help <command>      " + _("Get help for a command") + "/n";            strUsage += "/n" + HelpMessage();            fprintf(stdout, "%s", strUsage.c_str());            return false;        }        // Command-line RPC        for (int i = 1; i < argc; i++)            if (!IsSwitchChar(argv[i][0]) && !boost::algorithm::istarts_with(argv[i], "bonus:"))                fCommandLine = true;        if (fCommandLine)        {            if (!SelectParamsFromCommandLine()) {                fprintf(stderr, "Error: invalid combination of -regtest and -testnet./n");                return false;            }            int ret = CommandLineRPC(argc, argv);            exit(ret);        }#if !defined(WIN32)        fDaemon = GetBoolArg("-daemon", false);        if (fDaemon)        {            // Daemonize            pid_t pid = fork();            if (pid < 0)            {                fprintf(stderr, "Error: fork() returned %d errno %d/n", pid, errno);                return false;            }            if (pid > 0) // Parent process, pid is child process id            {                CreatePidFile(GetPidFile(), pid);                return true;            }            // Child process falls through to rest of initialization            pid_t sid = setsid();            if (sid < 0)                fprintf(stderr, "Error: setsid() returned %d errno %d/n", sid, errno);        }#endif        detectShutdownThread = new boost::thread(boost::bind(&DetectShutdownThread, &threadGroup));        fRet = AppInit2(threadGroup);    }    catch (std::exception& e) {        PrintExceptionContinue(&e, "AppInit()");    } catch (...) {        PrintExceptionContinue(NULL, "AppInit()");    }    if (!fRet) {        if (detectShutdownThread)            detectShutdownThread->interrupt();        threadGroup.interrupt_all();    }    if (detectShutdownThread)    {        detectShutdownThread->join();        delete detectShutdownThread;        detectShutdownThread = NULL;    }    Shutdown();//.........这里部分代码省略.........

////////////////////////////////////////////////////////////////////////////////// Start//bool AppInit(int argc, char* argv[]){    boost::thread_group threadGroup;    boost::thread* detectShutdownThread = NULL;    bool fRet = false;    try    {        //        // Parameters        //        // If Qt is used, parameters/acoin.conf are parsed in qt/bitcoin.cpp's main()        ParseParameters(argc, argv);        if (!boost::filesystem::is_directory(GetDataDir(false)))        {            fprintf(stderr, "Error: Specified data directory /"%s/" does not exist./n", mapArgs["-datadir"].c_str());            return false;        }        try        {            ReadConfigFile(mapArgs, mapMultiArgs);        } catch(std::exception &e) {            fprintf(stderr,"Error reading configuration file: %s/n", e.what());            return false;        }        // Check for -testnet or -regtest parameter (TestNet() calls are only valid after this clause)        if (!SelectParamsFromCommandLine()) {            fprintf(stderr, "Error: Invalid combination of -regtest and -testnet./n");            return false;        }        if (mapArgs.count("-?") || mapArgs.count("--help"))        {            // First part of help message is specific to bitcoind / RPC client            std::string strUsage = _("Acoin Core Daemon") + " " + _("version") + " " + FormatFullVersion() + "/n/n" +                _("Usage:") + "/n" +                  "  acoind [options]                     " + _("Start Acoin Core Daemon") + "/n" +                _("Usage (deprecated, use acoin-cli):") + "/n" +                  "  acoind [options] <command> [params]  " + _("Send command to Acoin Core") + "/n" +                  "  acoind [options] help                " + _("List commands") + "/n" +                  "  acoind [options] help <command>      " + _("Get help for a command") + "/n";            strUsage += "/n" + HelpMessage(HMM_BITCOIND);            strUsage += "/n" + HelpMessageCli(false);            fprintf(stdout, "%s", strUsage.c_str());            return false;        }        // Command-line RPC        bool fCommandLine = false;        for (int i = 1; i < argc; i++)            if (!IsSwitchChar(argv[i][0]) && !boost::algorithm::istarts_with(argv[i], "acoin:"))                fCommandLine = true;        if (fCommandLine)        {            int ret = CommandLineRPC(argc, argv);            exit(ret);        }#ifndef WIN32        fDaemon = GetBoolArg("-daemon", false);        if (fDaemon)        {            fprintf(stdout, "Acoin server starting/n");            // Daemonize            pid_t pid = fork();            if (pid < 0)            {                fprintf(stderr, "Error: fork() returned %d errno %d/n", pid, errno);                return false;            }            if (pid > 0) // Parent process, pid is child process id            {                CreatePidFile(GetPidFile(), pid);                return true;            }            // Child process falls through to rest of initialization            pid_t sid = setsid();            if (sid < 0)                fprintf(stderr, "Error: setsid() returned %d errno %d/n", sid, errno);        }#endif        SoftSetBoolArg("-server", true);        detectShutdownThread = new boost::thread(boost::bind(&DetectShutdownThread, &threadGroup));        fRet = AppInit2(threadGroup);    }    catch (std::exception& e) {        PrintExceptionContinue(&e, "AppInit()");    } catch (...) {        PrintExceptionContinue(NULL, "AppInit()");    }//.........这里部分代码省略.........

//.........这里部分代码省略.........    }    fDebug = GetBoolArg("-debug");#ifndef __WXMSW__    fDaemon = GetBoolArg("-daemon");#else    fDaemon = false;#endif    if (fDaemon)        fServer = true;    else        fServer = GetBoolArg("-server");    /* force fServer when running without GUI */#ifndef GUI    fServer = true;#endif    fPrintToConsole = GetBoolArg("-printtoconsole");    fPrintToDebugger = GetBoolArg("-printtodebugger");    fTestNet = GetBoolArg("-testnet");    fNoListen = GetBoolArg("-nolisten");    fLogTimestamps = GetBoolArg("-logtimestamps");    for (int i = 1; i < argc; i++)        if (!IsSwitchChar(argv[i][0]))            fCommandLine = true;    if (fCommandLine)    {        int ret = CommandLineRPC(argc, argv);        exit(ret);    }#ifndef __WXMSW__    if (fDaemon)    {        // Daemonize        pid_t pid = fork();        if (pid < 0)        {            fprintf(stderr, "Error: fork() returned %d errno %d/n", pid, errno);            return false;        }        if (pid > 0)        {            CreatePidFile(GetPidFile(), pid);            return true;        }        pid_t sid = setsid();        if (sid < 0)            fprintf(stderr, "Error: setsid() returned %d errno %d/n", sid, errno);    }#endif    if (!fDebug && !pszSetDataDir[0])        ShrinkDebugFile();    printf("/n/n/n/n/n/n/n/n/n/n/n/n/n/n/n/n/n/n/n/n");    printf("namecoin version %s/n", FormatFullVersion().c_str());#ifdef GUI    printf("OS version %s/n", ((string)wxGetOsDescription()).c_str());    printf("System default language is %d %s/n", g_locale.GetSystemLanguage(), ((string)g_locale.GetSysName()).c_str());

////////////////////////////////////////////////////////////////////////////////// Start//bool AppInit(int argc, char* argv[],boost::thread_group &threadGroup) {//	boost::thread* detectShutdownThread = NULL;	bool fRet = false;	try {		//		// Parameters		//		// If Qt is used, parameters/sharkfund.conf are parsed in qt/Sharkfund.cpp's main()		CBaseParams::IntialParams(argc, argv);		SysCfg().InitalConfig();		if (SysCfg().IsArgCount("-?") || SysCfg().IsArgCount("--help")) {			// First part of help message is specific to Dacrsd / RPC client			std::string strUsage = _("Sharkfund Core Daemon") + " " + _("version") + " " + FormatFullVersion() + "/n/n"					+ _("Usage:") + "/n" + "  Dacrsd [options]                     " + _("Start Sharkfund Core Daemon")					+ "/n" + _("Usage (deprecated, use Sharkfund-cli):") + "/n"					+ "  sharkfund [options] <command> [params]  " + _("Send command to Sharkfund Core") + "/n"					+ "  sharkfund [options] help                " + _("List commands") + "/n"					+ "  sharkfund [options] help <command>      " + _("Get help for a command") + "/n";			strUsage += "/n" + HelpMessage(HMM_BITCOIND);			strUsage += "/n" + HelpMessageCli(false);			fprintf(stdout, "%s", strUsage.c_str());			return false;		}		// Command-line RPC		bool fCommandLine = false;		for (int i = 1; i < argc; i++)			if (!IsSwitchChar(argv[i][0]) && !boost::algorithm::istarts_with(argv[i], "Sharkfund:"))				fCommandLine = true;		if (fCommandLine) {			int ret = CommandLineRPC(argc, argv);			exit(ret);		}#ifndef WIN32		fDaemon = SysCfg().GetBoolArg("-daemon", false);		if (fDaemon)		{			fprintf(stdout, "Sharkfund server starting/n");			// Daemonize			pid_t pid = fork();			if (pid < 0)			{				fprintf(stderr, "Error: fork() returned %d errno %d/n", pid, errno);				return false;			}			if (pid > 0) // Parent process, pid is child process id			{				CreatePidFile(GetPidFile(), pid);				return true;			}			// Child process falls through to rest of initialization			pid_t sid = setsid();			if (sid < 0)			fprintf(stderr, "Error: setsid() returned %d errno %d/n", sid, errno);		}#endif		SysCfg().SoftSetBoolArg("-server", true);		fRet = AppInit2(threadGroup);	} catch (std::exception& e) {		PrintExceptionContinue(&e, "AppInit()");	} catch (...) {		PrintExceptionContinue(NULL, "AppInit()");	}	return fRet;}

////////////////////////////////////////////////////////////////////////////////// Start//bool AppInit(int argc, char *argv[]){    shutdown_threads.store(false);    thread_group threadGroup(&shutdown_threads);    bool fRet = false;    //    // Parameters    //    gArgs.ParseParameters(argc, argv);    // Check for -testnet or -regtest parameter (Params() calls are only valid after this clause)    try    {        CheckParams(ChainNameFromCommandLine());    }    catch (const std::exception &e)    {        fprintf(stderr, "Error: %s/n", e.what());        return false;    }    try    {        gArgs.ReadConfigFile();    }    catch (const std::exception &e)    {        fprintf(stderr, "Error reading configuration file: %s/n", e.what());        return false;    }    GenerateNetworkTemplates();    // Process help and version before taking care about datadir    if (gArgs.IsArgSet("-?") || gArgs.IsArgSet("-h") || gArgs.IsArgSet("-help") || gArgs.IsArgSet("-version"))    {        std::string strUsage = "Eccoind version " + FormatFullVersion() + "/n";        if (gArgs.IsArgSet("-version"))        {            strUsage += LicenseInfo();        }        else        {            strUsage += "/nUsage:/neccoind [options]                     Start Eccoind/n";            strUsage += "/n" + HelpMessage();        }        fprintf(stdout, "%s", strUsage.c_str());        return false;    }    try    {        if (!fs::is_directory(GetDataDir(false)))        {            fprintf(stderr, "Error: Specified data directory /"%s/" does not exist./n",                gArgs.GetArg("-datadir", "").c_str());            return false;        }        // Command-line RPC        bool fCommandLine = false;        for (int i = 1; i < argc; i++)        {            if (!IsSwitchChar(argv[i][0]) && !boost::algorithm::istarts_with(argv[i], "ECC:"))            {                fCommandLine = true;            }        }        if (fCommandLine)        {            int ret = CommandLineRPC(argc, argv);            exit(ret);        }#ifndef WIN32        fDaemon = gArgs.GetBoolArg("-daemon", false);        if (fDaemon)        {            fprintf(stdout, "Eccoind server starting/n");            // Daemonize            pid_t pid = fork();            if (pid < 0)            {                fprintf(stderr, "Error: fork() returned %d errno %d/n", pid, errno);                return false;            }            if (pid > 0) // Parent process, pid is child process id            {                return true;            }            // Child process falls through to rest of initialization            pid_t sid = setsid();//.........这里部分代码省略.........

bool AppInit2(int argc, char* argv[]){#ifdef _MSC_VER    // Turn off microsoft heap dump noise    _CrtSetReportMode(_CRT_WARN, _CRTDBG_MODE_FILE);    _CrtSetReportFile(_CRT_WARN, CreateFileA("NUL", GENERIC_WRITE, 0, NULL, OPEN_EXISTING, 0, 0));#endif#if _MSC_VER >= 1400    // Disable confusing "helpful" text message on abort, ctrl-c    _set_abort_behavior(0, _WRITE_ABORT_MSG | _CALL_REPORTFAULT);#endif#ifndef __WXMSW__    umask(077);#endif    //    // Parameters    //    ParseParameters(argc, argv);    if (mapArgs.count("-datadir"))        strlcpy(pszSetDataDir, mapArgs["-datadir"].c_str(), sizeof(pszSetDataDir));    ReadConfigFile(mapArgs, mapMultiArgs); // Must be done after processing datadir    if (mapArgs.count("-?") || mapArgs.count("--help"))    {        string strUsage = string() +          _("Usage:") + "/t/t/t/t/t/t/t/t/t/t/n" +            "  bitcoin [options]                   /t  " + "/n" +            "  bitcoin [options] <command> [params]/t  " + _("Send command to -server or bitcoind/n") +            "  bitcoin [options] <command> -?      /t/t  " + _("Get help for a command/n") +            "  bitcoin help                        /t/t/t  " + _("List commands/n") +          _("Options:/n") +            "  -conf=<file>    /t  " + _("Specify configuration file (default: bitcoin.conf)/n") +            "  -gen            /t  " + _("Generate coins/n") +            "  -gen=0          /t  " + _("Don't generate coins/n") +            "  -min            /t  " + _("Start minimized/n") +            "  -datadir=<dir>  /t  " + _("Specify data directory/n") +            "  -proxy=<ip:port>/t  " + _("Connect through socks4 proxy/n") +            "  -addnode=<ip>   /t  " + _("Add a node to connect to/n") +            "  -connect=<ip>   /t  " + _("Connect only to the specified node/n") +            "  -server         /t  " + _("Accept command line and JSON-RPC commands/n") +            "  -daemon         /t  " + _("Run in the background as a daemon and accept commands/n") +            "  -?              /t  " + _("This help message/n");#if defined(__WXMSW__) && defined(GUI)        // Tabs make the columns line up in the message box        wxMessageBox(strUsage, "Bitcoin", wxOK);#else        // Remove tabs        strUsage.erase(std::remove(strUsage.begin(), strUsage.end(), '/t'), strUsage.end());        fprintf(stderr, "%s", strUsage.c_str());#endif        return false;    }    if (mapArgs.count("-debug"))        fDebug = true;    if (mapArgs.count("-printtodebugger"))        fPrintToDebugger = true;    if (fCommandLine)    {        int ret = CommandLineRPC(argc, argv);        exit(ret);    }    if (!fDebug && !pszSetDataDir[0])        ShrinkDebugFile();    printf("/n/n/n/n/n/n/n/n/n/n/n/n/n/n/n/n/n/n/n/n");    printf("BitcoinTEST version %d.%d.%d%s beta/n", VERSION/10000, (VERSION/100)%100, VERSION%100, pszSubVer);#ifdef GUI    printf("OS version %s/n", ((string)wxGetOsDescription()).c_str());    printf("System default language is %d %s/n", g_locale.GetSystemLanguage(), ((string)g_locale.GetSysName()).c_str());    printf("Language file %s (%s)/n", (string("locale/") + (string)g_locale.GetCanonicalName() + "/LC_MESSAGES/bitcoin.mo").c_str(), ((string)g_locale.GetLocale()).c_str());#endif    printf("Default data directory %s/n", GetDefaultDataDir().c_str());    if (mapArgs.count("-loadblockindextest"))    {        CTxDB txdb("r");        txdb.LoadBlockIndex();        PrintBlockTree();        return false;    }    //    // Limit to single instance per user    // Required to protect the database files if we're going to keep deleting log.*    //#if defined(__WXMSW__) && defined(GUI)    // todo: wxSingleInstanceChecker wasn't working on Linux, never deleted its lock file    //  maybe should go by whether successfully bind port 18333 instead    wxString strMutexName = wxString("bitcoin_running.") + getenv("HOMEPATH");    for (int i = 0; i < strMutexName.size(); i++)        if (!isalnum(strMutexName[i]))            strMutexName[i] = '.';    wxSingleInstanceChecker* psingleinstancechecker = new wxSingleInstanceChecker(strMutexName);//.........这里部分代码省略.........