zoukankan      html  css  js  c++  java
  • RabbitMQ通过Exchange.topic 对routingkey 进行正则表达式匹配

    消费者:

     static void Main(string[] args)
            {
                ConnectionFactory factory = new ConnectionFactory()
                {
                    HostName = "192.168.254.40",
                    UserName = "admin",
                    Password = "admin",
                };
    
                //第一步:创建connection 
                var connection = factory.CreateConnection();
    
                //第二步:创建一个channel
                var channel = connection.CreateModel();
    
                //第三步:申明交换机【因为rabbitmq已经有了自定义的ampq default exchange】
                channel.ExchangeDeclare("mytopicexchange", ExchangeType.Topic, true, false, null);
    
                //第四步:创建一个队列(queue)
                channel.QueueDeclare("mytopicqueue", true, false, false, null);
    
                //将queue绑定到exchange之上。。。。
                channel.QueueBind("mytopicqueue", "mytopicexchange", "*.com", null);
    
                EventingBasicConsumer consumer = new EventingBasicConsumer(channel);
    
                consumer.Received += (sender, e) =>
                {
                    var msg = Encoding.UTF8.GetString(e.Body);
    
                    Console.WriteLine(msg);
                };
    
                channel.BasicConsume("mytopicqueue", true, consumer);
    
                Console.WriteLine("consumer1 端启动完毕!!!");
    
                Console.Read();
            }

    生产者:

    static void Main(string[] args)
            {
                ConnectionFactory factory = new ConnectionFactory()
                {
                    HostName = "192.168.254.40",
                    UserName = "admin",
                    Password = "admin",
                };
    
                //第一步:创建connection
                var connection = factory.CreateConnection();
    
                //第二步:创建一个channel
                var channel = connection.CreateModel();
    
                for (int i = 0; i < 100; i++)
                {
                    var msg = Encoding.UTF8.GetBytes(string.Format("{0} :{1}", i, "你好"));
    
                    var routingKey = i % 13 == 0 ? "a.com" : "*.cn";
    
                    //第五步:发布消息
                    channel.BasicPublish("mytopicexchange", routingKey: routingKey, basicProperties: null, body: msg);
    
                    Console.WriteLine(i);
                }
            }

    当生产者routingkey 为a.com,消费者*.com 会匹配上

  • 相关阅读:
    SQL Server 动态行转列(参数化表名、分组列、行转列字段、字段值)
    Web Api 跨域解决方案
    Web Api Session开启会话支持
    Web Service 学习
    省市选择器
    如何创建圆形头像和圆角图片
    E
    二叉树
    素数筛法
    Color Me Less
  • 原文地址:https://www.cnblogs.com/yxlblogs/p/10239178.html
Copyright © 2011-2022 走看看