BRaft example解析

client.cpp模拟客户端

通过pthread_create创建线程

bthread_start_background启动线程

间隔1s打印一下QPS

    while (!brpc::IsAskedToQuit()) {
        sleep(1);
        LOG_IF(INFO, !FLAGS_log_each_request)
                << "Sending Request to " << FLAGS_group
                << " (" << FLAGS_conf << ')'
                << " at qps=" << g_latency_recorder.qps(1)
                << " latency=" << g_latency_recorder.latency(1);
    }

主要流程在：

sender函数中

1.select_leader

// 得到该组leader
// 返回:
//  0 : 成功
//  1 : 不确定leader是谁
//  -1: 其他情况
int select_leader(const GroupId& group, PeerId* leader);
 
// 更新leader
int update_leader(const GroupId& group, const PeerId& leader);
int update_leader(const GroupId& group, const std::string& leader_str);
 
// 阻塞线程，直到query_leader完成
butil::Status refresh_leader(const GroupId& group, int timeout_ms);
 
// 从路由表中删除该组

————————————————
版权声明：本文为CSDN博主「Aiky哇」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。
原文链接：https://blog.csdn.net/qq_35423190/article/details/108347907

example::CounterResponse response;

得到返回；

------

server.cpp服务端

// Apply this log as a braft::Task

消息封装成braft:Task

// This callback would be iovoked when the task actually excuted or fail
FetchAddClosure

实际触发raft的replicate log
_node->apply(task);

on_apply

apply的一个或多个任务已提交到raft组时（法定个数已收到这些任务，并将其存储在后备存储中）调用