安装rabbitmq

参考

快速开始

官网

新建三个项目

Messages 类库项目
Publisher 控制台项目
Subscriber 控制台项目
两个控制台项目安装EasyNetQ

添加消息

Messages下新建TextMessage.cs

namespace Messages
{public class TextMessage{/// 
/// 要发送的文本消息/// 
public string Text { get; set; }}
}

两个控制台项目添加对于Messages的引用

编写发布者

修改Publisher下的代码

using EasyNetQ;
using Messages;
using System;namespace ConsoleApp1
{internal class Program{static void Main(string[] args){//host=192.168.1.1;port=5672;virtualHost=MyVirtualHost;username=MyUsername;password=MyPassword;requestedHeartbeat=10using (var bus = RabbitHutch.CreateBus("host=10.10.90.139;port=5672;username=wjl;password=密码")){var input = String.Empty;Console.WriteLine("Enter a message. 'Quit' to quit.");while ((input = Console.ReadLine()) != "Quit"){bus.PubSub.Publish(new TextMessage { Text = input });Console.WriteLine("Message published!");}}}}
}

编写接收者

修改Subsciber下的代码

using EasyNetQ;
using Messages;
using System;namespace Subsciber
{internal class Program{static void Main(string[] args){//host=192.168.1.1;port=5672;virtualHost=MyVirtualHost;username=MyUsername;password=MyPassword;requestedHeartbeat=10using (var bus = RabbitHutch.CreateBus("host=10.10.90.139;port=5672;username=wjl;password=密码")){bus.PubSub.Subscribe("test", HandleTextMessage);Console.WriteLine("Listening for messages. Hit  to quit.");Console.ReadLine();}}static void HandleTextMessage(TextMessage textMessage){Console.ForegroundColor = ConsoleColor.Red;Console.WriteLine("Got message: {0}", textMessage.Text);Console.ResetColor();}}
}

先启动订阅者，在启动发布者，启动报错了，需要安装Newtonsoft.json

版本控制消息

Messages下新建MyMessageV2.cs
Messages安装EasyNetQ

using EasyNetQ.MessageVersioning;namespace Messages
{public class MyMessageV2 : TextMessage, ISupersede{public int Number { get; set; }}
}

新建VersioningSend控制台

using EasyNetQ;
using Messages;
using System;namespace VersioningSend
{internal class Program{static void Main(string[] args){/*当你发布一个消息，EasyNetQ通常为这个消息类型创建一个交换机，然后发布这个消息到这个交换机。订阅者创建队列，绑定到这个交换机，因此可以接收任何发布到这个交换机上的消息。当版本化的消息启用时，EasyNetQ将为每一个继承结构的版本化消息类型创建一个交换机，然后绑定这些交换机在一起。当你发布MyMessageV2消息时，这个消息被发送到MyMessageV2交换机上，并自动向上转发到MyMessage交换机。当消息被序列化时，EasyNetQ会存储这个消息类型名称到这个消息的Type属性中。这个元数据会连同消息一起发送到任何订阅者，订阅者然后能够用这个元数据来反序列化这个消息。当版本化消息启用时，EasyNetQ也将存储所有被取代的消息类型到这个消息Header属性中。订阅者将用这个属性查找第一个可用的消息类型去序列化，就算终结点没有最新版本的消息，只要有一个版本，它就能够被反序列化和被处理。*///host=192.168.1.1;port=5672;virtualHost=MyVirtualHost;username=MyUsername;password=MyPassword;requestedHeartbeat=10using (var bus = RabbitHutch.CreateBus("host=10.10.90.139;port=5672;username=wjl;password=wujialiang", service =>{service.EnableMessageVersioning();})){var input = String.Empty;Console.WriteLine("Enter a message. 'Quit' to quit.");while ((input = Console.ReadLine()) != "Quit"){bus.PubSub.Publish(new MyMessageV2 { Text = input, Number = 2 });Console.WriteLine("Message published!");}}}}
}

新建VersioningReceiver控制台

using EasyNetQ;
using Messages;
using System;namespace VersioningReceiver
{internal class Program{static void Main(string[] args){//host=192.168.1.1;port=5672;virtualHost=MyVirtualHost;username=MyUsername;password=MyPassword;requestedHeartbeat=10using (var bus = RabbitHutch.CreateBus("host=10.10.90.139;port=5672;username=wjl;password=wujialiang")){bus.PubSub.Subscribe("test", HandleTextMessage);Console.WriteLine("Listening for messages. Hit  to quit.");Console.ReadLine();}}static void HandleTextMessage(MyMessageV2 textMessage){Console.ForegroundColor = ConsoleColor.Red;Console.WriteLine("Got message: {0}，number:{1}", textMessage.Text,textMessage.Number);Console.ResetColor();}}
}

启动VersioningSend以及VersioningReceiver和Subsciber，发送一条消息

版本消息指南

如果不能通过扩展原始消息类型去实现，那么它就不是一个新版本的消息。它是一个新的消息类型。
如果你不确定，宁可去创建一个新的消息类型，而不是去版本化一个已存在的消息。
被版本化的消息，不应该在Request/Response中做为消息类型去使用，Request和Request是不同的，即使V2扩展与V1也是不同的。
版本化的消息不应用于Send/Receive，因为这是有针对性的发送，因为发送者和接受者之间是有依赖的。

版本化消息支持已经在发布-订阅场景中被开发和测试过。它没有在send-receive 或者 request-response场景中被测试过。在发布-订阅之外其他模式中，风险自负。
版本化消息支持这个时候还没有扩展到未来的publish场景下。额外的工作已经计划开启了，但是由于潜在的中断可能发生，项目所有者和社区需要一些必要的讨论。