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 会匹配上

  • 相关阅读:
    隐语义模型LFM
    基于内容的推荐、协同过滤
    评定标准
    函数式模型示例
    函数式模型概述
    序贯模型
    seq2seq
    链队列
    顺序栈
    线性表的静态链表存储结构
  • 原文地址:https://www.cnblogs.com/yxlblogs/p/10239178.html
Copyright © 2011-2022 走看看