EOS代码架构分析(二)通信机制（eos技术）

EOS通信机制分析

客户端和服务器端的通信采用RESTful软件架构风格，服务器端的每个资源对应一个唯一的URL地址，客户端将URL地址封装成http请求发送到服务器端，请求对应的资源或者执行相应操作。

客户端发送消息流程

以转账为例，说明EOS消息处理流程。通过cleos客户端发起转账命令，在main函数中，解析transfer命令，通过create_transfer函数将交易发送者、交易接收者、token数量等信息封装成mutable_variant_object对象，然后调用send_action函数，将交易信息发送到服务器端打包进区块链。

# ./cleos transfer sender recipient amount memo

programs/cleos/main.cpp

main()

{send_actions({create_transfer(sender, recipient, amount, memo)});}

void send_actions {? auto result = push_actions( move(actions), extra_kcpu, compression);

}

fc::variant push_actions {

signed_transaction trx;

trx.actions = std::forward<decltype(actions)>(actions);

return push_transaction(trx, extra_kcpu, compression);

}

fc::variant push_transaction{

trx.set_reference_block(ref_block_id);

// 发送 ”/V1/chain/push_transaction” URL地址到服务器端

if (!tx_dont_broadcast) {

return call(push_txn_func, packed_transaction(trx, compression)); }

}

fc::variant call{

try { return eosio::client::http::do_http_call( url, path, fc::variant(v) ); }

}

fc::variant do_http_call {// 将请求的URL封装成http包

request_stream << "POST " << path_prefix + path << " HTTP/1.0\r\n";

request_stream << "Host: " << server << "\r\n";

request_stream << "content-length: " << postjson.size() << "\r\n";

request_stream << "Accept: /\r\n";

request_stream << "Connection: close\r\n\r\n";

request_stream << postjson;

// 和服务器建立连接

do_connect(socket, server, port);

// 发送http报文，并获取返回结果

re = do_txrx(socket, request, status_code);}

服务器接收消息流程

nodeos服务器先通过http_plugin插件接收客户端发过来的http请求报文，然后解析出请求的URL地址和数据信息，然后调用对应的回调函数处理，并将结果返回给cleos客户端。

# ./nodeos -e -p eosio

HTTP消息处理流程

在nodeos的main函数中启动http_plugin插件，注册处理http请求的回调函数（handle_http_request），然后监听socket通信端口，等待建立客户端远程连接。

void http_plugin::plugin_startup() {

// 注册http请求处理函数

my->create_server_for_endpoint(*my->https_listen_endpoint, my->https_server);

// 监听socket通信端口

my->https_server.listen(*my->https_listen_endpoint);

// 等待建立客户端远程连接

my->https_server.start_accept();

}

void create_server_for_endpoint{

ws.set_http_handler(& {

handle_http_request<T>(ws.get_con_from_hdl(hdl));

});

}

http请求处理函数从http报文中解析出URL地址（resource）、消息内容（body），然后在url_handlers集合中查找URL对应的回调函数，最后通过handler_itr->second调用处理函数。

void handle_http_request {

auto body = con->get_request_body();

auto resource = con->get_uri()->get_resource();

auto handler_itr = url_handlers.find(resource);

if(handler_itr != url_handlers.end()) {

handler_itr->second(resource, body, con {

con->set_body(body);

con->set_status(websocketpp::http::status_code::value(code));

});}

注册URL处理函数

url_handlers是一个URL和处理函数的键值对map集合，由class http_plugin_impl管理，其它插件模块通过add_api函数注册URL回调函数。

生产区块流程

客户端发送 ”/V1/chain/push_transaction” URL地址和交易信息到服务器端，然后服务器调用URL对应的回调函数push_transaction将交易信息写入到一个待打包的区块（_pending_block）中。

producer_plugin插件启动后，通过schedule_production_loop函数循环生产区块。EOS采用DPoS（委托股权证明）算法，先由EOS持有者（股东）选出21个区块生产者（董事会成员），区块通过这21个生产者轮流产生，每3秒出一个区块，类似操作系统的时间片概念，每个时间片对应一个唯一的生产者，当时间片到来时才能打包区块，之后执行DPOS算法，详见之前的DPOS共识算法理解，

至此，一次完整的区块处理流程就完成了，后面不断重复打包过程，随着时间推移，形成一个不可逆转的区块链。

#热议区块链#