1 using System; 2 using EasyNetQ; 3 using Wen.EasyNetQDemo.Model; Wen.EasyNetQDemo.Publisher 6 { Program 8 { Main(string[] args) 10 { )) 12 { 13 string input; ); ((input = Console.ReadLine()) != ) 17 { 18 bus.Publish(new Demo 19 { 20 Message = input 21 }); 22 } 23 24 } 25 } 26 } 27 }

　　【备注】RabbitHutch.CreateBus() 方法可以创建一个简单的发布/订阅和包含请求/响应 API 的消息总线。

　　Subscriber

1 using System; 2 using EasyNetQ; 3 using Wen.EasyNetQDemo.Model; Wen.EasyNetQDemo.Subscriber 6 { Program 8 { Main(string[] args) 10 { )) 12 { , HandleDemo); ); 16 Console.ReadLine(); 17 } 18 } HandleDemo(Demo demo) 21 { 22 Console.ForegroundColor = ConsoleColor.Green; ); 24 Console.ResetColor(); 25 } 26 } 27 }

 图：效果图

「世事洞明皆学问 人情练达即文章」

【博主】反骨仔

【原文】