当前位置：首页 > news >正文

去中心化 AI 产品架构：从模型推理到 DApp 全链路实践

news 2026/6/22 5:22:00

去中心化 AI 产品架构：从模型推理到 DApp 全链路实践

一、当推理遇上共识：去中心化 AI 的核心困境

传统 AI 产品架构很简单：客户端请求 → 云端推理 → 返回结果。但当你试图把这套逻辑搬到 Web3 世界，问题接踵而至。链上无法运行大模型推理，链下推理结果又缺乏可信验证，用户凭什么相信返回的 AI 输出没有被篡改？

这就是去中心化 AI 的核心困境：如何在保持去中心化信任的前提下，高效地完成 AI 推理并交付结果。这不是简单的"把 API 换成智能合约"，而是需要重新设计整个信任链路。

更深层的矛盾在于——AI 推理天然是中心化的计算密集任务，而 Web3 的精神是去中心化。两者如何在同一架构中共存，决定了去中心化 AI 产品能否真正落地。

二、去中心化 AI 的信任架构设计

2.1 分层信任模型

去中心化 AI 产品不是把所有逻辑都塞进链上。合理的架构采用分层设计，在链上只做验证和结算，链下完成计算密集的推理任务。

graph TB subgraph 链上层 A[模型注册合约] --> B[推理请求合约] B --> C[结果验证合约] C --> D[质押与惩罚合约] end subgraph 链下计算网络 E[推理节点 1] --> F[结果聚合器] G[推理节点 2] --> F H[推理节点 N] --> F end B -->|分发任务| E B -->|分发任务| G B -->|分发任务| H F -->|提交聚合结果| C D -->|惩罚恶意节点| E D -->|惩罚恶意节点| G

2.2 推理结果的链上验证

链上无法运行大模型，但可以验证推理结果。核心思路是乐观验证（Optimistic Verification）：

推理节点提交结果并质押保证金
验证期（Challenge Period）内，任何人可以提交欺诈证明
如果欺诈被证实，质押金被罚没；超时无人质疑，结果被确认

这种模式借鉴了 Optimistic Rollup 的设计哲学，用经济博弈替代计算验证。

2.3 模型完整性保障

另一个关键问题是：推理节点是否真的使用了声明的模型？解决方案是ZK-ML（零知识机器学习）：

推理节点生成 ZK 证明，证明其确实用声明模型完成了推理
链上合约验证 ZK 证明的有效性
无需暴露模型权重，保护知识产权

目前 EZKL 和 RISC Zero 是这个方向的主要实践者，虽然性能仍有瓶颈，但已能支持小型模型的验证。

三、DApp 全链路开发实战

3.1 智能合约层：推理市场核心合约

