hexagon

Go AI Agent 框架

📖 项目简介

Hexagon 取名自网络热词「六边形战士」，表达对多项框架能力均衡发展的关注。

项目围绕 易用性、并发执行、扩展性、任务编排、可观测性、安全性 六个维度，为 Go 开发者提供构建 AI Agent 的框架组件。

🚀 核心特性

• ⚡ 并发执行 │ 基于 Go 和 goroutine 实现并发任务处理
• 🧩 简洁 API │ 提供便捷入口、声明式选项和明确的组件接口
• 🛡️ 安全组件 │ 提供 Guard、Guardrail、RBAC 和 Sandbox 等可组合组件
• 🔧 扩展机制 │ 提供插件接口和中间件扩展点
• 🛠️ 任务编排 │ 提供 Graph、Chain、Workflow 和 Planner 模块
• 🔍 可观测性 │ 提供 OpenTelemetry 追踪、指标、事件流和 Dev UI 集成

🌐 生态系统

Hexagon 与以下 AI Agent 开发相关仓库协同使用：

当前根模块构建基线：Go 1.25.12、ai-core v0.2.10、toolkit v0.3.4。examples/ 是独立 Go module，其依赖版本以 examples/go.mod 为准，不随根模块自动同步。

🧠 ai-core — AI 基础能力库

提供 LLM、Tool、Memory、Schema 等核心抽象，支持多种 LLM Provider：

import "github.com/hexagon-codes/ai-core/llm"
import "github.com/hexagon-codes/ai-core/llm/openai"
import "github.com/hexagon-codes/ai-core/tool"
import "github.com/hexagon-codes/ai-core/memory"

主要模块：

• llm/ - LLM Provider 接口 + 实现 (OpenAI, DeepSeek, Anthropic, Gemini, 通义, 豆包, Ollama)
• llm/router/ - 智能模型路由 (任务感知 + 模型能力档案)
• tool/ - 工具系统，支持函数式定义
• memory/ - 记忆系统，支持向量存储
• schema/ - JSON Schema 自动生成
• streamx/ - 流式响应处理
• template/ - Prompt 模板引擎

🛠️ toolkit — Go 通用工具库

Go 通用工具包，提供语言增强、加密、网络、缓存、协程池等基础能力：

import "github.com/hexagon-codes/toolkit/lang/conv"      // 类型转换
import "github.com/hexagon-codes/toolkit/lang/stringx"   // 字符串工具
import "github.com/hexagon-codes/toolkit/lang/syncx"     // 并发工具
import "github.com/hexagon-codes/toolkit/net/httpx"      // HTTP 客户端
import "github.com/hexagon-codes/toolkit/net/sse"        // SSE 客户端
import "github.com/hexagon-codes/toolkit/util/retry"     // 重试机制
import "github.com/hexagon-codes/toolkit/util/idgen"     // ID 生成
import "github.com/hexagon-codes/toolkit/util/poolx"     // 协程池
import "github.com/hexagon-codes/toolkit/cache/local"    // 本地缓存

主要模块：

• lang/ - 语言增强 (conv, stringx, slicex, mapx, timex, contextx, errorx, syncx)
• crypto/ - 加密 (aes, rsa, sign)
• net/ - 网络 (httpx, sse, ip)
• cache/ - 缓存 (local, redis, multi)
• util/ - 工具 (retry, rate, idgen, logger, validator, poolx 协程池)
• collection/ - 数据结构 (set, list, queue, stack)

🎨 hexagon-ui — Dev UI 前端

基于 Vue 3 + TypeScript 的开发调试界面：

cd hexagon-ui
npm install
npm run dev
# 访问 http://localhost:5173

功能特性：

• 实时事件流 (SSE 推送)
• 指标仪表板
• 事件详情查看
• LLM 流式输出展示

⚡ 快速开始

📦 安装

go get github.com/hexagon-codes/hexagon

⚙️ 环境配置

# OpenAI
export OPENAI_API_KEY=your-api-key

# 或 DeepSeek
export DEEPSEEK_API_KEY=your-api-key

🎯 基础示例

package main

import (
    "context"
    "fmt"
    "github.com/hexagon-codes/hexagon"
)

func main() {
    response, _ := hexagon.Chat(context.Background(), "What is Go?")
    fmt.Println(response)
}

🔧 带工具的 Agent

package main

import (
    "context"
    "fmt"
    "github.com/hexagon-codes/hexagon"
)

