zoukankan      html  css  js  c++  java
  • asp.net core3.1实战篇 RabbitMQ的使用(EasyNetQ的高级用法一)第三篇

    在.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<TextMessage>("test", HandleTextMessage);
    
                    Console.WriteLine("Listening for messages. Hit <return> to quit.");
                    Console.ReadLine();
                }
            }
    
            static void HandleTextMessage(TextMessage textMessage)
            {
                Console.ForegroundColor = ConsoleColor.Red;
                Console.WriteLine("Got message: {0}", textMessage.Text);
                Console.ResetColor();
            }
        }
    }

    同时启动两者控制台代码

     在这里插入图片描述

     在这里插入图片描述

    世界再大也有尽头!
  • 相关阅读:
    动态规划_树形DP
    动态规划_区间DP
    Git
    动态规划_状态机与状态压缩DP
    Mybatis
    3.UIViewController详解
    Flutter boost实现原理简介
    FFmpeg笔记(四)
    Xcode-FFmpeg环境搭建
    FFmpeg(一)
  • 原文地址:https://www.cnblogs.com/shijiehaiyang/p/15048514.html
Copyright © 2011-2022 走看看