// SPDX-License-Identifier: MIT pragma solidity ^0.8.20; import "@openzeppelin/contracts/security/ReentrancyGuard.sol"; import "@openzeppelin/contracts/security/Pausable.sol"; /// @title 去中心化 AI 推理市场 /// @notice 用户发布推理任务，节点竞争执行，链上验证结果 contract AIInferenceMarket is ReentrancyGuard, Pausable { struct InferenceTask { address requester; // 任务发起者 string modelId; // 模型标识符 bytes inputData; // 输入数据（加密或哈希） uint256 bounty; // 悬赏金额 uint256 deadline; // 截止时间 TaskStatus status; // 任务状态 bytes32 expectedHash; // 预期输出哈希（可选） } enum TaskStatus { Pending, // 等待节点接单 Committed, // 节点已提交结果 Challenged, // 结果被质疑 Verified, // 验证通过 Slashed // 惩罚已执行 } // 推理节点质押金额——为什么需要质押？ // 经济博弈：恶意提交错误结果会损失质押金 uint256 public constant MIN_STAKE = 1 ether; uint256 public constant CHALLENGE_PERIOD = 1 hours; mapping(address => uint256) public nodeStakes; mapping(uint256 => InferenceTask) public tasks; // task_id => node_address => result_hash mapping(uint256 => mapping(address => bytes32)) public commitments; uint256 public taskCount; event TaskCreated(uint256 indexed taskId, address requester, uint256 bounty); event ResultCommitted(uint256 indexed taskId, address node, bytes32 resultHash); event TaskVerified(uint256 indexed taskId); /// @notice 节点质押加入网络 function stake() external payable nonReentrant { require(msg.value >= MIN_STAKE, "质押金额不足"); nodeStakes[msg.sender] += msg.value; } /// @notice 创建推理任务 function createTask( string calldata modelId, bytes calldata inputData, uint256 deadline ) external payable nonReentrant whenNotPaused { require(msg.value > 0, "悬赏金额必须大于零"); require(deadline > block.timestamp, "截止时间必须在未来"); tasks[taskCount] = InferenceTask({ requester: msg.sender, modelId: modelId, inputData: inputData, bounty: msg.value, deadline: deadline, status: TaskStatus.Pending, expectedHash: bytes32(0) }); emit TaskCreated(taskCount, msg.sender, msg.value); taskCount++; } /// @notice 推理节点提交结果哈希（先提交哈希，后揭示结果） /// 为什么用 commit-reveal？防止节点复制其他节点的结果 function commitResult( uint256 taskId, bytes32 resultHash ) external nonReentrant { InferenceTask storage task = tasks[taskId]; require(task.status == TaskStatus.Pending, "任务状态不允许提交"); require(block.timestamp < task.deadline, "已过截止时间"); require(nodeStakes[msg.sender] >= MIN_STAKE, "节点未质押"); commitments[taskId][msg.sender] = resultHash; task.status = TaskStatus.Committed; emit ResultCommitted(taskId, msg.sender, resultHash); } /// @notice 验证期结束后确认结果 function verifyResult(uint256 taskId) external nonReentrant { InferenceTask storage task = tasks[taskId]; require(task.status == TaskStatus.Committed, "状态不正确"); // 检查验证期是否已过 // 为什么需要验证期？给社区时间审查结果 require( block.timestamp >= task.deadline + CHALLENGE_PERIOD, "验证期未结束" ); task.status = TaskStatus.Verified; // 将悬赏金转给第一个提交结果的节点 // 简化逻辑，生产环境应支持多节点共识 (bool sent, ) = task.requester.call{value: task.bounty}(""); require(sent, "转账失败"); emit TaskVerified(taskId); } }

3.2 链下推理节点实现

import asyncio import hashlib import json from web3 import AsyncWeb3 from eth_account import Account class InferenceNode: """去中心化推理节点——链下执行 AI 推理，链上提交结果""" def __init__(self, rpc_url: str, private_key: str, contract_address: str): self.w3 = AsyncWeb3(AsyncWeb3.AsyncHTTPProvider(rpc_url)) self.account = Account.from_key(private_key) self.contract = self._load_contract(contract_address) async def listen_for_tasks(self): """监听链上新任务事件""" event_filter = self.contract.events.TaskCreated.create_filter( fromBlock="latest" ) while True: events = await event_filter.get_new_entries() for event in events: await self._process_task(event) await asyncio.sleep(2) # 轮询间隔，避免 RPC 限流 async def _process_task(self, event): """处理推理任务""" task_id = event["args"]["taskId"] model_id = event["args"]["modelId"] try: # 加载对应模型并执行推理 result = await self._run_inference(model_id, event) # Commit-Reveal 第一阶段：提交结果哈希 result_hash = hashlib.sha256( json.dumps(result).encode() ).hexdigest() tx = await self.contract.functions.commitResult( task_id, bytes.fromhex(result_hash) ).transact({"from": self.account.address}) await self.w3.eth.wait_for_transaction_receipt(tx) except Exception as e: # 推理失败时记录日志，不提交错误结果 # 为什么不提交？错误结果可能触发惩罚机制 print(f"任务 {task_id} 推理失败：{e}") async def _run_inference(self, model_id: str, task_data: dict) -> dict: """调用本地模型执行推理——这里可替换为任意推理引擎""" # 实际项目中，这里对接 vLLM、TGI 等推理框架 # 模型按 model_id 从本地仓库加载 await asyncio.sleep(1) # 模拟推理耗时 return {"model": model_id, "output": "inference_result"}

3.3 前端 DApp 集成

// React + wagmi 集成示例 import { useContractWrite, useWaitForTransaction } from "wagmi"; import { parseEther } from "viem"; const CONTRACT_ABI = /* ... */; export function useCreateInferenceTask() { const { write, data } = useContractWrite({ address: "0x...", abi: CONTRACT_ABI, functionName: "createTask", }); const { isLoading, isSuccess } = useWaitForTransaction({ hash: data?.hash, }); const createTask = (modelId: string, inputData: string, bounty: string) => { write({ args: [modelId, inputData, Math.floor(Date.now() / 1000) + 3600], value: parseEther(bounty), }); }; return { createTask, isLoading, isSuccess }; }