MSG 公链业务模块详解

⬅ 返回 MSG 白皮书层级目录

共识调度机制 (Round-Robin + DAR) 业务流转

知识网络定位

当前页面已进入跨页知识网络层：不仅展示本页拓扑，还明确它在整站里的分类、被哪些页面引用、又继续指向哪些专题与证据页。

打开知识网络总览

状态：已实现分组：控制与治理出链：0 回链：8 相邻推荐：8

治理时间锁提案注册中心规范键处罚挑战恢复

这页继续通向

当前页没有显式继续指向其他模块页

这些页面会回到本页

AI Validator 自治闭环 Genesis + Quantum 双节点启动全链路总图安全总览拓扑白皮书总拓扑母图证据覆盖率矩阵资格审计与违约处罚机制 (Slashing & Audit)量子节点启动流铸造与结算引擎 (Emission & Settlement)


flowchart TD
    subgraph DARAudit["DAR 资格审计与评分"]
        Audit["资格审计: 过滤 jailed / slashed / audit_failed"] --> Eligible["保留合格验证者集合"]
        Eligible --> Cache{"DARScore.TotalScore > 0 ?"}
        Cache -->|"是"| Cached["优先使用合约缓存 DARScore"]
        Cache -->|"否"| Local["回退本地 CalculateDARScore"]
        Cached --> Count{"当前合格验证者数量"}
        Local --> Count
        Score["评分口径 = 在线 0-40 + 稳定 0-30 + 持币 0-20 + 持币时长 0-10"] --> Rank["按总分排序；同分按在线分 / 漏块 / NodeID 排序"]
    end

    subgraph ReviewClock["DAR / 节点角色重审时间边界"]
        BlockTime["block_time_schedule_v1
累计 economic_seconds"] --> ReviewPeriod["rating_update_interval = 86400 economic seconds"]
        ReviewPeriod --> ReviewGate{"到达重审窗口?"}
        ReviewGate -->|"是"| Audit
        ReviewGate -->|"否"| KeepPrev["保持当前角色与资格状态"]
        FailClosed["主网生产查询失败 -> fail-closed
不按默认 block 数触发重审"] -.-> ReviewGate
    end

    Count -->|"数量 >= 104"| Capped["进入 capped 模式"]
    Count -->|"数量 <= 96"| Open["进入 open 模式"]
    Count -->|"数量 97~103"| Keep["保持上一轮 selection_mode"]

    Capped --> Rank
    Rank --> Top100["仅保留 DAR TopN 进入轮值集合
N = max_validators，默认 100，可 DAO 增加"]
    Open --> All["所有合格验证者直接进入轮值集合"]
    Keep --> Prev["沿用上一轮 open / capped 结果"]

    subgraph SchedulerFlow["Round-Robin 调度与安全门"]
        Top100 --> Scheduler["Round-Robin 调度器"]
        All --> Scheduler
        Prev --> Scheduler
        Scheduler --> MinNodes{"至少 2 个量子节点在线?"}
        MinNodes -->|"否"| Wait["暂停出块，继续等待节点恢复"]
        MinNodes -->|"是"| NoRepeat{"WouldCauseConsecutiveBlock ?"}
        NoRepeat -->|"是"| Reject["拒绝该候选节点，记录连续出块原因"]
        NoRepeat -->|"否"| Build["按治理生效的 target_block_seconds 触发打包"]
        Reject --> Rotate["切到下一个候选 / 链停等恢复"]
        Rotate --> Build
        Build --> Sign["执行交易、计算状态并用 Dilithium-5 签名"]
        Sign --> Broadcast["向 P2P 网络广播新区块"]
    end

📄 pkg/consensus/dar.go（现行 DAR 四维评分）

// DARScore 当前口径：不是“贡献/合规”四象限，而是与现代码一致的四维评分。
// 1. 在线评分 OnlineScore: 0-40 分
// 2. 稳定性评分 StabilityScore: 0-30 分
// 3. 持币评分 HoldingsScore: 0-20 分
// 4. 持币时长评分 HoldingDurationScore: 0-10 分
// 总分 = 四项直接相加；Rust 合约为权威源，Go 侧在降级模式下保持同口径。

📄 pkg/consensus/dar.go（selection_mode 滞回）

// 104/96 不是节点评分阈值，而是 active validator capped 模式是否开启的“人数滞回阈值”：
// - 合格验证者数量 >= 104：进入 capped 模式，按治理参数 max_validators 截取 TopN
// - 合格验证者数量 <= 96：退出 capped，回到 open 模式
// - 数量在 97~103：保持上一轮 selection_mode，避免节点数量在边界附近抖动
// - 其中 max_validators 默认/最小为 100，可由 DAO 增加，但不能降低到协议下限以下
// 同时继续满足：至少 2 个量子节点在线、且不允许单一节点连续出块。

📄 pkg/consensus/round_robin.go + pkg/consensus/dar.go

// 当前共识页必须强调两个真实边界：
// 1. 合约驱动优先：
//    - 若验证者 DARScore.TotalScore > 0，优先使用合约缓存评分
//    - 只有新节点/合约未覆盖时才回退本地 CalculateDARScore
//
// 2. 连续出块零容忍：
//    WouldCauseConsecutiveBlock(nodeID, height)
//    if rr.lastBlockProducer == nodeID && rr.lastBlockHeight == height-1 {
//        return true, "node already produced previous block"
//    }
//
// 这说明：
// - 当前不是“纯本地打分 + 简单轮询”
// - 当前 active set 上限来自 validator_qualification_v2.max_validators，而不是节点硬编码 100
// - 调度是“合约评分优先 + 104/96 滞回 + DAO governed cap + 连续出块零容忍”的组合式路径。

📄 pkg/quantum/node.go + pkg/genesis/node.go + contracts/cosmwasm/all/dar_rating_v1

// 当前新增的时间边界口径：
// 1. 节点角色重审 / DAR review 不再把 17280 blocks 当成长期真值。
// 2. 当前主网语义是：
//    rating_update_interval = 86400 economic seconds
//    由 block_time_schedule_v1 的累计 economic_seconds 驱动。
// 3. 这意味着 DAO 若调整 target_block_seconds，
//    “24 小时重审”仍由 economic seconds 保持语义稳定，而不是随着固定 block 数漂移。
//
// 当前生产边界：
// - 主网生产路径若查不到 DAR config 或 block_time_schedule economic_seconds：fail-closed
// - 只允许非主网 / 本地兼容路径继续使用估算值
//
// 因此白皮书不能再把 DAR 重审时间写成“固定 17280 blocks”。

共识调度机制 (Round-Robin + DAR) 业务流转

知识网络定位

这页继续通向

这些页面会回到本页

相邻概念推荐