文章/答案/技术大牛

发布

社区首页 >专栏 >MongoDB详细表级操作统计及详细时延统计实现原理

MongoDB详细表级操作统计及详细时延统计实现原理

MongoDB中文社区

发布于 2021-08-06 02:56:57

1.4K00

代码可运行

文章被收录于专栏：MongoDB中文社区MongoDB中文社区

运行总次数：0

代码可运行

背景

MongoDB内核代码中提供有完善的gotool工具，这些开源工具作用主要有：数据导出及恢复(mongodump、mongorestore、mongoexport、mongoimport)工具、客户端shell链接工具(mongo)、IO测试工具(mongoperf)、流量qps/时延等监控统计工具(mongostat、mongotop)。

MongoDB默认只提供mongostat和mongotop工具来完成流量和时延统计，这两个工具的主要功能如下：

mongostat：监控整个集群的qps统计信息
mongotop：监控表级的读写时延统计信息

问题：

问题一：mongostat可以监控整个集群的qps信息，但是表级的qps信息如何监控？例如如果某一时刻读写流量突然暴涨引起集群抖动，怎么知道是那个具体的表引起？

问题二：mongotop可以获取整个表的读写时延消耗，如果某个表写时延很高，我们如何快速定位写时延高具体由增、删、改操作中的那个操作引起？

显然，mongostat和mongotop满足不了我们怼上面的两个问题的需求。实际上，MongoDB内部实现上提供有对应的表级别qps和表级别时延统计接口，拿到这些接口统计后，我们就可以快速获取对应的数据结果，本文讲分析表级统计的实现原理及核心代码实现。

1. mongostat、mongotop监控统计信息

MongoDB官方对外开源的qps及时延监控主要有mongostat和mongotop，本章节分析这两个工具的用法及监控项。

1.1 mongostat监控统计

MongoDB提供了mongostat工具来监控当前集群的各种操作统计。Mongostat监控统计如下图所示：

其中，insert、delete、update、query这四项统计比较好理解，分别对应增、删、改、查，getMore记录批量拉数据时候的游标操作统计，command统计在mongos和mongod中有不同的涵义，具体参考：MongoDB内核源码实现、性能调优、最佳运维实践系列-command命令处理模块源码实现三

mongostat help参数功能详细说明如下：

参数项	功能说明
general options:	获取版本信息、help帮助信息
verbosity options:	是否打印日志信息，-v表示打印日志，v个数越多日志打印越多 quiet默认不答应日志
connection options:	链接的mongo实例ip:port地址
ssl options:	SSL认证相关配置
authentication options:	鉴权认证的用户名和密码
uri options:	uri链接认证方式，类似MongoDB://username1:password1@ip:port
stat options:	统计选项设置： --discover：如果链接的是复制集节点，则输出整个复制集所有节点监控信息；如果链接的是代理mongos节点，则输出整个分片集群节点监控信息。 -n：一共输出多少行即停止监控输出，默认没限制 --json：指定输出个数为json格式 -i: 直接同一个屏幕显示统计信息，屏幕刷新周期就是-i指定的时间 --humanReadable：是否进行字节到M或者K等的转换，默认true

1.2 mongotop监控统计

mongotop实现对所有表的读写时延消耗统计，并按照总耗时排序直观输出，对应统计打印信息如下图所示：

mongotop监控输出项各字段说明如下：

ns: 表名
read：1秒钟内客户端对该表读操作消耗的总时间
write：1秒钟内客户端对该表写操作消耗的总时间
total：1秒钟内客户端对该表读写消耗的总时间

mongotop工具help参数信息说明如下表所示：

参数项	功能说明
general options:	获取版本信息、help帮助信息
verbosity options:	是否打印日志信息，-v表示打印日志，v个数越多日志打印越多 quiet默认不答应日志
connection options:	链接的mongo实例ip:port地址
ssl options:	SSL认证相关配置
authentication options:	鉴权认证的用户名和密码
uri options:	uri链接认证方式，类似MongoDB://username1:password1@ip:port
stat options:	统计选项设置： -n：一共输出多少行即停止监控输出，默认没限制 --json：指定输出个数为json格式

2. 表级详细操作统计及其时延监控统计

mongod实例会对表级别的增、删、改、查、getMore、command进行详细的操作统计，并对每种操作的时延进行统计。每个表都拥有一个CollectionData结构，该结构中存储所有操作统计和时延统计；同一个操作的qps统计和时延统计通过UsageData结构实现，包含count和time两个成员。

2.1 表级统计实现原理

