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