当前位置：网站首页 / C#开发 / 正文

AY C# RabbitMQ 2019 微笔记2

时间：2018年12月04日 | 作者 : aaronyang | 分类 : C#开发 | 浏览: 2037次 | 评论 0 人

发送消息，生产者接收消息消费者 RabbitMQ是Erlang语言开发
上篇博客

队列 Queue 先进先出

prefetchCount限制每次发送给消费者的消息个数，等于1，消息者一个一个处理，在第三篇会细讲，让你清楚为什么有这个属性

ExInclusive 只能被一个连接使用，连接关闭后，消息删除

auto deleted: 当最后一个使用者取消订阅时，删除大于一个使用者的队列

Arguments 可选的; 由插件和特定于代理的功能使用，例如消息TTL，队列长度限制等

Priorities 优先级，如果需要优先级队列，我们建议使用1到10之间。目前使用更多优先级将消耗更多资源（Erlang进程）。

一个消息一个消费者，消费者处理完了，是手动告诉兔子我处理完了，还是手动告诉兔子，兔子才会把消息删掉。

交换器，我称呼邮箱 Exchange 类似微信的公众号，你关注了Exchange，往这里发消息，订阅公众号的都能收到消息

一个消息很多消费者，共享这个消息的。

邮箱有类型的，

fanout 广播

model.ExchangeDeclare(ExchangeName, "fanout");

先连接的消费者都会即时收到消息，后来启动的消费者打开是不会收到之前的。你理解公众号就好理解了。

Direct 完全匹配的路由key，才会被接收

Topic 模糊匹配路由key，*一个单词，#任意数量字符

Head不管了，不怎么用。

====================www.ayjs.net 杨洋 wpfui.com ayui ay aaronyang=======请不要转载谢谢了。=========

旧的博客，从这篇往后看 :http://www.ayjs.net/post/366.html

现在使用新的类库的新的写法去实现基本例子，官方是Core或者.NET Framework 4.5.1+

建立2个控制台，分别引用 rabbitmq.client

使用稳定版5.1

生产者 MQ.Product1

测试 AyTestMQ

DEMO1 Hello Word 以前旧文章

发送方：

   var factory = new ConnectionFactory() { HostName = "localhost",UserName="ay",Password="123456",Port=5672 };
            using (var connection = factory.CreateConnection())
            using (var channel = connection.CreateModel())
            {
                channel.QueueDeclare(queue: "hello",
                                     durable: false,
                                     exclusive: false,
                                     autoDelete: false,
                                     arguments: null);

                string message = "Hello World!";
                var body = Encoding.UTF8.GetBytes(message);

                channel.BasicPublish(exchange: "",
                                     routingKey: "hello",
                                     basicProperties: null,
                                     body: body);
                Console.WriteLine(" [x] Sent {0}", message);
            }

            Console.WriteLine(" Press [enter] to exit.");

查看下，发送的消息只能byte[] 类型，如果是类，找个二进制序列化

有个hello队列了，这种处理 1个消息只能一个消费者

如果你失败了，你的兔子队列的所在的硬盘空间不够了，至少需要50M 的硬盘空间

接收方 最新版本换成事件方式了

需要引入

using RabbitMQ.Client;

using RabbitMQ.Client.Events;

这2个空间了

在AyTestMQ项目里面写法

using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace AyTestMQ
{
    class Program
    {
        static void Main(string[] args)
        {
            var factory = new ConnectionFactory() { HostName = "localhost", UserName = "ay", Password = "123456", Port = 5672 };
            using (var connection = factory.CreateConnection())
            using (var channel = connection.CreateModel())
            {
                channel.QueueDeclare(queue: "hello",
                                     durable: false,
                                     exclusive: false,
                                     autoDelete: false,
                                     arguments: null);

                var consumer = new EventingBasicConsumer(channel);
                consumer.Received += (model, ea) =>
                {
                    var body = ea.Body;
                    var message = Encoding.UTF8.GetString(body);
                    Console.WriteLine(" [x] Received {0}", message);
                };
                channel.BasicConsume(queue: "hello",
                                     autoAck: true,
                                     consumer: consumer);

                Console.WriteLine(" Press [enter] to exit.");
                Console.ReadLine();
            }



            Console.ReadKey();
        }
    }
}

这里Received跟以前不一样了，以前的阻塞方式

测试：

启动生产者

启动消费者