详细的表级统计通过以下几个类结构分层实现：

全局UsageMap表

UsageMap是一个StringMap表结构，该map表中的成员类型为CollectionData，一个CollectionData对应一个表名及其该表的各自详细qps和时延统计信息，核心代码定义如下：

typedef StringMap<CollectionData> UsageMap;

CollectionData表统计信息

CollectionData结构中包含多个成员，包含了三个维度的统计，每个维度中的成员对应一个操作统计项，统计维度及其操作类型如下表：

UsageData

UsageData完成上面的锁维度和请求类型维度的操作计数和时延计数，UsageData包含count和time两个成员，分别用于操作计数和时延计数。

OperationLatencyHistogram表级汇总型统计

OperationLatencyHistogram实现表级别的操作汇总计数和汇总型时延统计，在该汇总型统计中把请求类型维度中的六项操作(queries、getmore、insert、update、remove、commands)合并汇总为三项统计：reads、writes、_commands。

2.2 核心代码实现

MongoDB表级详细统计实现主要由src/mongo/db/stats/目录中的top.cpp、top.h、operation_latency_histogram.cpp、operation_latency_histogram.h四个文件完成。

2.2.1 核心数据结构实现

核心数据结构代码实现如下：

class Top {

   ......

  //map表中每个表占用一个  

  struct CollectionData {

    ......

    //锁维度

    UsageData readLock;

    UsageData writeLock;

      //表级别不同操作的时延统计，粒度相比OperationLatencyHistogram更小

      //请求类型维度，包含增、删、改、查、getMore、command六类

      UsageData queries;

      UsageData getmore;

      UsageData insert;

      UsageData update;

      UsageData remove;

      UsageData commands;

      //总的，上面的[queries,commands]

      UsageData total;

      

      //汇总型维度，包含读、写、command三个维度

      OperationLatencyHistogram opLatencyHistogram;

    };

    //锁类型，读锁还是写锁

    enum class LockType {

      ReadLocked,

      WriteLocked,

      NotLocked,

    };

    //Top._usage 各种命令的详细统计记录在该map表中

    //map表中每个表占用一个，参考Top::record

    typedef StringMap<CollectionData> UsageMap;

  public:

    //全局UsageMap表,表中每个成员对应一个collection表

    UsageMap _usage;  

    ......

  }

从上面的核心算法可以看出，UsageMap 为map表结构，包含有所有表名及其对应的表级请求统计和时延统计，每个表的所有统计记录到struct CollectionData {} 结构中。

CollectionData 结构中的成员可以分为三类：锁统计、详细请求统计、汇总型统计，其中汇总型统计由class OperationLatencyHistogram {}类实现，核心成员如下：

class OperationLatencyHistogram {

  ......

private:

  //可以用于记录历史统计，通过buckets来区分，最大可以记录kMaxBuckets个历史统计信息

  struct HistogramData {

    std::array<uint64_t, kMaxBuckets> buckets{};

    uint64_t entryCount = 0;

    uint64_t sum = 0;

  };

    ......

    HistogramData _reads, _writes, _commands;

  }

2.2.2 核心算法实现

按照不同的维度，表级详细统计核心算法实现可以包含：锁及请求类型详细统计算法实现、汇总型表级详细统计算法实现。

锁类型统计和请求类型详细统计核心算法实现

MongoDB按照不同统计维度，同一个请求可以归纳到不同锁类型，同时也可以归纳到不同请求类型。例如，db.test.find({xxx})这个查询，在对test表详细统计的时候，该查询会同时对该表的读锁readLock统计及queries统计进行计数，也就是会同时记录该操作锁操作计数和查询操作计数。

锁类型统计及请求类型表级统计核心算法实现如下：

1. 找出对应表统计存储结构CollectionData

void Top::record(...) {

  ......

  //根据表名从Map表种找到该表在表中对应hash位置

  auto hashedNs = UsageMap::HashedKey(ns);

  stdx::lock_guard<SimpleMutex> lk(_lock);

  //如果ns是已经删除的表，直接返回

  if ((command || logicalOp == LogicalOp::opQuery) && ns == _lastDropped) {

      _lastDropped = "";

      return;

    }

    //找到改表对应的CollectionData

    CollectionData& coll = _usage[hashedNs];

    //开始表级计数统计

    _record(opCtx, coll, logicalOp, lockType, micros, readWriteType);

  }

2. 对该表进行真正的计数统计操作

//Top::record**调用 各个命令的op及时延统计**

