使用C# EventStore ClientAPI，持久化订阅能否直接获取原始事件数据？

嗨，我之前也碰到过一模一样的情况！其实根本不用额外调用ReadEventAsync，你只需要在创建持久化订阅的时候多配置一个参数，就能直接拿到原始事件数据了。

问题原因 #

你收到的<event_number>@<stream_Id>格式内容是链接事件（Link Event），这种情况大多发生在订阅投影流（比如$all流或者自定义投影流）的时候——这些流里存储的并不是原始事件本身，而是指向原始事件的引用链接。

解决方案：创建订阅时开启ResolveLinkTos #

在使用EventStore的C# ClientAPI创建持久化订阅时，通过PersistentSubscriptionSettings开启ResolveLinkTos选项，EventStore就会自动帮你把链接事件解析成对应的原始事件，直接返回给你。

示例代码如下：

// 1. 配置订阅设置，开启链接事件解析
var subscriptionSettings = PersistentSubscriptionSettings.Create()
    .ResolveLinkTos() // 关键配置：自动解析链接事件为原始事件
    .StartFromBeginning(); // 可根据你的需求调整起始位置

// 2. 创建持久化订阅
var persistentSubscriptionManager = new PersistentSubscriptionManager(_eventStoreConnection);
await persistentSubscriptionManager.CreateAsync(
    streamName: "你的流名称", // 比如$all或者自定义流
    groupName: "你的订阅组名称",
    settings: subscriptionSettings);

注意事项 #

• 如果已经创建了没有开启ResolveLinkTos的订阅，你需要先删除旧订阅，再重新创建带有该配置的订阅——这个参数是订阅创建时确定的，无法动态修改。
• 处理事件时，ResolvedEvent.Event属性现在会直接返回原始事件数据，你可以直接读取Event.Data来获取事件内容，无需额外调用接口。

事件处理的示例代码：

subscription.SubscribeAsync((subscription, resolvedEvent) =>
{
    if (resolvedEvent.Event != null)
    {
        // 直接处理原始事件数据
        var rawEventData = resolvedEvent.Event.Data;
        // 反序列化为你的事件对象等操作
        // var yourEvent = JsonSerializer.Deserialize<YourEventType>(rawEventData);
    }
    return Task.CompletedTask;
}, (subscription, reason, exception) =>
{
    // 这里处理订阅异常
    Console.WriteLine($"订阅出错：{reason}，异常：{exception?.Message}");
    return Task.CompletedTask;
});

内容的提问来源于stack exchange，提问作者robs