easyNetq demo

2021-06-30 21:05

阅读：644

标签：summary name route show nec public 类库新建 color

本demo包含一个类库，2个console程序

1.新建类库 MQHelper，控制台程序 consumer和proc ，控制台程序引用MQHelper

2.使用nuget安装easynwtq 和rabbitmq.client.dll ,执行Install-Package EasyNetQ -Version 1.1.3.500 会自动安装 easynwtq和依赖项rabbitmq.client.dll

3.MQHelper

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using EasyNetQ;
namespace MQHelper
{
    public class MQManage
    {
        /// 
        /// 发送消息
        /// 
        public static void Publish(MyMessage msg)
        {
            //// 创建消息bus
            IBus bus = RabbitHutch.CreateBus("host=192.168.1.1:5672;virtualHost=as;username=123;password=123");

            try
            {
                bus.Publish(msg, x => x.WithTopic(msg.MessageRouter));
            }
            catch (EasyNetQException ex)
            {
                //处理连接消息服务器异常 
            }

            bus.Dispose();//与数据库connection类似，使用后记得销毁bus对象
        }

        /// 
        /// 接收消息
        /// 
        /// 
        public static void Subscribe(MyMessage msg)
        {
            //// 创建消息bus
            IBus bus = RabbitHutch.CreateBus("host=192.168.1.1:5672;virtualHost=as;username=123;password=123");

            try
            {
                bus.Subscribe(msg.MessageRouter, message => Console.WriteLine(message.MessageBody), x => x.WithTopic(msg.MessageRouter));
            }
            catch (EasyNetQException ex)
            {
                //处理连接消息服务器异常 
            }
        }

    }

    public class MyMessage
    {
        public string MessageID { get; set; }

        public string MessageTitle { get; set; }

        public string MessageBody { get; set; }

        public string MessageRouter { get; set; }
    }
}

4.proc 生产程序

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
namespace proc
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("proc2");
            //// 创建消息bus

            while (true)
            {
                MQHelper.MQManage.Publish(new MQHelper.MyMessage
                {
                    MessageID = "2",
                    MessageRouter = "ro2",
                    MessageBody ="当前时间="+DateTime.Now.ToString(),
                    MessageTitle = "title" + DateTime.Now
                });

                Thread.Sleep(3000);
            }
        }
    }
}

View Code

5.consumer 消费程序

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace consumer
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("consumer2");
            //// 创建消息bus

          MQHelper.MQManage.Subscribe(new MQHelper.MyMessage
            {
                MessageID = "2",
                MessageRouter = "ro2"
                //MessageBody=DateTime.Now.ToString(),
                //MessageTitle="title"+DateTime.Now
            });
        }
    }
}

View Code

6.先bin/debug 里先打开 consumer.exe ,再打开proc.exe 就能看到效果了

easyNetq demo

标签：summary name route show nec public 类库新建 color

原文地址：http://www.cnblogs.com/tiancai/p/7135775.html

上一篇：Ajax异步方式实现登录与參数的校验

下一篇：HTML5拖拽——将本地文件拖拽到网页中显示

文章来自：搜素材网的编程语言模块，转载请注明文章出处。
文章标题：easyNetq demo
文章链接：http://soscw.com/index.php/essay/100014.html

亲，登录后才可以留言！

easyNetq demo

评论

热门文章

推荐文章

最新文章

置顶文章