摘要：，调用函数，重置标志位为，计时器关闭，打印关闭提示日志。设定计时器的异步定时任务，任务体直接调用函数，对函数的返回值进行处理，如果有报错信息一般是服务中止则调用函数关闭插件。
原文链接：醒者呆的博客园，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函数：
