Monitor 作为Ceph的 Metada Server 维护了集群的信息，它包括了6个 Map， 分别是 MONMap，OSDMap，PGMap，LogMap，AuthMap，MDSMap。 其中 PGMap 和 OSDMap 是最重要的两张Map。
- Monitor内部使用一套Paxos来实现各种数据的更新，所以所有继承自PaxosService的Monitor 实现数据更新时需要通过Paxos达成一致后才能进行。
- PaxosService的dispatch内部调用子类的preprocess_query进行查询相关操作，如果非查询类处理， 再调用子类的prepare_update接口实现数据的更新，所以子类Monitor实现两个接口来处理相关的业务消息。
| 消息类型 | 消息结构体 | 消息作用 | 处理接口 |
|---|---|---|---|
| CEPH_MSG_PING | MPing | 定期Ping Monitor确认Monitor的存在 | handle_ping |
| CEPH_MSG_MON_GET_MAP | MMonGetMap | 认证前获取MonMap | handle_mon_get_map |
| CEPH_MSG_MON_METADATA | MMonMetadata | 处理保存某个Monitor的系统信息（cpu，内存等） | handle_mon_metadata |
| MSG_MON_COMMAND | MMonCommand | 传递命令行消息给Monitor，Monitor再分发给相应的XXXMonitor进行处理 | handle_command |
| CEPH_MSG_MON_GET_VERSION | MMonGetVersion | 获取cluster map的版本信息 | handle_get_version |
| CEPH_MSG_MON_SUBSCRIBE | MMonSubscribe | Cluster map订阅更新 | handle_subscribe |
| MSG_ROUTE | MRoute | 路由请求转发（待确认） | handle_route |
| MSG_MON_PROBE | MMonProbe | 启动加入时需要向其他Monitor发送Probe请求 | handle_probe |
| MSG_MON_SYNC | MMonSync | 同步Paxos状态数据 | handle_sync |
| MSG_MON_SCRUB | MMonScrub | MonitorDBStore数据一致性检测 | handle_scrub |
| MSG_MON_JOIN | MMonJoin | 如果不在MonMap中申请加入到MonMap | MonmapMonitor::prepare_join |
| MSG_MON_PAXOS | MMonPaxos | 选举完成后，leader会触发Paxos::leader_init，状态置为STATE_RECOVERING，并发起该消息的OP_COLLECT流程 | Paxos::dispatch |
| MSG_MON_ELECTION | MMonElection | 发起选举流程 | Elector::dispatch |
| MSG_FORWARD | MForward | 将请求转发到leader | handle_forward |
| MSG_TIMECHECK | MTimeCheck | Monitor每隔mon_timecheck_interval检测所有Monitor的系统时间来检测节点之间的时间差 | handle_timecheck |
| MSG_MON_HEALTH | MMonHealth | 每隔mon_health_data_update_interval检测存放Monitor上面使用的leveldb数据的状态 | HealthMonitor::service_dispatch |
| 消息类型 | 消息结构体 | 消息作用 | 处理接口 |
|---|---|---|---|
| MSG_MON_COMMAND | MMonCommand | 处理ceph auth xxx命令行相关处理 | preprocess_command处理ceph auth get/export/list等 prepare_command处理ceph auth import/add/get-or-create/caps等 |
| CEPH_MSG_AUTH | MAuth | 实现认证和授权消息处理 | prep_auth |
| 消息类型 | 消息结构体 | 消息作用 | 处理接口 |
|---|---|---|---|
| CEPH_MSG_MON_GET_OSDMAP | MMonGetOSDMap | 获取OSDMap | preprocess_get_osdmap |
| MSG_OSD_MARK_ME_DOWN | MOSDMarkMeDown | OSD shutdown之前通知Monitor发送该消息 | preprocess_mark_me_down prepare_mark_me_down |
| MSG_OSD_FAILURE | MOSDFailure | 1. OSD每隔OSD_TICK_INTERVAL检测心跳无响应的OSD，并将失败的OSD report给Monitor 2. Monitor判断上报次数>=mon_osd_min_down_reports，那么就将target_osd标识为down |
preprocess_failure |
| MSG_OSD_BOOT | MOSDBoot | 新OSD加入时发送请求到Monitor，参考新OSD的加入流程 | preprocess_bootprepare_boot |
| MSG_OSD_ALIVE | MOSDAlive | OSD判断up_thru_wanted决定是否发送请求给Monitor，Monitor发送Incremental OSDMap返回给OSD | preprocess_alive prepare_alive |
| MSG_OSD_PGTEMP | MOSDPGTemp | Primary OSD处于backfilling状态无法提供读取服务时，会发送该消息到Monitor，将PG临时映射到其他的OSD上提供去服务 | preprocess_pgtemp prepare_pgtemp |
| MSG_REMOVE_SNAPS | MRemoveSnaps | 删除快照信息 | prepare_remove_snaps |
| CEPH_MSG_POOLOP | MPoolOp | 删除/创建Pool，创建/删除pool快照等 | prepare_pool_op |
| 消息类型 | 消息结构体 | 消息作用 | 处理接口 |
|---|---|---|---|
| CEPH_MSG_STATFS | MStatfs | 返回文件系统osd占用的kb容量 | handle_statfs |
| MSG_PGSTATS | MPGStats | 查询或者更新pg状态 | preprocess_pg_stats prepare_pg_stats |
| MSG_GETPOOLSTATS | MGetPoolStats | 获取pool汇总状态信息 | preprocess_getpoolstats |
| MSG_MON_COMMAND | MMonCommand | 处理ceph pg xxx相关命令行 | preprocess_command |
| 消息类型 | 消息结构体 | 消息作用 | 处理接口 |
|---|---|---|---|
| MSG_MON_JOIN | MMonJoin | 更新MonMap | preprocess_join prepare_join |
| MSG_MON_COMMAND | MMonCommand | 处理ceph mon xxx相关命令行 | preprocess_command prepare_command |
| 消息类型 | 消息结构体 | 消息作用 | 处理接口 |
|---|---|---|---|
| MSG_MDS_BEACON | |||
| MSG_MDS_OFFLOAD_TARGETS |
| 消息类型 | 消息结构体 | 消息作用 | 处理接口 |
|---|---|---|---|
| MSG_LOG |