func main() {
    // 定义计算器工具
    type CalcInput struct {
        A  float64 `json:"a" desc:"第一个数字" required:"true"`
        B  float64 `json:"b" desc:"第二个数字" required:"true"`
        Op string  `json:"op" desc:"运算符" required:"true" enum:"add,sub,mul,div"`
    }

    calculator := hexagon.NewTool("calculator", "执行数学计算",
        func(ctx context.Context, input CalcInput) (float64, error) {
            switch input.Op {
            case "add": return input.A + input.B, nil
            case "sub": return input.A - input.B, nil
            case "mul": return input.A * input.B, nil
            case "div": return input.A / input.B, nil
            }
            return 0, fmt.Errorf("unknown operator")
        },
    )

    // 创建带工具的 Agent
    agent := hexagon.QuickStart(
        hexagon.WithTools(calculator),
        hexagon.WithSystemPrompt("你是一个数学助手"),
    )

    output, _ := agent.Run(context.Background(), hexagon.Input{
        Query: "计算 123 * 456",
    })
    fmt.Println(output.Content)
}

🔍 RAG 检索增强

// 创建 RAG 引擎
engine := hexagon.NewRAGEngine(
    hexagon.WithRAGStore(hexagon.NewMemoryVectorStore()),
    hexagon.WithRAGEmbedder(hexagon.NewOpenAIEmbedder()),
)

// 索引文档
engine.Index(ctx, []hexagon.Document{
    {ID: "1", Content: "Go 支持并发编程"},
    {ID: "2", Content: "Go 有丰富的标准库"},
})

// 检索
docs, _ := engine.Retrieve(ctx, "Go 的特性", hexagon.WithTopK(2))

📊 图编排

import "github.com/hexagon-codes/hexagon/orchestration/graph"

// 构建工作流图
g, _ := graph.NewGraph[MyState]("workflow").
    AddNode("analyze", analyzeHandler).
    AddNode("process", processHandler).
    AddEdge(graph.START, "analyze").
    AddEdge("analyze", "process").
    AddEdge("process", graph.END).
    Build()

// 执行
result, _ := g.Run(ctx, initialState)

👥 多 Agent 团队

// 创建团队
team := hexagon.NewTeam("research-team",
    hexagon.WithAgents(researcher, writer, reviewer),
    hexagon.WithMode(hexagon.TeamModeSequential),
)

// 执行
output, _ := team.Run(ctx, hexagon.Input{Query: "写一篇技术文章"})

🚀 高级能力

🔀 智能模型路由 (Smart Router)

根据任务类型、复杂度自动选择最优模型：

import "github.com/hexagon-codes/ai-core/llm/router"

// 创建智能路由器
smartRouter := router.NewSmartRouter(baseRouter,
    router.WithAutoClassify(true),
)

// 带路由上下文的请求
routingCtx := router.NewRoutingContext(router.TaskTypeCoding, router.ComplexityMedium).
    WithPriority(router.PriorityQuality).
    RequireFunctions()

resp, decision, _ := smartRouter.CompleteWithRouting(ctx, req, routingCtx)
// decision 包含: 选择的模型、得分、原因、备选方案

特性：

• 任务感知路由 (coding/reasoning/creative/analysis 等)
• 质量/成本/延迟优先级策略
• 20+ 预定义模型能力档案
• 路由历史和统计分析

♻️ 持久化运行时 (Durable Runtime)

统一的 Agent 执行运行时，支持 per-tool exactly-once 快照与中断恢复（Resume）：

import (
    "github.com/hexagon-codes/hexagon/runtime"
    "github.com/hexagon-codes/hexagon/checkpoint"
)

// 基于 Checkpointer 的持久化执行：崩溃/中断后 Resume 不重复执行已完成的工具
durable := runtime.NewDurableExecution(checkpoint.NewMemory())

特性：

• per-tool exactly-once：已完成工具调用入快照，Resume 不重放
• 统一 Runner + 执行策略（ReAct / PlanExecute / Reflection 共用同一运行时）
• 三维 Budget（token/调用/时长）+ CostControl 统一抽象
• 五级 PermissionMode 与 Context Compaction 中间件 (runtime/middleware)
• 长任务进度事件 + SSE 事件 sink

🧬 Agent 即工具 (AgentTool)

将一个 Agent 直接包装为工具，作为另一 Agent 的子能力组合：

import "github.com/hexagon-codes/hexagon/agent"

// 把 researcher Agent 暴露为可被 supervisor 调用的工具
researcherTool := agent.NewAgentTool(researcher,
    agent.WithAgentToolName("research"),
    agent.WithAgentToolDescription("调研指定主题并返回要点"),
)

