Files
MAcode/docs/AIGC-Hub技术选型与实现详图-绘制描述.md
selfrelease a329d4906b init: AIGC-Hub/AVCC 方案文档 + TCS-IPTV 内容可信锁定系统 MVP
- 方案文档: AVCC 体系建设、IPTV TCS 需求(0-req)/PRD(1-prd)/任务(2-task)/二三四期任务
- tcs-iptv: Go 后端(哈希SDK/MA码生成/可信数据空间mock/业务编排/HTTP API+HMAC鉴权)
- web-console: React+AntD 监管大屏(角色工作台/全流程演示/监管片库)
- 一剧一码+集级哈希, 集级下架/恢复, 全栈测试通过
2026-06-14 16:50:31 +08:00

46 KiB
Raw Permalink Blame History

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(测试)+ MockKMock+ 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(底层) 的四语言协同架构。