資訊專欄INFORMATION COLUMN
摘要：，調(diào)用函數(shù)，重置標(biāo)志位為，計(jì)時(shí)器關(guān)閉，打印關(guān)閉提示日志。設(shè)定計(jì)時(shí)器的異步定時(shí)任務(wù)，任務(wù)體直接調(diào)用函數(shù)，對函數(shù)的返回值進(jìn)行處理，如果有報(bào)錯(cuò)信息一般是服務(wù)中止則調(diào)用函數(shù)關(guān)閉插件。
原文鏈接：醒者呆的博客園，https://www.cnblogs.com/Evswa...
本文內(nèi)容本屬于《【精解】EOS TPS 多維實(shí)測》的內(nèi)容，但由于在編寫時(shí)篇幅過長，所以我決定將這一部分多帶帶成文撰寫，以便于理解。txn_test_gen_plugin 插件關(guān)鍵字：eos, txn_test_gen_plugin, signed_transaction, ordered_action_result, C++, EOS插件
這個(gè)插件是官方開發(fā)用來測試塊打包交易量的，這種方式由于是直接系統(tǒng)內(nèi)部調(diào)用來模擬transaction，沒有中間通訊的損耗，因此效率是非常高的，官方稱通過這個(gè)插件測試到了8000的tps結(jié)果，而就我的測試結(jié)果來講，沒有這么恐怖，但也能到2000了，熟不知，其他的測試手段，例如cleos，eosjs可能只有百級的量。下面，我們一同來研究一下這個(gè)插件是如何實(shí)現(xiàn)以上功能的，過程中，我們也會(huì)思考EOS插件的架構(gòu)體系，以及實(shí)現(xiàn)方法。通過本文的學(xué)習(xí)，如果有好的想法，我們也可以自己開發(fā)一個(gè)功能強(qiáng)大的插件pr給eos，為EOS社區(qū)做出我們自己的貢獻(xiàn)。
關(guān)于txn_test_gen_plugin插件的使用，非常易于上手，本文不做分析，這方面可以直接參考官方文檔。插件的整體架構(gòu)
插件代碼整體結(jié)構(gòu)中，我們上面介紹的核心功能的實(shí)現(xiàn)函數(shù)都是包含在一個(gè)結(jié)構(gòu)體struct txn_test_gen_plugin_impl中。剩余的其他代碼都是對插件本身的通訊進(jìn)行描述，包括如何調(diào)用，如何響應(yīng)等，以及整個(gè)插件的生命周期的控制：
set_program_options，設(shè)置參數(shù)的階段，是最開始的階段，內(nèi)容只設(shè)置了txn-reference-block-lag的值，默認(rèn)是0，-1代表最新頭區(qū)塊。
plugin_initialize，這一時(shí)期就把包含核心功能的結(jié)構(gòu)體txn_test_gen_plugin_impl加載到程序運(yùn)行時(shí)內(nèi)存中了，同時(shí)初始化標(biāo)志位txn_reference_block_lag為txn-reference-block-lag的值。
plugin_startup，我們通過基礎(chǔ)插件http_plugin的支持獲得了http接口的能力，這一時(shí)期，就暴露出來本插件的對外接口。
plugin_shutdown，調(diào)用stop_generation函數(shù)，重置標(biāo)志位running為false，計(jì)時(shí)器關(guān)閉，打印關(guān)閉提示日志。
下面是對外暴露的三個(gè)接口之一的stop_generation函數(shù)的源碼：
void stop_generation() {
if(!running)
throw fc::exception(fc::invalid_operation_exception_code);
timer.cancel();
running = false;
ilog("Stopping transaction generation test");
}
接下來，我們主要集中精力在結(jié)構(gòu)體txn_test_gen_plugin_impl上，研究路線是以剩余兩個(gè)接口分別為入口進(jìn)行逐一分析。
create_test_accounts 接口關(guān)于這個(gè)接口，調(diào)用方法是
curl --data-binary "["eosio", "5KQwrPbwdL6PhXujxW37FSSQZ1JiwsST4cqQzDeyXtP79zkvFD3"]" http://localhost:8888/v1/txn_test_gen/create_test_accounts
傳入的參數(shù)是eosio以及其私鑰。我們進(jìn)入到函數(shù)create_test_accounts中去分析源碼。
準(zhǔn)備知識(shí)首先，整個(gè)函數(shù)涉及到的所有transaction都是打包存入到一個(gè)vector集合std::vector中去。
trxs是一個(gè)事務(wù)集，它包含很多的trx，而其中每一個(gè)trx包含一個(gè)actions集合vector一、準(zhǔn)備賬戶
trxs的第一個(gè)trx，內(nèi)容為賬戶創(chuàng)建：
定義3個(gè)賬戶：txn.test.a，txn.test.b, txn.test.t
輔助功能：controller& cc = app().get_plugin
通過fc::crypto::private_key::regenerate函數(shù)分別生成他們的私鑰，要傳入生成秘鑰的seed。
通過私鑰直接調(diào)用get_public_key()即可獲得公鑰
設(shè)置每個(gè)賬戶的owner和active權(quán)限對應(yīng)的公鑰，一般來講他們是相同的
賬戶的創(chuàng)建者均為我們外部調(diào)用create_test_accounts接口時(shí)傳入的賬戶eosio，注意：eosio的私鑰是通過字符串傳入的，要通過fc::crypto::private_key轉(zhuǎn)換成私鑰對象
將每一個(gè)賬戶的創(chuàng)建組裝好成為一個(gè)action，存入trx的actions集合中去。
trx的actions成員已經(jīng)設(shè)置完畢，完成剩余trx的組裝工作，包括
expiration，通過cc獲得當(dāng)前頭區(qū)塊的時(shí)間，加上延遲時(shí)間，這里是30s，fc::seconds(30)
reference_block，值為通過cc獲取當(dāng)前的頭區(qū)塊，意思為本transaction的引用區(qū)塊，所有的信息是引用的這個(gè)區(qū)塊為頭區(qū)塊的環(huán)境
sign，簽名，使用的是創(chuàng)建者eosio的私鑰對象，上面我們已經(jīng)準(zhǔn)備好了，簽名的數(shù)據(jù)是data的摘要
當(dāng)前trx的actions中的元素的data并不是如文首的transaction中的data的加密串的結(jié)構(gòu)，而是明文的，這里的加密是數(shù)字摘要技術(shù)，感興趣的朋友可以去《應(yīng)用密碼學(xué)初探》進(jìn)行了解。
摘要的源碼函數(shù)是：sig_digest(chain_id, context_free_data)，其中參數(shù)使用到了chain_id，而context_free_data就是上面提到的明文data內(nèi)容，所以它是要與鏈id一起做數(shù)字摘要的（這一點(diǎn)我在使用eosjs嘗試自己做摘要的時(shí)候并未想到）
這一部分的源碼展示如下：
name newaccountA("txn.test.a");
name newaccountB("txn.test.b");
name newaccountC("txn.test.t");
name creator(init_name);
abi_def currency_abi_def = fc::json::from_string(eosio_token_abi).as();
controller& cc = app().get_plugin().chain();
auto chainid = app().get_plugin().get_chain_id();
fc::crypto::private_key txn_test_receiver_A_priv_key = fc::crypto::private_key::regenerate(fc::sha256(std::string(64, "a")));
fc::crypto::private_key txn_test_receiver_B_priv_key = fc::crypto::private_key::regenerate(fc::sha256(std::string(64, "b")));
fc::crypto::private_key txn_test_receiver_C_priv_key = fc::crypto::private_key::regenerate(fc::sha256(std::string(64, "c")));
fc::crypto::public_key txn_text_receiver_A_pub_key = txn_test_receiver_A_priv_key.get_public_key();
fc::crypto::public_key txn_text_receiver_B_pub_key = txn_test_receiver_B_priv_key.get_public_key();
fc::crypto::public_key txn_text_receiver_C_pub_key = txn_test_receiver_C_priv_key.get_public_key();
fc::crypto::private_key creator_priv_key = fc::crypto::private_key(init_priv_key);
//create some test accounts
{
signed_transaction trx;
//create "A" account
{
auto owner_auth = eosio::chain::authority{1, {{txn_text_receiver_A_pub_key, 1}}, {}};
auto active_auth = eosio::chain::authority{1, {{txn_text_receiver_A_pub_key, 1}}, {}};
trx.actions.emplace_back(vector{{creator,"active"}}, newaccount{creator, newaccountA, owner_auth, active_auth});
}
//create "B" account
{
auto owner_auth = eosio::chain::authority{1, {{txn_text_receiver_B_pub_key, 1}}, {}};
auto active_auth = eosio::chain::authority{1, {{txn_text_receiver_B_pub_key, 1}}, {}};
trx.actions.emplace_back(vector{{creator,"active"}}, newaccount{creator, newaccountB, owner_auth, active_auth});
}
//create "txn.test.t" account
{
auto owner_auth = eosio::chain::authority{1, {{txn_text_receiver_C_pub_key, 1}}, {}};
auto active_auth = eosio::chain::authority{1, {{txn_text_receiver_C_pub_key, 1}}, {}};
trx.actions.emplace_back(vector{{creator,"active"}}, newaccount{creator, newaccountC, owner_auth, active_auth});
}
trx.expiration = cc.head_block_time() + fc::seconds(30);
trx.set_reference_block(cc.head_block_id());
trx.sign(creator_priv_key, chainid);
trxs.emplace_back(std::move(trx));
}
二、token相關(guān)
trxs的第二個(gè)trx，內(nèi)容為token創(chuàng)建和issue，為賬戶轉(zhuǎn)賬為之后的測試做準(zhǔn)備
為賬戶txn.test.t設(shè)置eosio.token合約，之前在操作cleos set contract的時(shí)候可以通過打印結(jié)果發(fā)現(xiàn)，是有setcode和setabi兩個(gè)步驟的。
setcode handler:
設(shè)置handler的賬戶為txn.test.t
將wasm設(shè)置為handler的code，wasm是通過eosio.token合約的eosio_token_wast文件獲取的，vector
將handler加上相關(guān)權(quán)限組裝成action裝入trx的actions集合中。
setabi handler:
設(shè)置handler的賬戶為txn.test.t
設(shè)置handler的abi，將文件eosio_token_abi(json格式的)轉(zhuǎn)成json轉(zhuǎn)儲(chǔ)為abi_def結(jié)構(gòu)，然后通過fc::raw::pack操作將結(jié)果賦值給abi
將handler加上相關(guān)權(quán)限組裝成action裝入trx的actions集合中。
使用賬戶txn.test.t創(chuàng)建token，標(biāo)志位CUR，總發(fā)行量十億，裝成action裝入trx的actions集合中。
issue CUR 給txn.test.t 600枚CUR，裝成action裝入trx的actions集合中。
從txn.test.t轉(zhuǎn)賬給txn.test.a 200枚CUR，裝成action裝入trx的actions集合中。
從txn.test.t轉(zhuǎn)賬給txn.test.b 200枚CUR，裝成action裝入trx的actions集合中。
trx的actions成員已經(jīng)設(shè)置完畢，完成剩余trx的組裝工作（同上），這里只介紹不同的部分
max_net_usage_words，指定了網(wǎng)絡(luò)資源的最大使用限制為5000個(gè)詞。
這一部分的源碼展示如下：
//set txn.test.t contract to eosio.token & initialize it
{
signed_transaction trx;
vector wasm = wast_to_wasm(std::string(eosio_token_wast));
setcode handler;
handler.account = newaccountC;
handler.code.assign(wasm.begin(), wasm.end());
trx.actions.emplace_back( vector{{newaccountC,"active"}}, handler);
{
setabi handler;
handler.account = newaccountC;
handler.abi = fc::raw::pack(json::from_string(eosio_token_abi).as());
trx.actions.emplace_back( vector{{newaccountC,"active"}}, handler);
}
{
action act;
act.account = N(txn.test.t);
act.name = N(create);
act.authorization = vector{{newaccountC,config::active_name}};
act.data = eosio_token_serializer.variant_to_binary("create", fc::json::from_string("{"issuer":"txn.test.t","maximum_supply":"1000000000.0000 CUR"}}"));
trx.actions.push_back(act);
}
{
action act;
act.account = N(txn.test.t);
act.name = N(issue);
act.authorization = vector{{newaccountC,config::active_name}};
act.data = eosio_token_serializer.variant_to_binary("issue", fc::json::from_string("{"to":"txn.test.t","quantity":"600.0000 CUR","memo":""}"));
trx.actions.push_back(act);
}
{
action act;
act.account = N(txn.test.t);
act.name = N(transfer);
act.authorization = vector{{newaccountC,config::active_name}};
act.data = eosio_token_serializer.variant_to_binary("transfer", fc::json::from_string("{"from":"txn.test.t","to":"txn.test.a","quantity":"200.0000 CUR","memo":""}"));
trx.actions.push_back(act);
}
{
action act;
act.account = N(txn.test.t);
act.name = N(transfer);
act.authorization = vector{{newaccountC,config::active_name}};
act.data = eosio_token_serializer.variant_to_binary("transfer", fc::json::from_string("{"from":"txn.test.t","to":"txn.test.b","quantity":"200.0000 CUR","memo":""}"));
trx.actions.push_back(act);
}
trx.expiration = cc.head_block_time() + fc::seconds(30);
trx.set_reference_block(cc.head_block_id());
trx.max_net_usage_words = 5000;
trx.sign(txn_test_receiver_C_priv_key, chainid);
trxs.emplace_back(std::move(trx));
}
發(fā)起請求
目前trxs集合已經(jīng)包含了兩個(gè)trx元素，其中每個(gè)trx包含了多個(gè)action。下面要將trxs推送到鏈上執(zhí)行
push_transactions函數(shù)，遍歷trxs元素，每個(gè)trx多帶帶發(fā)送push_next_transaction
push_next_transaction函數(shù)，首先將trx取出通過packed_transaction函數(shù)進(jìn)行組裝成post的結(jié)構(gòu)
packed_transaction函數(shù)，通過set_transaction函數(shù)對trx進(jìn)行摘撿，使用pack_transaction函數(shù)進(jìn)行組裝
pack_transaction函數(shù)，就是調(diào)用了一下上面提過的fc::raw::pack操作，然后通過accept_transaction函數(shù)向鏈發(fā)起請求
accept_transaction函數(shù)，是chain_plugin的一個(gè)函數(shù)，它內(nèi)部調(diào)用了incoming_transaction_async_method異步發(fā)起交易請求。
這部分代碼比較雜，分為幾個(gè)部分：
push_transactions函數(shù)：
