# AIGC-Hub 技术选型、实现与技术路线详图 — 绘制描述 > 用途：下午与技术专家深度交流，聚焦技术选型理由、混合语言分工、系统实现细节与技术演进路线 > 建议工具：Figma / draw.io / ProcessOn / PPT > 画布方向：横版，左侧为技术分层架构，右侧为技术路线甘特图 > 建议尺寸：A1 横版 或 双屏16:9拼接 --- ## 一、图的整体构图逻辑 采用 **"左架构 · 中选型 · 右路线"** 三栏式布局： - **左栏（40%）**：技术分层架构图 — 从接入层到基础设施逐层展开，每层标注具体技术组件 - **中栏（25%）**：混合语言选型矩阵 — 按性能/场景/团队维度说明每种语言的分工定位 - **右栏（35%）**：技术路线甘特图 — 三期演进，每期标注技术里程碑与组件版本升级 --- ## 二、左栏：技术分层架构详图 ### 绘制方式：7 层水平堆叠，每层用不同色带区分 ``` ┏━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┓ ┃ ⓪ 接入与流量层 ┃ ┃━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┃ ┃ ┃ ┃ ┌─────────┐ ┌─────────────┐ ┌─────────┐ ┌────────────┐ ┃ ┃ │ CDN │ │ WAF / DDoS │ │ DNS │ │ TLS 1.3 │ ┃ ┃ │广电云CDN │ │ 防护 │ │ 解析 │ │ 证书管理 │ ┃ ┃ └─────────┘ └─────────────┘ └─────────┘ └────────────┘ ┃ ┃ ┃ ┃ ┌───────────────────────────────────────────────────────┐ ┃ ┃ │ API Gateway: Kong / Apache APISIX │ ┃ ┃ │ · 流量控制 · JWT/HMAC鉴权 · 灰度发布 · 日志采集 │ ┃ ┃ │ · 限流: Token Bucket (500-2000 QPS/平台) │ ┃ ┃ └───────────────────────────────────────────────────────┘ ┃ ┃ ┃ ┃ ┌───────────────────────────────────────────────────────┐ ┃ ┃ │ Nginx Ingress Controller (K8s L7) │ ┃ ┃ │ · TLS终止 · 路由规则 · 3 replicas │ ┃ ┃ └───────────────────────────────────────────────────────┘ ┃ ┗━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┛ ┏━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┓ ┃ ① 前端与客户端层 ┃ ┃━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┃ ┃ ┃ ┃ ┌──────────────┐ ┌──────────────┐ ┌──────────────┐ ┃ ┃ │ 监管大屏 │ │ 运营后台 │ │ 创作者工作台 │ ┃ ┃ │ React 18 │ │ React 18 │ │ React 18 │ ┃ ┃ │ ECharts │ │ Ant Design 5│ │ Ant Design 5│ ┃ ┃ │ WebSocket │ │ Zustand │ │ 大文件上传 │ ┃ ┃ └──────────────┘ └──────────────┘ └──────────────┘ ┃ ┃ ┃ ┃ ┌──────────────┐ ┌──────────────┐ ┃ ┃ │ 移动端(扫码) │ │ C2PA CLI │ ┃ ┃ │ React Native │ │ Rust编译 │ ┃ ┃ │ / 小程序 │ │ 跨平台二进制 │ ┃ ┃ └──────────────┘ └──────────────┘ ┃ ┗━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┛ ┏━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┓ ┃ ② 后端微服务层（混合语言架构 · 核心） ┃ ┃━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┃ ┃ ┃ ┃ ┌─── Go 1.22+ (高并发 · 低延迟 · 网关级) ──────────────────┐ ┃ ┃ │ │ ┃ ┃ │ [MA编码网关] [赋码引擎] [清算引擎] │ ┃ ┃ │ Gin/Echo Gin+GORM Gin+GORM │ ┃ ┃ │ 万级QPS 编码规则计算 实时分账对账 │ ┃ ┃ │ AVCC解析 码资源分配 数值精度计算 │ ┃ ┃ │ │ ┃ ┃ │ [区块链服务] │ ┃ ┃ │ ChainMaker SDK / Fabric SDK │ ┃ ┃ │ 国密SM2/SM3/SM4 · gRPC高性能交互 │ ┃ ┃ └─────────────────────────────────────────────────────────┘ ┃ ┃ ┃ ┃ ┌─── Kotlin 2.0+ / Spring Boot 3.x (业务中台 · 企业级) ───┐ ┃ ┃ │ │ ┃ ┃ │ [工作台BFF服务] [审核编排服务] [平台接入管理] │ ┃ ┃ │ Spring WebFlux Coroutines Spring Security │ ┃ ┃ │ 协程非阻塞 任务状态机 OAuth2/RBAC │ ┃ ┃ │ GraphQL聚合 审核流程编排 多租户隔离 │ ┃ ┃ │ │ ┃ ┃ │ [数据回传服务] [报表与对账服务] [通知与回调服务] │ ┃ ┃ │ Kafka Consumer ClickHouse查询 WebHook/邮件/短信 │ ┃ ┃ │ 批量数据校验 定时报表生成 重试与幂等保证 │ ┃ ┃ │ │ ┃ ┃ │ 选型理由： │ ┃ ┃ │ · JVM生态成熟，企业级中间件（Spring全家桶）开箱即用 │ ┃ ┃ │ · Coroutines 协程模型兼顾高并发与代码可读性 │ ┃ ┃ │ · 空安全+DSL 减少运行时NPE，提升代码健壮性 │ ┃ ┃ │ · 与Java互操作，可复用成熟的ChainMaker Java SDK │ ┃ ┃ │ · 团队可从Java/Kotlin渐进迁移，降低招聘门槛 │ ┃ ┃ └─────────────────────────────────────────────────────────┘ ┃ ┃ ┃ ┃ ┌─── Python 3.11+ (AI管道 · 业务编排 · 快速迭代) ─────────┐ ┃ ┃ │ │ ┃ ┃ │ [审核AI管道] [版权链交互层] [文档生成] │ ┃ ┃ │ FastAPI FastAPI WeasyPrint │ ┃ ┃ │ Triton Client Web3py ReportLab │ ┃ ┃ │ 模型推理编排 合约调用封装 PDF证书 │ ┃ ┃ │ │ ┃ ┃ │ [审核任务调度] │ ┃ ┃ │ Celery + Redis │ ┃ ┃ │ 异步任务分发与结果聚合 │ ┃ ┃ └─────────────────────────────────────────────────────────┘ ┃ ┃ ┃ ┃ ┌─── Rust (底层性能 · 媒体处理 · 安全关键) ───────────────┐ ┃ ┃ │ │ ┃ ┃ │ [C2PA SDK核心] [视频指纹提取] [编解码加速] │ ┃ ┃ │ c2pa-rs FFmpeg绑定 感知哈希算法 │ ┃ ┃ │ JUMBF嵌入/验证 大文件流处理 高性能无GC │ ┃ ┃ │ │ ┃ ┃ │ 提供绑定: PyO3(Python) / N-API(JS) / CGO(Go) │ ┃ ┃ └─────────────────────────────────────────────────────────┘ ┃ ┗━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┛ ┏━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┓ ┃ ③ AI 推理层 ┃ ┃━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┃ ┃ ┃ ┃ ┌──────────────────────────────────────────────────────┐ ┃ ┃ │ NVIDIA Triton Inference Server 2.x │ ┃ ┃ │ · 动态批处理 · 多框架(PyTorch/ONNX) · GPU调度 │ ┃ ┃ └──────────────────────────────────────────────────────┘ ┃ ┃ ┃ ┃ ┌───────┐ ┌───────┐ ┌───────┐ ┌───────┐ ┌────────────┐ ┃ ┃ │画面合规│ │台词NLP│ │音频合规│ │AIGC真实│ │版权指纹向量│ ┃ ┃ │Vision │ │NLP │ │Audio │ │Deep │ │Fingerprint│ ┃ ┃ │A10/A100│ │A10 │ │A10 │ │Fake │ │CPU+Milvus │ ┃ ┃ │PyTorch│ │Trans- │ │torch- │ │A100 │ │HNSW索引 │ ┃ ┃ │OpenMM │ │formers│ │audio │ │PyTorch│ │COSINE相似 │ ┃ ┃ └───────┘ └───────┘ └───────┘ └───────┘ └────────────┘ ┃ ┃ ┃ ┃ 模型版本管理: MLflow / DVC ┃ ┃ A/B测试: 流量切分 + 灰度发布 ┃ ┗━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┛ ┏━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┓ ┃ ④ 数据存储层 ┃ ┃━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┃ ┃ ┃ ┃ ┌─────────────── 关系型 (OLTP) ──────────────────────────┐ ┃ ┃ │ PostgreSQL 16 + Patroni + etcd │ ┃ ┃ │ · 1主2从 · JSONB灵活schema · 等保审计日志 │ ┃ ┃ │ · 核心表: avcc_records / review_reports / chain_records│ ┃ ┃ │ · RPO<1s · RTO<30s │ ┃ ┃ └────────────────────────────────────────────────────────┘ ┃ ┃ ┃ ┃ ┌──────┐ ┌──────────┐ ┌──────────┐ ┌───────┐ ┌─────────┐ ┃ ┃ │Redis │ │ClickHouse│ │Elastic- │ │Milvus │ │ MinIO │ ┃ ┃ │Cluster│ │ 24.x │ │search 8.x│ │/pgvec │ │对象存储 │ ┃ ┃ │7.x │ │ │ │ │ │ │ │ │ ┃ ┃ │3主3从 │ │3节点副本 │ │3节点 │ │HNSW │ │4节点纠删│ ┃ ┃ │ │ │ │ │ │ │ │ │ │ ┃ ┃ │缓存 │ │时序分析 │ │全文检索 │ │向量 │ │视频/水印│ ┃ ┃ │限流 │ │播放统计 │ │审核报告 │ │指纹 │ │证书PDF │ ┃ ┃ │分布式锁│ │运营报表 │ │日志 │ │版权比对│ │证据包 │ ┃ ┃ └──────┘ └──────────┘ └──────────┘ └───────┘ └─────────┘ ┃ ┗━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┛ ┏━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┓ ┃ ⑤ 消息与异步层 ┃ ┃━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┃ ┃ ┃ ┃ ┌────────────────────────────────────────────────────────┐ ┃ ┃ │ Apache Kafka 3.x (3 Broker) │ ┃ ┃ │ Topics: │ ┃ ┃ │ · topic.avcc.apply.created (6分区, 7天) │ ┃ ┃ │ · topic.review.task.finished (12分区, 7天) │ ┃ ┃ │ · topic.chain.tx.confirmed (6分区, 30天) │ ┃ ┃ │ · topic.playback.event (24分区, 3天, 高吞吐) │ ┃ ┃ │ · topic.system.dlq (3分区, 永久) │ ┃ ┃ │ │ ┃ ┃ │ 语义: 核心流At-Least-Once · 播放流At-Most-Once │ ┃ ┃ │ 保序: Key=avcc_record_id → 同Partition │ ┃ ┃ └────────────────────────────────────────────────────────┘ ┃ ┃ ┃ ┃ ┌──────────┐ ┌──────────────┐ ┌────────────────┐ ┃ ┃ │Celery │ │Kafka Streams │ │APScheduler │ ┃ ┃ │+ Redis │ │/ Flink │ │/ Airflow │ ┃ ┃ │异步任务 │ │实时流处理 │ │定时调度 │ ┃ ┃ │PDF/邮件 │ │异常检测 │ │清算/报表 │ ┃ ┃ └──────────┘ └──────────────┘ └────────────────┘ ┃ ┗━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┛ ┏━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┓ ┃ ⑥ 区块链层 ┃ ┃━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┃ ┃ ┃ ┃ ┌────────────────────────────────────────────────────────┐ ┃ ┃ │ 长安链 ChainMaker 2.x (首选) / Fabric 2.5+ │ ┃ ┃ │ │ ┃ ┃ │ 共识: TBFT/Raft · 国密SM2/SM3/SM4 · 5组织联盟 │ ┃ ┃ │ │ ┃ ┃ │ 智能合约（Go实现）: │ ┃ ┃ │ ┌────────────┐ ┌────────────┐ ┌────────────┐ │ ┃ ┃ │ │AVCC_Copy- │ │AVCC_User- │ │AVCC_Settle-│ │ ┃ ┃ │ │right │ │Rights │ │ment │ │ ┃ ┃ │ │版权主链合约│ │用户权益合约│ │分账清算合约│ │ ┃ ┃ │ └────────────┘ └────────────┘ └────────────┘ │ ┃ ┃ │ │ ┃ ┃ │ 链服务代理: chain-svc (Go) → gRPC → ChainMaker Nodes │ ┃ ┃ │ 异步上链: Kafka → chain-svc → 区块监听 → 确认回调 │ ┃ ┃ │ 密钥管理: HSM硬件安全模块（等保三级必要） │ ┃ ┃ └────────────────────────────────────────────────────────┘ ┃ ┗━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┛ ┏━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┓ ┃ ⑦ 基础设施与 DevOps 层 ┃ ┃━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┃ ┃ ┃ ┃ ┌─── 容器编排 ───┐ ┌─── 可观测性 ───┐ ┌─── CI/CD ──────┐ ┃ ┃ │ K8s 1.29+ │ │ Prometheus │ │ GitLab CI │ ┃ ┃ │ Istio(可选) │ │ Grafana 10.x │ │ ArgoCD │ ┃ ┃ │ Harbor 2.x │ │ Jaeger/OTel │ │ Harbor扫描 │ ┃ ┃ │ Vault │ │ ELK / Loki │ │ Nexus制品库 │ ┃ ┃ └───────────────┘ └───────────────┘ └────────────────┘ ┃ ┃ ┃ ┃ 安全域: DMZ → 应用区 → 数据区 → AI推理区 → 区块链区 → 监管区 ┃ ┃ 网络策略: mTLS · NetworkPolicy · WAF · 等保三级全栈合规 ┃ ┗━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┛ ``` --- ## 三、中栏：混合语言选型矩阵 ### 绘制方式：横向对比表 + 雷达图 ``` ┌────────────────────────────────────────────────────────────────────┐ │ 混合语言选型决策矩阵 │ ├─────────┬────────────┬─────────────┬──────────────┬───────────────┤ │ 维度 │ Go 1.22 │ Kotlin 2.0 │ Python 3.11 │ Rust │ ├─────────┼────────────┼─────────────┼──────────────┼───────────────┤ │ 定位 │ 网关/计算 │ 业务中台 │ AI管道/编排 │ 底层/媒体 │ │ │ 密集型 │ 企业级服务 │ 快速迭代 │ 安全关键 │ ├─────────┼────────────┼─────────────┼──────────────┼───────────────┤ │ 并发模型 │ Goroutine │ Coroutines │ asyncio │ async/await │ │ │ 百万级轻量 │ 结构化并发 │ + Celery │ 零成本抽象 │ ├─────────┼────────────┼─────────────┼──────────────┼───────────────┤ │ 典型QPS │ 5万-10万 │ 1万-5万 │ 1千-5千 │ 10万+ │ │ (单实例) │ │ (WebFlux) │ (FastAPI) │ (裸性能) │ ├─────────┼────────────┼─────────────┼──────────────┼───────────────┤ │ 生态优势 │ 云原生原生 │ Spring全家桶│ AI/ML生态 │ 安全/性能 │ │ │ K8s/Docker │ 企业中间件 │ PyTorch/HF │ WASM/嵌入式 │ ├─────────┼────────────┼─────────────┼──────────────┼───────────────┤ │ 团队门槛 │ 中等 │ 低(Java转型)│ 低 │ 高 │ ├─────────┼────────────┼─────────────┼──────────────┼───────────────┤ │ 负责服务 │ MA网关 │ 工作台BFF │ 审核AI管道 │ C2PA SDK │ │ │ 赋码引擎 │ 审核编排 │ 版权链交互 │ 视频指纹 │ │ │ 清算引擎 │ 平台接入 │ 文档生成 │ 编解码加速 │ │ │ 区块链服务 │ 数据回传 │ 任务调度 │ │ │ │ │ 报表对账 │ │ │ │ │ │ 通知回调 │ │ │ ├─────────┼────────────┼─────────────┼──────────────┼───────────────┤ │ 框架 │ Gin/Echo │ Spring Boot │ FastAPI │ c2pa-rs │ │ │ GORM │ 3.x+WebFlux │ Celery │ PyO3/N-API │ │ │ ChainMaker │ Exposed/R2DBC│ SQLAlchemy │ CGO │ │ │ SDK │ Ktor(备选) │ Triton Cli │ │ ├─────────┼────────────┼─────────────┼──────────────┼───────────────┤ │ 构建产物 │ 静态二进制 │ JVM JAR/ │ Docker容器 │ .so/.dylib │ │ │ <20MB │ Native(GraalVM)│ + wheel │ + WASM │ ├─────────┼────────────┼─────────────┼──────────────┼───────────────┤ │ 一期占比 │ 35% │ 25% │ 30% │ 10% │ │ 三期占比 │ 30% │ 35% │ 20% │ 15% │ └─────────┴────────────┴─────────────┴──────────────┴───────────────┘ ``` ### 选型理由可视化（雷达图） ``` 建议绘制 4 个重叠雷达图，5 个维度轴： - 性能 (Performance) - 生态成熟度 (Ecosystem) - 团队可得性 (Hiring) - 类型安全 (Type Safety) - AI/ML亲和力 (AI Affinity) Go: 性能★★★★☆ 生态★★★★★ 招聘★★★★☆ 类型★★★☆☆ AI★★☆☆☆ Kotlin: 性能★★★★☆ 生态★★★★★ 招聘★★★★★ 类型★★★★★ AI★★★☆☆ Python: 性能★★☆☆☆ 生态★★★★☆ 招聘★★★★★ 类型★★☆☆☆ AI★★★★★ Rust: 性能★★★★★ 生态★★★☆☆ 招聘★★☆☆☆ 类型★★★★★ AI★★☆☆☆ ``` --- ## 四、Kotlin 在系统中的具体定位与服务拆分 ``` ┌─────────────────────────────────────────────────────────────┐ │ Kotlin 服务群（Spring Boot 3.x） │ │ │ │ ┌─────────────────────────────────────────────────────┐ │ │ │ workbench-bff (工作台聚合网关) │ │ │ │ · GraphQL/REST → 聚合赋码+审核+分账数据 │ │ │ │ · WebFlux 非阻塞 · R2DBC 响应式DB │ │ │ │ · 协程处理：并行调用多个下游微服务 │ │ │ └─────────────────────────────────────────────────────┘ │ │ │ │ ┌─────────────────────────────────────────────────────┐ │ │ │ review-orchestrator (审核编排服务) │ │ │ │ · 状态机驱动（Spring StateMachine / 自研 Kotlin DSL）│ │ │ │ · queued→preprocessing→inferencing→fusion→completed │ │ │ │ · 协程编排多个AI模型的并行推理结果聚合 │ │ │ │ · 优先级队列管理（P/G/O 三级） │ │ │ └─────────────────────────────────────────────────────┘ │ │ │ │ ┌─────────────────────────────────────────────────────┐ │ │ │ platform-access-svc (平台接入管理) │ │ │ │ · 平台注册/激活/冻结全生命周期 │ │ │ │ · API Key 管理 · 配额管控 · OAuth2 Server │ │ │ │ · 多租户数据隔离 │ │ │ └─────────────────────────────────────────────────────┘ │ │ │ │ ┌─────────────────────────────────────────────────────┐ │ │ │ data-ingest-svc (数据回传服务) │ │ │ │ · Kafka Consumer (Kotlin Coroutines) │ │ │ │ · 批量数据校验 + ClickHouse 批写入 │ │ │ │ · 播放数据聚合 · 异常检测触发 │ │ │ └─────────────────────────────────────────────────────┘ │ │ │ │ ┌─────────────────────────────────────────────────────┐ │ │ │ report-svc (报表与对账服务) │ │ │ │ · 定时任务(Spring Scheduler + Coroutines) │ │ │ │ · 月度对账单 · 版权估值报告 · 监管日报 │ │ │ │ · 导出 PDF/Excel │ │ │ └─────────────────────────────────────────────────────┘ │ │ │ │ ┌─────────────────────────────────────────────────────┐ │ │ │ notification-svc (通知与回调服务) │ │ │ │ · WebHook 回调（审核完成/赋码成功/分账到账） │ │ │ │ · 邮件/短信/站内信 · 重试+幂等 │ │ │ │ · Spring Retry + Kotlin sealed class 状态建模 │ │ │ └─────────────────────────────────────────────────────┘ │ │ │ │ 技术栈明细： │ │ · Kotlin 2.0 + Spring Boot 3.3 + Spring WebFlux │ │ · Kotlin Coroutines + Flow（响应式流） │ │ · Exposed / R2DBC（响应式数据库访问） │ │ · Spring Security + OAuth2 Resource Server │ │ · Kotest（测试）+ MockK（Mock）+ Testcontainers │ │ · GraalVM Native Image（可选，冷启动优化） │ │ · Gradle Kotlin DSL 构建 │ └─────────────────────────────────────────────────────────────┘ ``` --- ## 五、右栏：技术路线甘特图 ### 绘制方式：横向时间轴 + 纵向服务/组件行 ``` 时间轴 → M1 M2 M3 M4 M5 M6 │ M7 M8 M9 M10 M11 M12 │ Y2 ├─────── 一期：筑基 ─────────┤├──────── 二期：贯通 ──────────┤├─ 三期 ─→ ═══════════════════════════════════════════════════════════════════════════════ 基础设施 ───────────────────────────────────────────────────────────────────────────── K8s集群 ████████ 升级1.30+→ PG+Redis+Kafka ████████ 等保三级测评 ░░░░░░░░░░░░░░░░████ 复测 Harbor+Vault ████ ═══════════════════════════════════════════════════════════════════════════════ Go 服务 ───────────────────────────────────────────────────────────────────────────── 赋码引擎V1 ████████████████ MA网关V1 ████████████ 清算引擎V1 ████████████████ 区块链服务V1 ████████████████████ MA网关V2(根解析) ████████████ ═══════════════════════════════════════════════════════════════════════════════ Kotlin 服务 ───────────────────────────────────────────────────────────────────────────── 工作台BFF V1 ████████████████ 审核编排V1 ████████████████ 平台接入管理 ████████████ 工作台BFF V2 ████████████ 数据回传服务 ████████ 报表对账服务 ████████████ 通知回调服务 ████████ 平台接入V2(OAuth2) ████████ ═══════════════════════════════════════════════════════════════════════════════ Python 服务 ───────────────────────────────────────────────────────────────────────────── 审核AI管道V1(画面+台词) ████████████████████ 文档生成(PDF证书) ████████ 审核AI管道V2(+声音+真实性) ████████████████████████ 版权链交互层 ████████████████ ═══════════════════════════════════════════════════════════════════════════════ Rust 服务 ───────────────────────────────────────────────────────────────────────────── C2PA SDK V1(Python绑定) ████████████████ 视频指纹提取 ████████████████ C2PA SDK V2(JS/Go绑定) ████████████████ WASM边缘模块(机顶盒) ████████→ ═══════════════════════════════════════════════════════════════════════════════ 区块链 ───────────────────────────────────────────────────────────────────────────── ChainMaker部署+合约V1 ████████████████████████ 版权主链合约 ████████████████ 用户权益合约 ████████████████ 分账清算合约 ████████████████ ═══════════════════════════════════════════════════════════════════════════════ AI 模型 ───────────────────────────────────────────────────────────────────────────── 画面合规模型V1 ████████████████ 台词NLP模型V1 ████████████████ Triton部署+调优 ████████████████ 声音合规模型V1 ████████████████ AIGC真实性模型V1 ████████████████████ 版权指纹+Milvus ████████████████ 模型V2全量迭代 ████→ ═══════════════════════════════════════════════════════════════════════════════ ``` --- ## 六、服务间通信矩阵（附图） ``` ┌───────────────────────────────────────────────────────────────┐ │ 服务间通信方式矩阵 │ ├─────────────────┬──────────┬──────────┬──────────┬───────────┤ │ 调用方 → 被调方 │ 同步REST │ 异步Kafka│ gRPC │ 内部SDK │ ├─────────────────┼──────────┼──────────┼──────────┼───────────┤ │ 工作台BFF(Kt) │ → 赋码(Go)│ │ │ │ │ │ → 审核(Kt)│ │ │ │ │ │ → 清算(Go)│ │ │ │ ├─────────────────┼──────────┼──────────┼──────────┼───────────┤ │ 赋码引擎(Go) │ │ → 审核 │ │ │ │ │ │ → 链服务 │ │ → C2PA(Rust)│ ├─────────────────┼──────────┼──────────┼──────────┼───────────┤ │ 审核编排(Kt) │ → Triton │ │ │ → 指纹(Rust)│ │ │(HTTP/gRPC)│→ 链服务 │ │ │ ├─────────────────┼──────────┼──────────┼──────────┼───────────┤ │ 清算引擎(Go) │ │ → 链服务 │ │ │ │ │ → CH查询 │ │ │ │ ├─────────────────┼──────────┼──────────┼──────────┼───────────┤ │ 链服务(Go) │ │ ← 赋码 │→ ChainMaker│ │ │ │ │ ← 审核 │ (gRPC) │ │ │ │ │ → 确认 │ │ │ ├─────────────────┼──────────┼──────────┼──────────┼───────────┤ │ 数据回传(Kt) │ │ ← 网关 │ │ │ │ │ → CH写入 │ → 清算 │ │ │ ├─────────────────┼──────────┼──────────┼──────────┼───────────┤ │ MA网关(Go) │ → ZIIOT │ → 播放 │ │ │ │ │ ← 平台 │ │ │ │ └─────────────────┴──────────┴──────────┴──────────┴───────────┘ 通信规范： · 同步REST: OpenAPI 3.1 规范 · 超时3s · 重试2次 · 熔断(Resilience4j/Go breaker) · 异步Kafka: Avro/JSON Schema Registry · 幂等消费 · DLQ兜底 · gRPC: Protobuf 3 · 双向流 · 链上事件订阅 · 内部SDK: Rust FFI (CGO/PyO3) · 进程内调用 · 零网络开销 ``` --- ## 七、关键技术决策记录（ADR 摘要，图旁备注） | 决策编号 | 决策 | 理由 | 替代方案 | |---------|------|------|---------| | ADR-001 | Go 作为网关/赋码/清算语言 | 单机万级QPS，编译为静态二进制，容器镜像<20MB | Java(GC暂停)，Rust(开发效率) | | ADR-002 | Kotlin 作为业务中台语言 | Spring生态+协程+空安全，Java团队无缝迁移 | Java 21(虚拟线程)，Go(缺乏Spring生态) | | ADR-003 | Python 专注AI管道 | PyTorch/Triton Client原生支持，模型迭代快 | Kotlin(JVM推理慢)，Go(AI生态弱) | | ADR-004 | Rust 负责C2PA与媒体处理 | c2pa-rs官方实现，零GC大文件处理，安全关键 | Go(无c2pa库)，C++(内存安全) | | ADR-005 | 长安链优先于Fabric | 国密原生支持，国产自主可控，等保三级必要 | Fabric(成熟但国密需额外适配) | | ADR-006 | PostgreSQL 而非 MySQL | JSONB灵活schema，高级索引，PostGIS备用 | MySQL 8(JSONB弱)，TiDB(运维复杂) | | ADR-007 | Kafka 而非 RabbitMQ | 海量播放数据(日亿级)吞吐需求，持久化回溯 | RabbitMQ(吞吐不足)，Pulsar(生态不成熟) | | ADR-008 | Kotlin Coroutines而非WebFlux纯响应式 | 代码可读性远优于Reactor链式，调试友好 | Reactor Mono/Flux(回调地狱)，Vert.x | --- ## 八、性能指标与容量规划（图旁表格） | 指标 | 一期目标 | 二期目标 | 三期目标 | |------|---------|---------|---------| | MA网关解析QPS | 2,000 | 10,000 | 50,000 | | 赋码引擎TPS | 100 | 500 | 2,000 | | AI审核吞吐(部/天) | 500 | 5,000 | 50,000 | | 播放数据写入(条/秒) | 10,000 | 100,000 | 1,000,000 | | 链上TPS | 100 | 500 | 2,000 | | P99延迟(网关解析) | <50ms | <30ms | <20ms | | P99延迟(赋码流程) | <5s | <3s | <1s | | 存储容量 | 50TB | 200TB | 1PB+ | --- ## 九、视觉设计建议 | 元素 | 建议 | |------|------| | 语言色彩编码 | Go=天蓝 · Kotlin=紫色 · Python=金黄 · Rust=橙红 | | 层级色彩 | 接入层-浅灰 · 服务层-白底+语言色块 · 数据层-深灰 · 基础设施-黑色 | | 连线 | 同步调用=实线 · 异步Kafka=虚线+闪电图标 · gRPC=双线 · FFI=波浪线 | | 甘特图配色 | Go任务=天蓝条 · Kotlin任务=紫色条 · Python=金黄 · Rust=橙红 · 基础设施=灰 | | 信息层次 | 架构师看左栏分层 · 开发者看中栏选型 · PM看右栏路线图 | --- > 本文档是面向技术专家的"深度详图"绘制蓝图。 > 与"全景图"的区别：全景图侧重业务+技术平衡，本图100%聚焦技术实现细节。 > Kotlin 作为第四种核心语言加入，承担原方案中 Python 业务编排层与部分 Go 业务服务的职责， > 形成 **Go(网关/计算) + Kotlin(业务中台) + Python(AI) + Rust(底层)** 的四语言协同架构。