supervisor := hexagon.QuickStart(
    hexagon.WithTools(researcherTool),
    hexagon.WithSystemPrompt("你是一个调度者，按需调用子 Agent"),
)

🧾 原生结构化输出 (Structured Output)

借助 Provider 原生 json_schema 强制解码为强类型 Go 结构体：

import "github.com/hexagon-codes/hexagon/llm/structured"

type Invoice struct {
    Number string  `json:"number"`
    Amount float64 `json:"amount"`
}

inv, _ := structured.Generate[Invoice](ctx, provider, "解析这张发票：...",
    structured.WithNativeJSONSchema("invoice"),
    structured.WithStrictMode(true),
)

📄 智能文档工作流 (ADW)

超越传统 RAG 的端到端文档自动化：

import "github.com/hexagon-codes/hexagon/rag/adw"
import "github.com/hexagon-codes/hexagon/rag/adw/extractor"
import "github.com/hexagon-codes/hexagon/rag/adw/validator"

// 定义提取 Schema
schema := adw.NewExtractionSchema("invoice").
    AddStringField("invoice_number", "发票号码", true).
    AddDateField("date", "日期", "YYYY-MM-DD", true).
    AddMoneyField("amount", "金额", true).
    AddStringField("vendor", "供应商", false)

// 创建处理管道
pipeline := adw.NewPipeline("invoice-processing").
    AddStep(adw.NewDocumentTypeDetectorStep()).
    AddStep(extractor.NewLLMExtractionStep(llmProvider, schema)).
    AddStep(extractor.NewEntityExtractionStep(llmProvider)).
    AddStep(validator.NewSchemaValidationStep(schema)).
    AddStep(adw.NewConfidenceCalculatorStep()).
    Build()

// 处理文档
output, _ := pipeline.Process(ctx, adw.PipelineInput{
    Documents: documents,
    Schema:    schema,
})

// 访问结果
for _, doc := range output.Documents {
    fmt.Println("发票号:", doc.StructuredData["invoice_number"])
    fmt.Println("实体:", doc.Entities)
    fmt.Println("验证:", doc.IsValid())
}

特性：

• Document 扩展：结构化数据/表格/实体/关系/验证错误
• Schema 驱动的结构化提取
• LLM 提取器：实体/关系提取
• 验证规则：类型/格式/范围/枚举/正则
• 并发处理 + 钩子系统

🌐 A2A 协议 (Agent-to-Agent)

实现 Google A2A 协议，支持标准化的 Agent 间通信：

import "github.com/hexagon-codes/hexagon/agent/a2a"

// 将 Hexagon Agent 暴露为 A2A 服务
server := a2a.ExposeAgent(myAgent, "http://localhost:8080")
server.Start(":8080")

// 连接远程 A2A Agent
client := a2a.NewClient("http://remote-agent.example.com")
card, _ := client.GetAgentCard(ctx)

// 发送消息
task, _ := client.SendMessage(ctx, &a2a.SendMessageRequest{
    Message: a2a.NewUserMessage("你好"),
})

// 流式交互
events, _ := client.SendMessageStream(ctx, req)
for event := range events {
    switch e := event.(type) {
    case *a2a.ArtifactEvent:
        fmt.Print(e.Artifact.GetTextContent())
    }
}

特性：

• A2A 数据模型 (AgentCard/Task/Message/Artifact)
• JSON-RPC 2.0 + SSE 流式响应
• 多种认证方式 (Bearer Token/API Key/Basic Auth/RBAC)
• Agent 发现服务 (Registry/Static/Remote)
• 推送通知支持
• Hexagon Agent 桥接适配

💡 设计理念

1. 渐进式复杂度 - 提供便捷入口、声明式配置和图编排 API
2. 约定优于配置 - 提供默认值，同时保留显式配置选项
3. 组合优于继承 - 小而专注的组件，灵活组合
4. 显式优于隐式 - 类型安全，编译时检查
5. 运行支持 - 提供可观测性和降级相关组件

🏗️ 架构

📐 整体架构

🔗 生态系统依赖

📈 数据流

🤖 LLM 支持

📁 项目结构

