工业级生成式 AI 微服务平台

基于 Go 1.24+LangChainGopgvector 构建。 集成 Saga 分布式事务与 JWE 金融级安全标准。

DDD 架构模式
Saga 分布式事务
RAG 知识增强

核心架构拓扑

点击下方各组件查看详细职责与技术栈。系统采用分层设计,通过 gRPC 实现内部高速通信。

接入与安全层 (Access Layer)

API Gateway
Gin + gRPC-Gateway
Auth Service
JWE + Redis Session

核心微服务群 (Core Services)

User
Entitlement
Billing
Flow (Saga)
Creation (AI Engine)
Notification
Admin

基础设施层 (Infrastructure)

Consul
PostgreSQL
Redis
RabbitMQ

请选择组件

点击左侧架构图中的任意节点,查看该服务的核心职责、技术栈细节及关键业务逻辑。

Technology Stack

N/A

Key Patterns

  • 等待选择...
Exonflow-AI Architecture Explorer

AI 创作链路与 RAG 架构

基于 LangChainGo 编排的检索增强生成 (Retrieval-Augmented Generation) 流程。

Step 1: Input
用户提问

包含上下文的自然语言输入

Step 2: Embedding
向量化

Text → Vector [0.12, -0.4...]

Step 3: Retrieval
pgvector 检索

ANN Search 获取 Top-K 文档

Step 4: Generate
LLM 生成

Context + Prompt → Token Stream

# 准备就绪,点击上方按钮开始 RAG 流程演示...

Saga 分布式事务模拟

AI 业务必须解决“先付费后服务”与“服务可能失败”的矛盾。Exonflow-AI 使用 Saga 模式编排跨服务事务:

  • 1 预估冻结 (Freeze): Billing 服务根据 Prompt 长度预估费用并冻结额度。
  • 2 执行生成 (Action): Creation 服务调用 AI 模型,若失败则触发补偿。
  • 3 实扣确认 (Confirm): 根据实际 Token 消耗进行多退少补。

控制台

用户余额: 1000 Credits 冻结: 0
S
Flow Service
Saga 状态机启动 (Pending)
B
Billing Service
Try: 冻结额度 (TCC)
C
Creation Service
Action: AI 生成
E
Final State
等待事务结果...

实时业务监控 (模拟)

System Healthy
QPS
1,245
Token Cost
$42.8/h
Avg Latency
240ms

DDD 代码结构分层

每个微服务严格遵循以下四层架构,确保业务逻辑纯净。

1. Interfaces Layer (接口层)
  • api/proto: Protocol Buffers 定义
  • dto/: Data Transfer Objects
  • handler/: HTTP/gRPC 入口逻辑
2. Application Layer (应用层)
  • service/: 用例编排 (Use Cases)
  • cqrs/: Command & Query 分离
  • 不包含核心业务逻辑,只做协调
3. Domain Layer (领域层 - 核心)

业务资产 (Pure Go)

  • aggregate/: 聚合根 (充血模型)
  • entity/: 实体与值对象
  • repository/: 仓储接口定义 (依赖倒置)
4. Infrastructure Layer (基础设施层)
  • persistence/: GORM/Postgres 实现
  • cache/: Redis 客户端封装
  • mq/: RabbitMQ Publisher/Consumer