RabbitMQ Headers Exchange示例
RabbitMQ 示例 Exchange headers
2023-09-11 14:18:14 时间
(1)、发布者
1 var connectionFactory = new ConnectionFactory() { HostName="192.168.205.128",UserName="guest",Password="guest"}; //创建连接工厂 2 var connection = connectionFactory.CreateConnection(); //创建connection 3 var channel = connection.CreateModel(); //创建channel 4 //声明交换机 5 //String exchange, 交换机名称 6 //String type, 交换机类型 7 //Boolean durable, 是否持久化 8 //Boolean autoDelete, 是否自动删除 9 //IDictionary< String, Object > arguments 交换机参数 10 channel.ExchangeDeclare("headersExchange", ExchangeType.Headers, true, false, null); 11 //声明队列 12 //String queue, 队列名称 13 //Boolean durable, 是否持久化 14 //Boolean exclusive, 是否专有的(排外) 15 //Boolean autoDelete, 是否自动删除 16 //IDictionary<String, Object> arguments 队列参数 17 channel.QueueDeclare("headersQueue", true, false, false, null); 18 //将队列绑定到交换机上 19 //String queue, 队列名称 20 //String exchange, 交换机名称 21 //String routingKey, routingKey 22 //IDictionary< String, Object > arguments 绑定参数 23 IDictionary<String, Object> arguments = new Dictionary<String, Object>() 24 { 25 {"x-match","any"}, //设置x-match属性为any,即头信息中只要有一个匹配就可以了 26 { "username","fanqi"} 27 }; 28 channel.QueueBind("headersQueue", "headersExchange", string.Empty, arguments); 29 30 //设置消息属性 31 var properties = channel.CreateBasicProperties(); 32 properties.Headers = new Dictionary<String, Object>(); 33 properties.Headers.Add("username", "fanqi"); 34 35 //发布消息 36 //String exchange, 交换机名称 37 //String routingKey, routingKey 38 //IBasicProperties basicProperties, 发布属性 39 //Byte[] body 消息内容 40 channel.BasicPublish("headersExchange", string.Empty, properties, Encoding.UTF8.GetBytes("来自.net的问候")); 41 Console.ReadKey();
(2)、接收者
1 var connectionFactory = new ConnectionFactory() { HostName = "192.168.205.128", UserName = "guest", Password = "guest" }; //创建连接工厂 2 var connection = connectionFactory.CreateConnection(); //创建connection 3 var channel = connection.CreateModel(); //创建channel 4 //声明交换机 5 //String exchange, 交换机名称 6 //String type, 交换机类型 7 //Boolean durable, 是否持久化 8 //Boolean autoDelete, 是否自动删除 9 //IDictionary< String, Object > arguments 交换机参数 10 channel.ExchangeDeclare("headersExchange", ExchangeType.Headers, true, false, null); 11 //声明队列 12 //String queue, 队列名称 13 //Boolean durable, 是否持久化 14 //Boolean exclusive, 是否专有的(排外) 15 //Boolean autoDelete, 是否自动删除 16 //IDictionary<String, Object> arguments 队列参数 17 channel.QueueDeclare("headersQueue", true, false, false, null); 18 //将队列绑定到交换机上 19 //String queue, 队列名称 20 //String exchange, 交换机名称 21 //String routingKey, routingKey 22 //IDictionary< String, Object > arguments 绑定参数 23 24 IDictionary<String, Object> arguments = new Dictionary<String, Object>() 25 { 26 {"x-match","any"}, //设置x-match属性为any,即头信息中只要有一个匹配就可以了 27 { "username","fanqi"} 28 }; 29 channel.QueueBind("headersQueue", "headersExchange", string.Empty, arguments); 30 //1.直接获取消息 31 //var result = channel.BasicGet("headersQueue", true); 32 //Console.WriteLine(Encoding.UTF8.GetString(result.Body)); 33 //2.使用事件机制获取消息 34 EventingBasicConsumer consumer = new EventingBasicConsumer(channel); 35 consumer.Received += (sender, e) => 36 { 37 Console.WriteLine(Encoding.UTF8.GetString(e.Body)); 38 }; 39 channel.BasicConsume("headersQueue", true, consumer); 40 Console.ReadKey();
相关文章
- SpringBoot使用RabbitMQ
- Go/Python/Erlang编程语言对比分析及示例 基于RabbitMQ.Client组件实现RabbitMQ可复用的 ConnectionPool(连接池) 封装一个基于NLog+NLog.Mongo的日志记录工具类LogUtil 分享基于MemoryCache(内存缓存)的缓存工具类,C# B/S 、C/S项目均可以使用!
- RabbitMQ安装
- PHP+RabbitMQ消息队列的配置和使用方法【MQ】
- RabbitMQ: /var/lib/rabbitmq/.erlang.cookie must be accessible by owner only
- 【RabbitMQ】连接RabbitMQ异常: com.rabbitmq.client.ShutdownSignalException connection error;
- RabbitMQ安装教程(Windows环境下)
- RabbitMQ下的生产消费者模式与订阅发布模式
- RabbitMQ延迟消息的延迟极限是多少?
- Rabbitmq交换器Exchange和消息队列
- RabbitMQ中客户端的Channel类里各方法释义
- RabbitMQ修改连接数,内存以及磁盘教程
- rabbitMQ rabbitmq-server -detached rabbitmq-server -detached rabbitmq-server -detached
- Rabbitmq 简单示例
- springboot 通过配置文件 控制Rabbitmq 启动
- centos 6.7下安装rabbitmq 3.6.6过程
- RabbitMQ如何保证队列里的消息99.99%被消费?
- 面试官:RabbitMQ怎么实现消费的可靠投递