hexagon/
├── agent/              # Agent 核心 (ReAct/Role/Team/Handoff/State/Primitives/AgentTool/Supervisor)
│   ├── a2a/            # A2A 协议 (Client/Server/Handler/Discovery)
│   ├── artifact/       # 工件系统
│   ├── semantic/       # 语义能力
│   └── skill/          # 技能注册与签名
├── core/               # 统一接口 (Component/Runnable, Stream[T], Compose/Fallback)
├── runtime/            # 统一执行运行时 (Runner/DurableExecution/策略/中间件)
│   ├── middleware/     # Budget/CostControl/Compaction/PermissionMode
│   └── strategy/       # 执行策略 (ReAct/PlanExecute/Reflection)
├── orchestration/      # 编排引擎
│   ├── graph/          # 图编排 (状态图/检查点/Barrier/分布式/可视化)
│   ├── chain/          # 链式编排 (Compile 期 I/O 类型校验)
│   ├── workflow/       # 工作流引擎
│   └── planner/        # 规划器
├── checkpoint/         # 统一 Checkpointer 持久化
├── interrupt/          # 中断恢复
├── rag/                # RAG 系统
│   ├── loader/         # 文档加载 + Parser 层 (Text/MD/CSV/XLSX/PPTX/DOCX/PDF/OCR)
│   ├── splitter/       # 文档分割 (Character/Recursive/Markdown/Sentence/Token/Code)
│   ├── retriever/      # 检索器 (Vector/Keyword/Hybrid/HyDE/Adaptive/ParentDoc)
│   ├── reranker/       # 重排序
│   ├── synthesizer/    # 响应合成
│   ├── adw/            # 智能文档工作流 (extractor/validator)
│   ├── agentic/        # Agentic RAG
│   ├── corrective/     # 纠错式 RAG
│   ├── selfrag/        # Self-RAG
│   └── multimodal/     # 多模态
├── llm/                # LLM 编排层
│   ├── structured/     # 原生 json_schema 结构化输出
│   ├── batch/          # 批量调用
│   ├── conversation/   # 会话管理
│   ├── parser/         # 输出解析
│   └── template/       # Prompt 模板
├── memory/store/       # 多 Agent 记忆存储 (InMemory/File/Redis/Persistent)
├── mcp/                # MCP 协议 (动态发现/自动重连/多传输)
├── hooks/              # 钩子系统 (Run/Tool/LLM/Retriever)
├── observe/            # 可观测性 (Tracer/Metrics/OTel/Langfuse/DevUI/Replay)
├── security/           # 安全防护 (Guard/Guardrails/RBAC/Cost/Audit/Filter/PII/Tenant/Credential)
├── tool/               # 工具系统 (File/Python/Shell/Sandbox/HTTP/Search/DB/Browser...)
├── store/              # 存储
│   └── vector/         # 向量存储 (FAISS/PgVector/Redis/Milvus/Chroma/Pinecone/Weaviate)
├── client/             # 客户端
├── plugin/             # 插件系统
├── config/             # 配置管理
├── evaluate/           # 评估系统 (agenteval/rag/metrics)
├── testing/            # 测试工具 (Mock/Record/E2E/Integration)
├── .github/workflows/  # 根模块 CI（质量检查/双版本测试/race/漏洞扫描）
├── deploy/             # 部署配置 (Docker Compose/Helm Chart)
├── examples/           # 示例代码 (独立 module)
├── hexagon.go          # 顶层 API（核心入口符号）
└── deprecated.go       # 过渡性重导出（下一大版本移除）

⚠️ 近期重要变更

架构重构（v0.5.0）

v0.5.0 进行了一次结构性收敛，并升级到 ai-core v0.1.4 / toolkit v0.1.0（Go 1.25）：

• 顶层 feature 包归组：a2a → agent/a2a、artifact → agent/artifact、semantic → agent/semantic、skill → agent/skill、adw → rag/adw。
• 编排正统化：以 orchestration/graph 为编排正统轴，裁剪冗余的 compose / process / flow 包。
• 持久化收敛：统一为单一 Checkpointer（checkpoint/）。
• 下沉去重：stream 下沉 ai-core/streamx、媒体下沉 ai-core/media、安全/沙箱/blobstore 下沉 toolkit；Schema 统一走 ai-core/schema（core.Schema 为类型别名）。
• 新增能力：统一 runtime（DurableExecution per-tool exactly-once + Resume、Budget/CostControl、五级 PermissionMode、Context Compaction）、agent.AgentTool、MCP 自动重连、observe/otel 的 Langfuse 导出、orchestration/chain 的 Compile 期类型校验、rag/loader Parser 层、llm/structured 原生 json_schema。
• examples 独立 module：go get github.com/hexagon-codes/hexagon 不再拉入示例依赖图。

迁移期保留 deprecated.go 作为顶层重导出 shim，将在下一大版本移除。

