Skip to content

序列化

CAP 提供了 ISerializer 接口来支持对消息进行序列化,默认情况下我们使用 json 来对消息进行序列化处理并存储到数据库中。

自定义序列化

public class YourSerializer: ISerializer
{
    Task<TransportMessage> SerializeAsync(Message message)
    {

    }

    Task<Message> DeserializeAsync(TransportMessage transportMessage, Type valueType)
    {

    }
}

然后将你的实现注册到容器中:

//注册你的自定义实现
services.AddSingleton<ISerializer, YourSerializer>();

// ---
services.AddCap