Ceph Monitor Paxos算法怎么用

共计 4052 个字符，预计需要花费 11 分钟才能阅读完成。

丸趣 TV 小编给大家分享一下 Ceph Monitor Paxos 算法怎么用，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！

一些相关变量

last_pn：最新的 proposal number；

accepted_pn：最新的接受的 proposal number；

accepted_pn_from：peon 接受最新的 proposal number 的 leader 的 last_committed(也就是说只接受比 accepted_pn_from 大的 pn 值)

first_committed：

last_committed：leader 和 peon 都存在的，接受最新 value 的版本号；

peer_first_committed：记录集群成员中第一次 commit 的版本号；

peer_last_committed：记录集群成员中最新 commit 的版本号；

一些函数解析

Paxos::init()

      从 MonitorDB 中读取 last_pn/accepted_pn/last_committed/first_committed 的值；

leader

     Paxos::collect()

     |__state = STATE_RECOVERING           设置当前状态为 RECOVERING

     |__初始化相关变量 uncommitted_v/uncommitted_pn/uncommitted_value/peer_first_committed/peer_last_committed

     |__检查是否存在 uncommitted value 存在，通过查看 MonitorDB 中是否存在 last_committed+ 1 的值存在，若存在则初始化 uncommitted_pn/uncommitted_v/uncommitted_value

     |__Paxos::get_new_proposal_number()                     生成一个单调递增的且全局唯一的 last_pn 值

     |__初始化 accepted_pn=last_pn/accepted_pn_from=last_committed

     |__遍历 mon- get_quorum()，创建 MMonPaxos 消息且设置消息的 last_committed/first_committed/pn(accepted_pn)

     |__向 mon- get_quorum() 中所有 monitor 节点发送 MMonPaxos 消息

     Paxos::handle_last()

     |__更新 peer_first_committed/peer_last_committed 数组

     |__对于 peon.first_committed leader.last_committed+1，则 leader 调用 mon- bootstrap()

     |__Paxos::store_state()                     保存 MMonPaxos 消息中 value 值的 version_t leader.last_committed version_t =peon.last_committed 到 leader 的 MonitorDB 中

     |__遍历 peer_last_committed 数组中所有 peon，对于数组中 peon.version_t leader.last_committed 来说，创建 MMonPaxos 消息且消息类型是 MMonPaxos::OP_COMMIT 且将该消息发送给 peon

     |__对于 peon.accepted_pn leader.accepted_pn，则调用 Paxos::collect()

     |__对于 peon.accetped_pn == leader.accepted_pn，则认为 peon 认可 leader 的 proposal number，对于所有 peon 都认可 leader 的 proposal number，则设置当前状态为 STATE_UPDATING_PREVIOUS

     |__Paxos::begin()，调用参数是 peon 传过来的 uncommitted_value

     Paxos::begin()

     |__初始化 accepted 数组

     |__对于 last_committed== 0 的情况，设置 first_committed=1

     |__将参数中传递进来的 peon 的 uncommitted_value 写入到 MonitorDB 中

     |__更新 pending_v = last_committed+1/pending_pn=aceepted_pn 且写入到 MonitorDB 中

     |__遍历 mon- get_quorum()，创建 MMonPaxos 消息且设置消息类型是 MMonPaxos::OP_BEGIN

     |__设置消息的 pn=accepted_pn/last_committed=last_committed/value[last_committed+1]=new_value

     |__发送 MMonPaxos 消息到 peon

     Paxos::handle_accept()

     |__对于 peon.accepted_pn != leader.accepted_pn，则直接拒绝

     |__将 peon 插入到 accepted 数组中

     |__若所有 peon 都返回 OP_ACCEPT 消息，则调用 Paxos::commit_start()

     Paxos::commit_start()

     |__写 last_committed=last_committed+ 1 到 MonitorDB 中

     |__将 uncommited_value 写入到 MonitorDB 中

     |__写 MonitorDB 成功后回调 Paxos::commit_finish() 函数

     Paxos::commit_finish()

     |__遍历 mon- get_quorum()，创建 MMonPaxos 消息且消息类型是 MMonPaxos::OP_COMMIT

     |__设置消息的 value[last_committed]=new_value/pn=accepted_pn/last_committed=last_committed

     |__将消息发送给 peon

     |__设置当前状态为 STATE_REFRESH

peon

     Paxos::handle_collect()

     |__state = STATE_RECOVERING           设置当前状态为 RECOVERING

     |__对于 leader 的 first_committed peon 的 last_committed+1，则调用 mon- bootstrap()

     |__创建 MMonPaxos 消息且设置消息类型为 MMonPaxos::OP_LAST

     |__设置消息的 last_committed/first_committed

     |__若 leader.accepted_pn peon.accepted_pn，则设置 peon.accepted_pn=leader.accepted_pn，同时设置 peon.accepted_pn_from=leader.pn_from

     |__将 peon.accepted_pn 写入到 MonitorDB 中

     |__设置 MMonPaxos 消息的 pn/pn_from=accepted_pn/accepted_pn_from

     |__若 leader.last_committed peon.last_committed，则说明 peon 存在 uncommitted value，于是从 MonitorDB 读取出 pending_pn/pending_value 且设置到 MMonPaxos 消息中的 uncommitted_pn/value[pending_v] 中

     |__发送 MMonPaxos 消息给 leader

     Paxos::handle_begin()

     |__对于 leader.pn peon.accepted_pn，则直接拒绝

     |__state = STATE_UPDATING

     |__保存 leader.uncommitted_value 到 MonitorDB

     |__保存 pending_v=last_committed+1/pending_pn=accepted_pn 到 MonitorDB

     |__创建 MMonPaxos 消息且设置消息类型为 MMonPaxos::OP_ACCEPT

     |__设置消息 pn=accepted_pn/last_committed=last_committed

     |__将 MMonPaxos 消息发送给 leader

     Paxos::handle_commit()

     |__Paxos::store_state()           将 leader committed 的 value 写入到 MonitorDB 中

leader 和 peon 之间的处理流程对应关系如下：

leader                                             peon

     collect()                                          handle_collect()

     handle_last()                                  

     begin()                                            handle_begin()

     handle_accept()

     commit_start()

     commit_finish()                              handle_commit()

以上是“Ceph Monitor Paxos 算法怎么用”这篇文章的所有内容，感谢各位的阅读！相信大家都有了一定的了解，希望分享的内容对大家有所帮助，如果还想学习更多知识，欢迎关注丸趣 TV 行业资讯频道！