如何将EventStore流中的数据解析回正确的类型

本文关键字：类型 数据 EventStore | 更新日期: 2023-09-27 18:25:28

我将事件数据存储在EventStore:中

var data = new EventData(Guid.NewGuid(),
                         @event.GetType().ToString(),
                         true,
                         @event.ToJsonBytes(), 
                         @event.GetType().ToJsonBytes());
this.connection.AppendToStreamAsync(this.stream + "/" + aggregateId, 
                                    ExpectedVersion.Any, data);

似乎有效。但是如何在不给出具体类型的情况下解析回EventStore中的数据呢？

我尝试了这种方法，但这只解析基类的数据：

foreach (var data in result.Events)
{
   var @event = data.Event.Data.ParseJson<Event>();
   if (@event != null) // event contains only the base type data
   {
      events.Add(@event);
   }
}

如何获取从Event派生的SomeSpecialEvent的数据？有几种事件类型，我不能把它们都放在这里（存储机制应该不知道具体的类型）。

如何将T放入的任何想法。ParseJson而不使用泛型？

如何将EventStore流中的数据解析回正确的类型

自己找到了一个解决方案：

        var result = this.connection.ReadStreamEventsForwardAsync(this.stream + "/" + aggregateId, 0, 4095, false).Result;
        foreach (var data in result.Events)
        {
            var assemblyQualifiedName = data.Event.Metadata.ParseJson<string>();
            var type = Type.GetType(assemblyQualifiedName);
            var json = Helper.UTF8NoBom.GetString(data.Event.Data);
            var @event = JsonConvert.DeserializeObject(json, type) as Event;
            if (@event != null)
            {
                events.Add(@event);
            }
        }

保存时需要将类型添加到元数据中：

           var type = @event.GetType().AssemblyQualifiedName;
            var data = new EventData(
                Guid.NewGuid(),
                @event.GetType().Name,
                true,
                @event.ToJsonBytes(),
                type.ToJsonBytes());
相关文章：