性能优化与问题排查

// 查询计划
db.t_orders.find({ status: "paid" }).explain()

// 执行统计
db.t_orders.find({ status: "paid" }).explain("executionStats")

// 所有计划执行信息
db.t_orders.find({ status: "paid" }).explain("allPlansExecution")

{
    "queryPlanner": {
        "winningPlan": {
            "stage": "FETCH",              // 执行阶段
            "inputStage": {
                "stage": "IXSCAN",         // 使用索引扫描
                "keyPattern": { "status": 1 },
                "indexName": "idx_status",
                "direction": "forward"
            }
        },
        "rejectedPlans": [...]             // 被拒绝的计划
    },
    "executionStats": {
        "executionSuccess": true,
        "nReturned": 1000,                 // 返回文档数
        "executionTimeMillis": 15,         // 执行时间（毫秒）
        "totalKeysExamined": 1000,         // 扫描的索引条目数
        "totalDocsExamined": 1000,         // 扫描的文档数
        "executionStages": {
            "stage": "FETCH",
            "nReturned": 1000,
            "docsExamined": 1000,
            "inputStage": {
                "stage": "IXSCAN",
                "nReturned": 1000,
                "keysExamined": 1000
            }
        }
    }
}

// 查看当前慢查询阈值
db.getProfilingStatus()
// { "was": 1, "slowms": 100 }

// 设置慢查询阈值为200ms
db.setProfilingLevel(1, { slowms: 200 })

// level 0: 关闭
// level 1: 仅记录慢查询
// level 2: 记录所有操作（慎用，性能影响大）

// 查看所有当前操作
db.currentOp()

// 查看执行时间超过5秒的操作
db.currentOp({
    "active": true,
    "secs_running": { "$gt": 5 }
})

// 查看等待锁的操作
db.currentOp({
    "waitingForLock": true
})

// 查看特定集合的操作
db.currentOp({
    "ns": "mydb.t_orders"
})


// 终止执行时间超过10秒的操作
db.currentOp().inprog.forEach(function(item){if(item.secs_running > 10 )db.killOp(item.opid)})

db.serverStatus()

// 关注的关键指标
{
    "connections": {
        "current": 50,      // 当前连接数
        "available": 950,   // 可用连接数
        "totalCreated": 1000
    },
    "opcounters": {
        "insert": 10000,
        "query": 50000,
        "update": 5000,
        "delete": 1000
    },
    "mem": {
        "resident": 4096,   // 常驻内存（MB）
        "virtual": 8192     // 虚拟内存（MB）
    },
    "wiredTiger": {
        "cache": {
            "bytes currently in the cache": ...,
            "maximum bytes configured": ...
        }
    }
}

// 1. 确认是否全表扫描
db.t_orders.find({ status: "paid" }).explain("executionStats")
// 检查 winningPlan.stage 是否为 COLLSCAN

// 2. 检查现有索引
db.t_orders.getIndexes()

// 3. 创建合适的索引
db.t_orders.createIndex({ status: 1 }, { background: true })

// 4. 验证索引生效
db.t_orders.find({ status: "paid" }).explain("executionStats")
// 确认 stage 变为 IXSCAN

// 1. 确认是否内存排序
db.t_orders.find({ status: "paid" }).sort({ createTime: -1 }).explain("executionStats")
// 检查是否有 SORT 阶段

// 2. 创建支持排序的索引
db.t_orders.createIndex({ status: 1, createTime: -1 }, { background: true })

// 3. 验证索引排序
db.t_orders.find({ status: "paid" }).sort({ createTime: -1 }).explain("executionStats")
// 确认无 SORT 阶段

// 1. 查看分片数据分布
db.t_orders.getShardDistribution()

// 2. 查看chunk分布
db.getSiblingDB("config").chunks.aggregate([
    { $match: { ns: "mydb.t_orders" } },
    { $group: { _id: "$shard", count: { $sum: 1 } } }
])

// 3. 检查分片键选择
db.getSiblingDB("config").collections.findOne({ _id: "mydb.t_orders" })

// 1. 查看当前连接数
db.serverStatus().connections
// { "current": 950, "available": 50, "totalCreated": 10000 }

// 2. 查看连接来源
db.currentOp(true).inprog.forEach(function(op) {
    if (op.client) print(op.client);
})

// 3. 检查应用连接池配置
// 确认maxPoolSize设置是否合理

// 1. 查看等待锁的操作
db.currentOp({ "waitingForLock": true })

// 2. 查看持有锁时间长的操作
db.currentOp({
    "active": true,
    "secs_running": { "$gt": 10 }
})

// 3. 查看锁状态
db.serverStatus().locks

// 列出所有索引
db.t_orders.getIndexes()

// 检查索引使用统计
db.t_orders.aggregate([{ $indexStats: {} }])

// 针对主要查询验证索引覆盖
const mainQueries = [
    { status: "paid" },
    { customerId: "C001", createTime: { $gte: ISODate("2024-01-01") } },
    { orderId: "ORD001" }
];

mainQueries.forEach(query => {
    const plan = db.t_orders.find(query).explain("executionStats");
    print("Query:", JSON.stringify(query));
    print("Stage:", plan.queryPlanner.winningPlan.stage);
    print("DocsExamined:", plan.executionStats.totalDocsExamined);
    print("---");
});