Agent-Comm-Hub
どのような問題を解決しますか?
複数のAIエージェント(Claude Code、OpenClaw、WorkBuddy、カスタムエージェントなど)を実行する場合、それらはサイロ化して動作します。そのため、以下のようなことができません:
壊れやすいWebhookや共有データベースなしで相互に通信する
エージェントの境界を越えてタスクをスケジュールする
ワンショットプロンプトを超えてコンテキストを共有する
過去の経験に基づいてチームとして共に進化する
Agent Communication Hubは、すべてのMCP互換エージェントに共通の神経系(メッセージバス、タスクキュー、メモリレイヤー、進化エンジン)を提供し、エージェントが孤立するのではなく協力できるようにします。
3行で試す
# 1. Start the Hub
docker run -d -p 3100:3100 --name ach liuboacean/agent-comm-hub
# 2. Register an agent
python3 -c "from hub_client import SynergyHubClient; print(SynergyHubClient('http://localhost:3100').register('YOUR_INVITE_CODE'))"
# 3. Send a message
python3 -c "from hub_client import SynergyHubClient; c=SynergyHubClient('http://localhost:3100'); c.set_token('YOUR_TOKEN'); c.send_message(to='other-agent', content='Hello!')"設定ファイルは不要。外部サービスも不要。ローカルで動作します。
特徴の概要
カテゴリ | ツール数 | 機能 |
ID管理 | 6 | エージェント登録、ハートビート、RBACロール、信頼スコアリング |
メッセージング | 5 | P2P / ブロードキャスト、FTS5検索、重複排除 |
タスクスケジューリング | 8 | 7状態マシン、パイプライン、並列グループ、自動リトライ |
メモリ | 5 | プライベート / チーム / 全体スコープ、エッジ関数スコアリング |
オーケストレーション | 11 | 依存関係チェーン(DFSサイクル検出)、品質ゲート、ハンドオーバープロトコル |
進化 | 12 | 経験共有、4段階の戦略承認、信頼スコアフィードバックループ |
セキュリティ | 6 | トークン認証、4レベルRBAC、監査ハッシュチェーン、CORSホワイトリスト |
ファイル | 3 | アップロード / ダウンロード / リスト、最大10MBのBase64 |
53個のMCPツール · SQLite WAL(メッセージ損失ゼロ) · SSEプッシュ遅延 < 50ms
アーキテクチャ
┌──────────────┐ ┌──────────────────────────┐ ┌──────────────┐
│ Agent A │ SSE │ Agent Communication │ SSE │ Agent B │
│ (Claude Code)│◄────────►│ Hub v2.4 │◄────────►│ (WorkBuddy) │
│ │ MCP │ localhost:3100 │ MCP │ │
└──────────────┘◄─────────►│ │◄─────────►└──────────────┘
│ ┌────────────────────┐ │
│ │ Identity / RBAC │ │
│ │ Message / Broadcast │ │
│ │ Task Scheduler │ │
│ │ Memory (3 scopes) │ │
│ │ Evolution Engine │ │
│ │ Orchestrator │ │
│ └──────────┬───────────┘ │
└─────────────┼──────────────┘
│
SQLite (WAL)Claude Code、OpenClaw、WorkBuddy、Hermes、カスタムエージェントなど、MCP互換エージェントであれば何でも接続可能です。
SDKの例
Python — 依存関係ゼロ
from hub_client import SynergyHubClient
hub = SynergyHubClient(hub_url="http://localhost:3100", agent_id="my-agent")
hub.set_token("your-api-token")
# Send a message
hub.send_message(to="workbuddy", content="Task completed, handing over.")
# Store shared memory
hub.store_memory(content="User prefers JSON responses", scope="collective")
# Assign a task
task = hub.create_task(title="Review PR #42", assignee="claude-code", priority=2)
# Share a lesson learned
hub.share_experience(title="DB lock timeout fix", content="...", category="debug")
# Stream incoming events
hub.on_message = lambda msg: print(f"Received: {msg}")
hub.connect_sse() # blocks — long-lived SSE connectionTypeScript — こちらも外部依存関係ゼロ
import { AgentClient } from "./client-sdk/agent-client.js";
const client = new AgentClient({
agentId: "my-agent",
hubUrl: "http://localhost:3100",
token: "your-api-token",
onMessage: async (msg) => { /* handle */ },
onTaskAssigned: async (task) => { /* handle */ },
});
await client.start();
await client.sendMessage({ to: "workbuddy", content: "Done!" });デプロイメント
Docker (推奨)
docker run -d -p 3100:3100 --name ach liuboacean/agent-comm-hubDocker Compose (Prometheus + Grafanaを含む)
cd deploy && docker compose up -d
# Hub: http://localhost:3100
# Grafana: http://localhost:3000 (admin/admin)
# Prometheus: http://localhost:9090ソースからビルド
git clone https://github.com/liuboacean/agent-comm-hub.git
cd agent-comm-hub
npm install && npm run build
npm startスキルとして追加
# ClawHub
clawhub install liuboacean/agent-comm-hub
# SkillHub (30+ platforms)
npx skills add liuboacean/agent-comm-hubMCP設定
Hubを起動した後、エージェントのMCP設定に追加してください:
オプション1: stdio (推奨)
{
"mcpServers": {
"agent-comm-hub": {
"command": "node",
"args": ["<hub-install-path>/stdio.js"],
"env": {
"HUB_KEY": "your-connection-key"
}
}
}
}オプション2: HTTP + SSE
{
"mcpServers": {
"agent-comm-hub": {
"url": "http://localhost:3100/mcp"
}
}
}エージェントのLLMは、自然言語を通じて53個のツールすべてを直接呼び出すことができます。
セキュリティ
機能 | 詳細 |
RBAC | 4レベル: public → member → group_admin → admin |
トークン認証 | SHA-256エージェントトークン、DBにハッシュとして保存 |
監査ハッシュチェーン | DBトリガーによる |
信頼スコアリング | 自動計算され、戦略承認ティアに影響 |
CORS | ホワイトリストのみ、デフォルトで拒否 |
セキュリティヘッダー | X-Frame-Options, CSP, HSTS, X-XSS-Protection |
リクエスト追跡 | すべてのリクエストとレスポンスヘッダーにtraceIdを付与 |
ファイル構造
agent-comm-hub/
├── src/ # Hub server source (TypeScript)
│ ├── server.ts # Express + SSE + MCP entry point
│ ├── db.ts # SQLite WAL schema + queries
│ ├── identity.ts # Registration, heartbeat, RBAC
│ ├── memory.ts # 3-scope memory with FTS5
│ ├── task.ts # 7-state task scheduler
│ ├── orchestrator.ts # Dependency chains, pipelines
│ ├── evolution.ts # Strategy engine, trust scoring
│ └── security.ts # Auth, token, RBAC, audit
├── client-sdk/
│ ├── hub_client.py # Python SDK (zero deps, 68 methods)
│ └── agent-client.ts # TypeScript SDK (35 public methods)
├── deploy/
│ ├── docker-compose.yml # Prometheus + Grafana observability
│ └── prometheus.yml # Metrics scraping config
├── docs/
│ ├── API_REFERENCE.md # 53 tools complete reference
│ ├── advanced-orchestration-guide.md
│ ├── evolution-engine-guide.md
│ └── hermes-integration-guide.md
├── scripts/
│ ├── install.sh # Hub server install script
│ └── test-e2e.sh # End-to-end test suite
└── tests/ # Integration + unit testsドキュメント
ドキュメント | 読むタイミング |
すべてのツールのシグネチャと例 | |
パイプライン、並列グループ、品質ゲート | |
信頼スコアリング、戦略承認ワークフロー | |
Hermesエージェントのステップバイステップ設定 | |
このページ |
ライセンス
MIT — 個人プロジェクトおよび商用プロジェクトで自由に使用できます。
Latest Blog Posts
MCP directory API
We provide all the information about MCP servers via our MCP API.
curl -X GET 'https://glama.ai/api/mcp/v1/servers/liuboacean/agent-comm-hub'
If you have feedback or need assistance with the MCP directory API, please join our Discord server