C# Agent 入门指南：从零构建你的第一个智能代理

1次阅读

共计 2353 个字符，预计需要花费 6 分钟才能阅读完成。

C# Agent 是一种基于消息传递的轻量级并发模型，它封装了内部状态和行为，通过异步消息与其他组件交互。想象它是一个独立的数字员工，比如：

自动化客服：接收用户问题→调用知识库→返回答案
数据清洗管道：监听文件变动→格式化内容→写入数据库
游戏 NPC 控制器：感知环境→决策行动→更新状态

运行时：.NET 6+（推荐 LTS 版本）
IDE：Visual Studio 2022（社区版免费）或 Rider
NuGet 包：
Microsoft.Extensions.Hosting（生命周期管理）
System.Threading.Channels（高效消息队列）

// 基础 Agent 骨架
public abstract class Agent<TMessage>
{private readonly Channel<TMessage> _mailbox = Channel.CreateUnbounded<TMessage>();
    protected CancellationTokenSource _cts = new();

    // 核心消息处理循环
    public async Task RunAsync()
    {await foreach (var msg in _mailbox.Reader.ReadAllAsync(_cts.Token))
        {try { await HandleMessageAsync(msg); }
            catch (Exception ex) {LogError(ex); }
        }
    }

    // 外部发送消息入口
    public bool Post(TMessage msg) => _mailbox.Writer.TryWrite(msg);

    protected abstract Task HandleMessageAsync(TMessage msg);
    protected virtual void LogError(Exception ex) => Console.WriteLine($"[ERR] {ex.Message}");
}

典型用例——温度监控 Agent：

public class TemperatureMonitor : Agent<float>
{
    private float _currentTemp;
    private readonly float _alertThreshold;

    public TemperatureMonitor(float threshold) => _alertThreshold = threshold;

    protected override async Task HandleMessageAsync(float newTemp)
    {
        _currentTemp = newTemp;
        if (_currentTemp > _alertThreshold)
        {await AlertCoolingSystemAsync();
            Console.WriteLine($"⚠️ 温度警报: {_currentTemp}°C");
        }
    }

    private Task AlertCoolingSystemAsync() => Task.Delay(100); // 模拟调用外部系统
}

sequenceDiagram
    participant Sender
    participant Agent
    Sender->>Agent: Post(msg1)
    Sender->>Agent: Post(msg2)
    Note right of Agent: 消息按到达顺序
    Agent->>Agent: 串行处理 msg1
    Agent->>Agent: 串行处理 msg2

使用 Channel 的SingleWriter模式保证线程安全：

private readonly Channel<TMessage> _mailbox = Channel.CreateSingleWriterUnbounded<TMessage>();

方案一：快照模式

public async Task SaveStateAsync()
{
    var snapshot = new AgentSnapshot 
    { 
        CurrentTemp = _currentTemp,
        LastUpdated = DateTime.UtcNow
    };
    await File.WriteAllTextAsync("state.json", JsonSerializer.Serialize(snapshot));
}

方案二：事件溯源

private readonly List<IEvent> _eventLog = new();

protected override Task HandleMessageAsync(TMessage msg)
{var @event = CreateEvent(msg);
    _eventLog.Add(@event);
    ApplyEvent(@event);
}