网站引导制作,wordpress qq邮箱订阅,怎么宣传自己新开的店铺,注册网站能赚钱吗在前一个教程中#xff0c;我们创建了一个工作队列。工作队列背后的假设是每个任务会被交付给一个【工人】。在这一部分我们将做一些完全不同的事情--我们将向多个【消费者】传递信息。这种模式被称为“发布/订阅”。 为了说明这种模式#xff0c;我们将构建一个简单的日志…在前一个教程中我们创建了一个工作队列。工作队列背后的假设是每个任务会被交付给一个【工人】。在这一部分我们将做一些完全不同的事情--我们将向多个【消费者】传递信息。这种模式被称为“发布/订阅”。 为了说明这种模式我们将构建一个简单的日志系统。它将包括两个程序第一个将发出日志消息第二个将接收并打印它们。 在我们的日志系统中每个接收程序的运行副本都会得到消息。这样我们就可以运行一个接收者程序将日志记录到磁盘同时我们可以运行另一个接收者程序并在屏幕上看到打印出来的日志。 从本质上讲已发布的日志消息将被广播到所有的接收者程序。1、消息交换机【Exchange】 在教程的前面部分我们从队列中发送和接收消息。在RabbitMQ中现在是时候引入全消息模型。 让我们快速看看我们以前的教程讲了什么 【生产者】就是一个用于发送消息的用户程序 【消费者】就是一个用于接收和使用消息的用户程序 【队列】是一个暂存消息的缓存区 RabbitMQ消息传递模型的核心思想是【生产者】不直接发送任何信息到队列。事实上【生产者】根本就不知道消息是否会被传送到任何队列。 相反【生产者】只能发送消息到【消息交换机】。交换是件很简单的事。一方面它接收来自【生产者】的消息另一方面是将接收到消息推送到队列中。【消息交换机】必须知道它如何处理接收消息的确切方法。是否应该发送到特定队列它应该被发送到多个队列呢或者它应该被丢弃。该规则由【消息交换机】的类型来定义。 这里有一些可用的【消息交换机】的类型【Direct】直接【Topic】主题【Headers】标题和【Fanout】扇出。我们将集中关注最后一个-【Fanout】扇出。让我们创建一个这种类型的【消息交换机】并给它命名为Logs
channel.ExchangeDeclare(logs, fanout); 【Fanout】类型的【消息交换机】非常简单。正如你从名字可能猜出的它只是传播它收到的所有消息去它知道所有的队列中。这正是我们需要我们的日志记录器。 显示【消息交换机】的列表 使用Rabbitmqctl列出在服务器上可以运行的最有用的【消息交换机】 sudo rabbitmqctl list_exchanges 在这个列表中会有一些amq.*【消息交换机】和默认未命名消息交换机。这些都是默认创建的但现在不太可能需要使用它们。 默认的消息交换机 在教程前面的部分我们队【消息交换机】是一无所知但是我依然可以发送消息去想去的队列那是因为我们使用了默认的【消息交换机】这些默认的消息 交换机我用使用两个双引号“”来标识。 我们回忆一下以前是如何发送消息的
var message GetMessage(args);var body Encoding.UTF8.GetBytes(message);
channel.BasicPublish(exchange: , routingKey: hello, basicProperties: null, body: body); 第一个参数是【消息交换机】的名称。空字符串表示默认或未命名的消息交换机消息会被路由到指定的routingkey名称的队列如果它存在的话。 现在我们可以发布到我们命名的【消息交换机】
var message GetMessage(args);var body Encoding.UTF8.GetBytes(message);
channel.BasicPublish(exchange: logs, routingKey: , basicProperties: null, body: body);
2、临时队列 也许你还记得以前我们使用的队列所指定的名称记得Hello和task_queue吗对我们来说能够给一个队列指定名称是至关重要的--因为我们需要把【Worker】指向同一个队列。如果要在【生产者】和【消费者】之间共享队列给队列命名是很重要的。 但这不是我们的日志记录器的情况。我们想听到所有的日志消息而不仅仅是其中的一个子集。我们也只对当前刚刚收到的消息感兴趣而不是对旧的。为了解决上述问题我们需要做两件事。 首先无论何时当我们连接到Rabbit的时候我们都需要一个新的并且是空的队列。要做到这一点我们可以创建一个具有随机名称的队列或者甚至更好一点-让服务器为我们选择一个随机队列名称。 其次一旦我们断开与【消费者】的队列就应该自动删除该队列。 在.NET客户端中当我们没有为queueDeclare提供参数时我们创建了一个具有生成名称的非持久排他自动删除队列
var queueName channel.QueueDeclare().QueueName; 在这点上QueueName包含随机队列名称。例如它可能看起来像amq.gen-jzty20brgko-hjmujj0wlg。
3、绑定【Binding】 frameborder0 scrollingno style 我们已经创建了一个【Fanout】类型的【消息交换机】和队列。现在我们需要告诉【消息交换机】向我们的队列发送消息。【消息交换机】和【队列】之间的关系称为绑定。 channel.QueueBind(queue: queueName, exchange: logs, routingKey: ); 从现在开始日志的【消息交换机】就可以将消息推送到我们定义的队列中去了。 我们可以通过以下语句查看【binding】列表数据
rabbitmqctl list_bindings
4、把所有的代码整合到一起 【生产者】的程序它发出的日志消息看起来并没有和以前的教程有很大的不同。最重要的变化是我们现在想发送的消息是到达我们指定名称的日志【消息交换机】而不是无名的。我们在发送消息的时候需要提供一个routingkey表示的名称但【Fanout】类型的【消息交换机】会容忽视该routingKey的值的。这里有EmitLog.cs文件代码
相关文章RabbitMQ系列教程之一我们从最简单的事情开始Hello WorldRabbitMQ系列教程之二工作队列Work Queues如何优雅的使用RabbitMQ.NET 使用 RabbitMQ 图文简介RabbitMQ 高可用集群搭建及电商平台使用经验总结搭建高可用的rabbitmq集群 Mirror Queue 使用C#驱动连接RabbitMQ消息队列应用体验Rabbitmq强大的【优先级队列】之轻松面对现实业务场景原文地址http://www.cnblogs.com/PatrickLiu/p/6943830.html.NET社区新闻深度好文微信中搜索dotNET跨平台或扫描二维码关注
