4.Direct交换机之使用指定routingkey完成日志记录场景

标题 :
4.Direct交换机之使用指定routingkey完成日志记录场景
目录 :
RabbitMQ
序号 :
4

const string logOthersQueueName &＃61; "log-queue-others";

​
​
var connection &＃61; connectionFactory.CreateConnection();
var channel &＃61; connection.CreateModel();
​
//设置服务质量
channel.BasicQos(0, 1, false);
​
//定义一个类型为Direct的交换机
channel.ExchangeDeclare(exchangeName, ExchangeType.Direct, true, false, null);
​
​
//定义一个队列,将用于存放日志级别为 Warn,Info,Debug的日志
channel.QueueDeclare(queue: logOthersQueueName, durable: true, exclusive: false, autoDelete: false, arguments: null);
​
​
​
//将debug&＃xff0c;info&＃xff0c;warn 都绑定到log-queue-others"队列中
var routingKeys &＃61; new[] { "info", "warn", "debug" };
foreach (var routingKey in routingKeys)
{
channel.QueueBind(logOthersQueueName, exchangeName, routingKey, null);
}
​
//定义消费者
var consumer &＃61; new EventingBasicConsumer(channel);
consumer.Received &＃43;&＃61; (model, ea) &＃61;>
{
var body &＃61; ea.Body;
var message &＃61; Encoding.UTF8.GetString(body);
Console.WriteLine(" [x] Received {0} " &＃43; DateTime.Now, message);
channel.BasicAck(ea.DeliveryTag, false);
};
channel.BasicConsume(queue: logOthersQueueName, false, consumer: consumer);
​
​
Console.WriteLine(" Press [enter] to exit.");
Console.ReadLine();
}
}
}
​
&＃96;&＃96;&＃96;

• 这里我们把log-queue-others队列绑定到了交换机上,并指定了routingKey为info,warn和debug.这样会产生三组路由.info,warn,debug三种级别的日志均被路由到log-queue-others队列上

• 按照预期设计,将消费发送序号!&＃61;10的倍数的日志.
  
  ​

  引用链接

  https://www.rabbitmq.com/tutorials/tutorial-four-dotnet.html