本文共 1488 字，大约阅读时间需要 4 分钟。

在.net core控制台安装

Install-Package EasyNetQ

一：定义公共消息类

namespace Messages{
       public class TextMessage    {
           public string Text {
    get; set; }     }}

二： 发布者代码

using System;using EasyNetQ;using Messages;namespace Publisher{
       class Program    {
           static void Main(string[] args)        {
               using (var bus = RabbitHutch.CreateBus("host=localhost"))            {
                   var input = "";                Console.WriteLine("Enter a message. 'Quit' to quit.");                while ((input = Console.ReadLine()) != "Quit")                {
                       bus.Publish(new TextMessage                        {
                               Text = input                        });                }            }        }    }}

三： 订阅者代码

using System;using EasyNetQ;using Messages;namespace Subscriber{
       class Program    {
           static void Main(string[] args)        {
               using (var bus = RabbitHutch.CreateBus("host=localhost"))            {
                   bus.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();        }    }}
    
   

同时启动两者控制台代码

转载地址：https://codeboy.blog.csdn.net/article/details/107831823 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！