void Top::_record(...) { 

  //**汇总型详细表级统计**

  _incrementHistogram(opCtx, micros, &c.opLatencyHistogram, readWriteType); 

  //**该表总时延计数，包括增删改查getMore command六项** 及其他所有的统计

  c.total.inc(micros); 

  //**写锁计数**

  if (lockType == LockType::WriteLocked) 

    c.writeLock.inc(micros); 

    //**读锁计数**

    else if (lockType == LockType::ReadLocked) 

      c.readLock.inc(micros); 
    //**详细增 删 改 查 getMore command统计及时延**

    switch (logicalOp) { 

      //**无效类型**

      case LogicalOp::opInvalid: 

        // use 0 for unknown, non-specific 

        break; 

      case LogicalOp::opUpdate:  //**增**

        c.update.inc(micros); 

        break; 

      case LogicalOp::opInsert: //**插入**

        c.insert.inc(micros); 

        break; 

      case LogicalOp::opQuery: //**查询**

        c.queries.inc(micros); 

        break; 

      case LogicalOp::opGetMore: //getMore**游标**

        c.getmore.inc(micros); 

        break; 

      case LogicalOp::opDelete: //**删除**

        c.remove.inc(micros); 

        break; 

      case LogicalOp::opKillCursors: //

        break; 

      case LogicalOp::opCommand: 

        c.commands.inc(micros); 

        break; 

      default: 

        MONGO_UNREACHABLE; 

    } 

  }

表级汇总型操作及时延统计

汇总型操作详细统计主要实现读、写、command操作统计及对应时延统计，这类操作核心代码实现如下：

1. 按照不同操作分类

//不同请求归类参考getReadWriteType

 //Top::_incrementHistogram  操作和时延计数操作

void OperationLatencyHistogram::increment(uint64_t latency, Command::ReadWriteType type) {

  //确定latency时延对应在[0-2]、(2-4]、(4-8]、(8-16]、(16-32]、(32-64]、(64-128]...中的那个区间

  int bucket = _getBucket(latency);

  switch (type) {

    //读时延累加，操作计数自增

    case Command::ReadWriteType::kRead:

      incrementData(latency, bucket, &reads);

        break;

      //写时延累加，操作计数自增

      case Command::ReadWriteType::kWrite:

        incrementData(latency, bucket, &writes);

        break;

      //command时延累加，操作计数自增

      case Command::ReadWriteType::kCommand:

        incrementData(latency, bucket, &commands);

        break;

      default:

        MONGO_UNREACHABLE;

    }

  }

2. 对应分类操作计数、时延计数

//OperationLatencyHistogram::increment中调用

//读 写 command总操作自增，时延对应增加latency

void OperationLatencyHistogram::_incrementData(uint64_t latency, int bucket, HistogramData* data) {

  //落在bucket桶指定时延范围的对应操作数自增

  data->buckets[bucket]++;

  //该操作总计数

  data->entryCount++;

  //该操作总时延计数

  data->sum += latency;

  }

3. 时延范围分区桶统计

MongoDB进行汇总型操作及时延统计后，可以获取总体的读、写、command平均时延，但是无法获取例如最大时延、95%分位时延、99分位时延等。MongoDB为了满足这些需求，同时降低代码实现难度，通过分区时延统计来满足业务的这些需求。

时延范围分区桶实现原理：根据时延值，按照如下时延范围和分区桶得对应关系来完成统计操作，时延和桶的对应关系如下图所示：

时延范围分区桶核心算法实现核心代码实现如下：

//桶计数

void OperationLatencyHistogram::_incrementData(uint64_t latency, int bucket, HistogramData* data) {

  //落在bucket桶指定时延范围的对应操作数自增

  data->buckets[bucket]++;

  ......

}

 

//不同请求归类参考getReadWriteType

//Top::_incrementHistogram  操作和时延计数操作

  void OperationLatencyHistogram::increment(uint64_t latency, Command::ReadWriteType type) {

    //确定latency时延对应在[0-2]、(2-4]、(4-8]、(8-16]、(16-32]、(32-64]、(64-128]...中的那个区间

    int bucket = _getBucket(latency);

    switch (type) {

      //读时延累加，操作计数自增

      case Command::ReadWriteType::kRead:

        incrementData(latency, bucket, &reads);

        break;

      //写时延累加，操作计数自增

      case Command::ReadWriteType::kWrite:

        incrementData(latency, bucket, &writes);

        break;

      //command时延累加，操作计数自增

      case Command::ReadWriteType::kCommand:

        incrementData(latency, bucket, &commands);

        break;

      default:

        MONGO_UNREACHABLE;

    }

  }