7.Topic交换机之模拟文件分类

标题 :

7.Topic交换机之模拟文件分类

目录 :

RabbitMQ

序号 :

7

            Password = "123456",

            AutomaticRecoveryEnabled = true,

            TopologyRecoveryEnabled = true

        };

const string exchangeName = "file-type-exchange";

const string queueName = "file-type-queue";

var connection = connectionFactory.CreateConnection();

var channel = connection.CreateModel();

//设置服务质量

channel.BasicQos(0, 1, false);

//定义一个类型为Topic的交换机

channel.ExchangeDeclare(exchangeName, ExchangeType.Topic, true, false, null);

//定义一个队列,将用于存放文件信息

channel.QueueDeclare(queue: queueName, durable: true, exclusive: false, autoDelete: false, arguments: null);

//将队列绑定到交换机上

channel.QueueBind(queueName, exchangeName, ".bmp", null);

channel.QueueBind(queueName, exchangeName, ".mp4", null);

channel.QueueBind(queueName, exchangeName, "#1000.dev", null);

//定义消费者

var consumer = new EventingBasicConsumer(channel);

consumer.Received += (model, ea) =>

{

var body = ea.Body;

var message = Encoding.UTF8.GetString(body);

Console.WriteLine("这个一个图像文件,或者是一个名称为#1000.dev的文件:{0}", message);

channel.BasicAck(ea.DeliveryTag, false);

};

channel.BasicConsume(queue: queueName, false, consumer: consumer);

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

Console.ReadLine();

}

}

}



![](https://www.showdoc.cc/server/api/common/visitfile/sign/6bbd65eff41cfe3afe7f3f1ea82b82fb?showdoc=.jpg)

###引用链接

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

巴特西

7.Topic交换机之模拟文件分类

最新文章

热门文章