顶层 API 瘦身（v0.3.2-beta）

hexagon.go 的导出符号从 98 个精简至 18 个核心符号，仅保留最常用的入口：

• Chat(), ChatWithTools(), Run() — 便捷函数
• QuickStart() 及选项函数 (WithProvider, WithTools, WithSystemPrompt, WithMemory)
• NewTool() — 工具创建
• SetDefaultProvider() — 设置默认 LLM Provider
• 核心类型重导出 (Input, Output, Tool, Memory, Message, Agent, Provider)
• Version 常量

其余所有导出均已移至 deprecated.go，附带弃用注释，将在下一个大版本中移除。

迁移方式： 直接 import 对应子包，而非通过顶层包访问。例如：

// 旧方式（已弃用）
team := hexagon.NewTeam("my-team", hexagon.WithAgents(a1, a2))
engine := hexagon.NewRAGEngine(hexagon.WithRAGStore(store))

// 新方式（推荐）
import "github.com/hexagon-codes/hexagon/agent"
import "github.com/hexagon-codes/hexagon/rag"

team := agent.NewTeam("my-team", agent.WithAgents(a1, a2))
engine := rag.NewEngine(rag.WithStore(store))

Bug 修复与改进

• RunWithStats 并发安全 — 使用本地节点副本，消除多 goroutine 间的数据竞争
• ParallelForEachLoopNode 不再死锁 — 修复 context 取消时的死锁问题
• RecursiveSplitter 防无限循环 — 当 overlap >= chunkSize 时自动保护
• SetDefaultProvider 时序修复 — 即使在 Chat()/QuickStart() 之前调用也会被正确使用

📚 文档

📄 核心文档

📖 使用指南

💻 示例代码

🖥️ Dev UI

内置开发调试界面，实时查看 Agent 执行过程。

以下示例仅监听本机回环地址，并显式处理 Start 和 Stop 返回的错误：

import (
    "context"
    "log"
    "time"

    "github.com/hexagon-codes/hexagon/observe/devui"
)

// 创建 DevUI
ui := devui.New(
    devui.WithAddr("127.0.0.1:8080"),
    devui.WithMaxEvents(1000),
)

// 启动服务
go func() {
    if err := ui.Start(); err != nil {
        log.Printf("DevUI stopped with error: %v", err)
    }
}()

// 在所属服务退出时停止 DevUI
defer func() {
    ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    defer cancel()
    if err := ui.Stop(ctx); err != nil {
        log.Printf("Failed to stop DevUI: %v", err)
    }
}()

// 访问 http://127.0.0.1:8080

运行示例：

# 按 examples 独立模块的依赖启动后端
(cd examples && GOWORK=off go run ./devui)

# 在另一个终端启动外部 hexagon-ui 仓库
cd ../hexagon-ui
npm install
npm run dev
# 访问 http://localhost:5173

🚢 部署

Hexagon 是 Go 库，不包含可直接运行的应用入口或官方应用镜像。deploy/ 提供开发基础设施和自定义应用镜像的 Kubernetes 接入模板，不是一键部署成品应用。

Docker Compose 开发基础设施

Compose 仅启动 Qdrant、Redis 和 PostgreSQL，不会启动 Hexagon 应用或 Dev UI：

cd deploy
cp .env.example .env
docker compose up -d

Helm 自定义镜像接入模板

Helm Chart 用于接入你自行构建的应用镜像。先设置镜像并检查渲染结果，再根据应用实际命令、探针和配置调整模板：

cd deploy
helm template hexagon helm/hexagon/ \
  --set app.image.repository=registry.example.com/your-app \
  --set app.image.tag=your-tag \
  --set devui.enabled=false

详见 部署指南。

🔨 开发

make build   # 构建
make test    # 测试
make lint    # 代码检查
make fmt     # 格式化

CI 与发布

• 推送到 main 和提交 Pull Request 时，单一 CI 在 Go 1.25.12 下执行格式、依赖一致性、go vet、普通测试和 govulncheck，并在 Go 1.26.5 下补充一次 race 测试。
• 本仓没有自动发布工作流；维护者只在目标提交的 CI 成功后创建不可变 SemVer tag，Go 模块以该 tag 发布。
• examples/ 是独立 module，不在根模块 ./... 的测试范围内；修改示例时应以 examples/go.mod 为基线单独验证。

🤝 贡献

欢迎贡献！请阅读 CONTRIBUTING.md 了解如何参与。

📜 许可证

Apache License 2.0

Copyright 2026 hexagon-codes

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

    http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.