• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

[c#]RabbitMQ的简单使用

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

摘要

Message Queue消息队列,简称MQ,是一种应用程序对应用程序的通信方法,应用程序通过读写出入队列的消息来通信,而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信,而不是通过直接调用彼此通信。

MQ是消费-生产者模型的一个典型代表,一端往消息队列中不断写入消息,而另一端则可以读取或者订阅队列中的消息。

安装

官网地址:http://www.rabbitmq.com/download.html

下载后,需要安装RabbitMQ服务。如果没有Erlang环境会弹出下面的提示:

下载Erlang环境并安装

地址:http://www.erlang.org/downloads

然后安装RabbitMQ,安装成功后会在服务中看到该服务。

一个例子

新建一个控制台应用程序,并使用Nuget引入RabbitMQ

 代码如下:

当type等于1时,客户端为生产者,2时为消费者

    /// <summary>
    /// RabbitMQ
    /// </summary>
    class Program
    {
        static void Main(string[] args)
        {
            string type = Console.ReadLine();
            //生产者
            if (type=="1")
            {
                ConnectionFactory factory = new ConnectionFactory();
                factory.HostName = "127.0.0.1";
                //默认端口
                factory.Port = 5672;
                using (IConnection conn = factory.CreateConnection())
                {
                    using (IModel channel = conn.CreateModel())
                    {
                        //在MQ上定义一个持久化队列,如果名称相同不会重复创建
                        channel.QueueDeclare("MyRabbitMQ", true, false, false, null);
                        while (true)
                        {
                            string message = string.Format("Message_{0}", Console.ReadLine());
                            byte[] buffer = Encoding.UTF8.GetBytes(message);
                            IBasicProperties properties = channel.CreateBasicProperties();
                            properties.DeliveryMode = 2;
                            channel.BasicPublish("", "MyRabbitMQ", properties, buffer);
                            Console.WriteLine("消息发送成功:" + message);
                        }
                    }
                }
            }
            else
            {
                //消费者
                ConnectionFactory factory = new ConnectionFactory();
                factory.HostName = "127.0.0.1";
                //默认端口
                factory.Port = 5672;
                using (IConnection conn = factory.CreateConnection())
                {
                    using (IModel channel = conn.CreateModel())
                    {
                        //在MQ上定义一个持久化队列,如果名称相同不会重复创建
                        channel.QueueDeclare("MyRabbitMQ", true, false, false, null);

                        //输入1,那如果接收一个消息,但是没有应答,则客户端不会收到下一个消息
                        channel.BasicQos(0, 1, false);

                        Console.WriteLine("Listening...");

                        //在队列上定义一个消费者
                        QueueingBasicConsumer consumer = new QueueingBasicConsumer(channel);
                        //消费队列,并设置应答模式为程序主动应答
                        channel.BasicConsume("MyRabbitMQ", false, consumer);

                        while (true)
                        {
                            //阻塞函数,获取队列中的消息
                            BasicDeliverEventArgs ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();
                            byte[] bytes = ea.Body;
                            string str = Encoding.UTF8.GetString(bytes);

                            Console.WriteLine("队列消息:" + str.ToString());
                            //回复确认
                            channel.BasicAck(ea.DeliveryTag, false);
                        }
                    }
                }
            }
          
        }
    }

测试

启动生产者

启动消费者

使用生产者入队,1,2,3,4,5,6,7,8

消费者

 参考文章

http://www.cnblogs.com/qy1141/p/4054135.html?utm_source=tuicool&utm_medium=referral

  • 博客地址:http://www.cnblogs.com/wolf-sun/
    博客版权:如果文中有不妥或者错误的地方还望高手的你指出,以免误人子弟。如果觉得本文对你有所帮助不如【推荐】一下!如果你有更好的建议,不如留言一起讨论,共同进步! 再次感谢您耐心的读完本篇文章。

鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
C# 托管堆和垃圾回收器GC发布时间:2022-07-14
下一篇:
C#泛型编程简介发布时间:2022-07-14
热门推荐
热门话题
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap