这篇文章主要介绍了Ceph实现读写流程的示例分析，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。

让客户满意是我们工作的目标，不断超越客户的期望值来自于我们对这个行业的热爱。我们立志把好的技术通过有效、简单的方式提供给客户，将通过不懈努力成为客户在信息化领域值得信任、有价值的长期合作伙伴，公司提供的服务项目有：主机域名、网页空间、营销软件、网站建设、银州网站维护、网站推广。

一、Osd中的模块

消息封装

在OSD上发送和接收信息。有两类：

1.cluster_messenger -与其它OSDs和monitors沟通
2.client_messenger －与客户端沟通

消息调度

Dispatcher类，主要负责消息分类

工作队列

1.       OpWQ: 处理ops（从客户端）和sub ops（从其他的OSD）。运行在op_tp线程池。

2.       PeeringWQ: 处理peering任务，运行在op_tp线程池。

3.       CommandWQ:处理cmd命令，运行在command_tp。

4.       RecoveryWQ: 数据修复，运行在recovery_tp。

5.       SnapTrimWQ: 快照相关，运行在disk_tp。

6.       ScrubWQ: scrub，运行在disk_tp。

7.       ScrubFinalizeWQ: scrub，运行在disk_tp。

8.       RepScrubWQ: scrub，运行在disk_tp。

9.       RemoveWQ: 删除旧的pg目录。运行在disk_tp。

线程池

有4种 OSD线程池:

1.       op_tp: 处理ops和sub ops

2.       recovery_tp:处理修复任务

3.       disk_tp: 处理磁盘密集型任务

4.       command_tp: 处理命令

二、Ceph读流程

注：索引的格式，查找更新索引、如何持久化的，还没搞清楚。

没有所谓索引，一切皆规则：

每个object的文件名格式为：

objectname_key_head(snap_num)_hash_namespace_poolid

Ø  objectname：对象名

Ø  key、namespace：都是客户端指定，做名称空间细分用。当块儿设备使用时，一般都置为空

Ø  head(snap_num)：snapshot版本

Ø  hash：由objectname计算得到，u_int32_t类型，这里转换为16进制字符打印，如3AF0B980

Ø  poolid：pool的id

目录结构：

数据目录/PG名称/子目录/object文件名

举例说明：

/data09/ceph/osd2/current/0.0_head/DIR_0/DIR_8/DIR_9/10000007af4.00000000__head_3AF0B980__0

其中，子目录是根据object文件名中hash字段的字符反向排列生成。当一个目录中的文件个数大于配置值（merge_threshold * 16 * split_multiplier）时，会建子目录，对文件进行归档。

ReplicatedPG.h

ReplicatedPG.cc

 int ReplicatedPG::do_osd_ops(OpContext *ctx, vector& ops)函数中的

 Case CEPH_OSD_OP_READ分支                                       

 r = osd->store->fiemap(coll, soid, op.extent.offset, op.extent.length, bl);

 r = pgbackend->objects_read_sync(                  

           soid, miter->first, miter->second, &tmpbl);

 pgbackend->objects_read_sync转int ReplicatedBackend::objects_read_sync调用 store->read(coll, hoid, off, len, *bl) ，来自ObjectStore::read

三、Ceph写流程

阶段1：主节点发请求

阶段2：从节点处理请求

osd->store->queue_transactions(&osr, rm->tls, onapply, oncommit);

这里注册的两个回调：

 Context *oncommit = new C_OSD_RepModifyCommit(rm);  当日志写入磁盘后被调用

 Context *onapply = new C_OSD_RepModifyApply(rm);    当该操作被处理后被调用

分别向主节点做ACK和ON_DISK两种回应。

注：transaction封装，journal log写入细节，对象写入细节还没来得及看。

阶段3：主节点接收从节点回应，并回应客户端

感谢你能够认真阅读完这篇文章，希望小编分享的“Ceph实现读写流程的示例分析”这篇文章对大家有帮助，同时也希望大家多多支持创新互联，关注创新互联行业资讯频道，更多相关知识等着你来学习!