4、多Agent通信机制：直接通信、黑板模式、共享内存、消息队列、通信协议设计

多Agent系统里，通信机制是灵魂。你想想看，几个AI Agent一起干活，如果互相不说话，那跟单打独斗有什么区别？我在做量化投资系统时，最头疼的就是Agent之间怎么高效交换信息。今天咱们就把这块掰开揉碎了讲。

4.1 直接通信：点对点的硬连接

直接通信，说白了就是Agent A直接找Agent B说话。这种方式最直观，也最容易实现。

我在早期项目中用过这种方式。两个Agent之间通过Socket或者RPC直接调用。比如，风险监控Agent发现市场异动，直接通知交易Agent暂停下单。

# 伪代码示例：直接通信
class RiskAgent:
    def send_alert(self, trade_agent, message):
        trade_agent.receive_alert(message)

class TradeAgent:
    def receive_alert(self, message):
        if message['type'] == 'pause':
            self.pause_trading()

4.2 黑板模式：共享的公告栏

黑板模式，你可以想象成一个公共公告栏。每个Agent都可以往上面贴消息，也可以从上面读取感兴趣的内容。

我个人习惯用黑板模式做数据聚合。比如，多个数据源Agent把行情数据写到黑板上，策略Agent自己去取。这样谁都不需要知道对方的存在。

# 黑板模式示例
class Blackboard:
    def __init__(self):
        self.data = {}
    
    def write(self, key, value):
        self.data[key] = value
    
    def read(self, key):
        return self.data.get(key)

# Agent A 写数据
blackboard.write('market_data', {'price': 100.5})

# Agent B 读数据
data = blackboard.read('market_data')

4.3 共享内存：最快的通信方式

共享内存，就是多个Agent直接访问同一块内存区域。速度极快，但风险也大。

嗯，这里要注意。共享内存适合高频交易场景。我记得有一次做毫秒级策略，用消息队列延迟太高，换成共享内存后，延迟从微秒级降到了纳秒级。

# 共享内存示例（Python multiprocessing）
from multiprocessing import shared_memory

# 创建共享内存
shm = shared_memory.SharedMemory(name='agent_data', create=True, size=1024)

# Agent A 写入
shm.buf[:4] = b'\x00\x00\x00\x64'  # 写入整数100

# Agent B 读取
value = int.from_bytes(shm.buf[:4], 'little')

4.4 消息队列：异步解耦的利器

消息队列，是目前最主流的通信方式。Agent把消息扔到队列里，其他Agent异步消费。解耦性最好。

我建议用RabbitMQ或者Kafka。RabbitMQ适合小规模系统，Kafka适合大数据量场景。

# 消息队列示例（RabbitMQ）
import pika

# 生产者Agent
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='trade_orders')
channel.basic_publish(exchange='', routing_key='trade_orders', body='buy 100 shares')

# 消费者Agent
def callback(ch, method, properties, body):
    print(f"收到订单: {body}")

channel.basic_consume(queue='trade_orders', on_message_callback=callback, auto_ack=True)

4.5 通信协议设计：规矩要定好

通信协议，就是Agent之间说话的规矩。没有规矩，再好的通信机制也白搭。

我个人习惯用JSON或者Protobuf。JSON简单易读，Protobuf性能好。小项目用JSON，大项目用Protobuf。

// 通信协议示例（JSON格式）
{
  "agent_id": "risk_agent_01",
  "message_type": "alert",
  "timestamp": 1700000000,
  "payload": {
    "alert_type": "volatility_spike",
    "symbol": "BTC/USD",
    "value": 0.15,
    "threshold": 0.10
  }
}

协议要素	说明	我的建议
消息头	包含发送者、类型、时间戳	必须包含，用于追踪
消息体	实际数据内容	尽量扁平化，避免嵌套
校验码	防止数据篡改	建议用HMAC
版本号	协议版本管理	兼容旧版本

4.6 知识体系总览

下面这张图，是我对多Agent通信机制的整体理解。你看一眼就能明白各个机制的关系和适用场景。

这张图把五种通信机制的关系理清楚了。你从中心往外看，每个分支代表一种方式。底部是我根据实战经验给出的选择建议。

好了，这一章的内容就到这里。多Agent通信这块，说白了就是选对工具、定好规矩。你在实际项目中，可以根据系统规模和性能要求灵活组合使用。