















为了能够支持消息版本控制,你需要确保这个必要的组件已配置。最简单的实现是这样的:
var bus = RabbitHutch.CreateBus("host=localhost",
services => services.EnableMessageVersioning());
一旦消息版本功能启动,你必须显示的选择你要版本化的消息加入版本控制。
// 这个消息不是被版本化的, 当这个消息被发布时,将和其他消息用同样发布去处理。
public class MyMessage
{
public string Text { get; set; }
}
// 这个消息是版本化过的。对于订阅者有两种消息,MyMessageV2和MyMessage
public class MyMessageV2 : MyMessage, ISupersede<MyMessage>
{
public int Number { get; set; }
}
当你发布一个消息,EasyNetQ通常为这个消息类型创建一个交换机,然后发布这个消息到这个交换机。订阅者创建队列,绑定到这个交换机,因此可以接收任何发布到这个交换机上的消息。
当版本化的消息启用时,EasyNetQ将为每一个继承结构的版本化消息类型创建一个交换机,然后绑定这些交换机在一起。当你发布MyMessageV2消息时,这个消息被发送到MyMessageV2交换机上,并自动向上转发到MyMessage交换机。
当消息被序列化时,EasyNetQ会存储这个消息类型名称到这个消息的Type属性中。这个元数据会连同消息一起发送到任何订阅者,订阅者然后能够用这个元数据来反序列化这个消息。
当版本化消息启用时,EasyNetQ也将存储所有被取代的消息类型到这个消息Header属性中。订阅者将用这个属性查找第一个可用的消息类型去序列化,就算终结点没有最新版本的消息,只要有一个版本,它就能够被反序列化和被处理。
英文版本:https://github.com/EasyNetQ/EasyNetQ/wiki/Versioning-Messages
本文地址:http://www.cnblogs.com/HuangLiang/p/EasyNetQ_Versioning_Messages.html
此内容由惯性聚合(RSS阅读器)自动聚合整理,仅供阅读参考。 原文来自 — 版权归原作者所有。