RabbitMQ入門學習系列(六) Exchange的Topic類型

時間 2019-11-08

標籤 rabbitmq 入門學習系列 exchange topic 類型欄目 RabbitMQ 简体版

原文原文鏈接

快速閱讀

介紹exchange的topic類型，和Direct類型類似，可是增長了"."和"#"的匹配。比Direct類型靈活正則表達式

Topic消息類型

特色是：topic消息類型不能是任意的routing key, 必須是有點"."組成的單詞列表。c#

和dirct相似，最後也是也相應的key進行匹配測試

例如：speed.color.sepciesthis

**注意能夠用*號和#號出現，和咱們平常用的正則表達式含義相近**google

"*"號表明任意一個單詞code

"#"號表明0個或多個單詞blog

生產者代碼

建立鏈接和信道
聲明exchange類型
設置兩個routingkey 各自發送兩次。一共發送四條消息

static void Main(string[] args)
{
    var factory = new ConnectionFactory() { HostName = "localhost" };
    using (var connection = factory.CreateConnection())
        using (var channel = connection.CreateModel())
    {
        channel.ExchangeDeclare(exchange: "topicType", type: "topic");

        var list = new List<string>();
        list.Add("www.baidu.com");
        list.Add("www.google.com");
        for (var i = 0; i < 2; i++)
        {
            var routingKey = list[0];
            string message = "Hello World!this  message routingkey is  " + routingKey;
            var body = Encoding.UTF8.GetBytes(message);
            var properties = channel.CreateBasicProperties();
            properties.Persistent = true;

            channel.BasicPublish(exchange: "topicType",
                                 routingKey: routingKey,
                                 basicProperties: null,
                                 body: body);

            Console.WriteLine(" [x] Sent {0},id={1}", message,i);
            Thread.Sleep(1000);
        }

        for (var i = 0; i < 2; i++)
        {
            var routingKey = list[1];
            string message = "Hello World!this  message routingkey is  " + routingKey;
            var body = Encoding.UTF8.GetBytes(message);
            var properties = channel.CreateBasicProperties();
            properties.Persistent = true;

            channel.BasicPublish(exchange: "topicType",
                                 routingKey: routingKey,
                                 basicProperties: null,
                                 body: body);

            Console.WriteLine(" [x] Sent {0},id={1}", message, i);
            Thread.Sleep(1000);
        }

    }

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

消費者代碼

建立鏈接和信道
爲了測試 topic 類型，限制輸入中含有baidu,google兩個關鍵詞和發送的routing key相匹配。
聲明交換器類型
隊列聲明
把exchange和隊列綁定到信道上
接受消息

static void Main(string[] args)
{
    bool flag = true;
    string level = "";
    while (flag)
    {
        Console.WriteLine("請選擇要查看的消息類型");
        level = Console.ReadLine();
        if (level.IndexOf(".baidu.")>0 || level.IndexOf(".google.") > 0 )
            flag = false;
        else
            Console.Write("不支持你輸入的消息");
    }

    var factory = new ConnectionFactory() { HostName = "localhost" };
    using (var connection = factory.CreateConnection())
    {
        using (var channel = connection.CreateModel())
        {
            channel.ExchangeDeclare(exchange: "topicType", type: "topic");
            var queueName = channel.QueueDeclare().QueueName;
            channel.QueueBind(queue: queueName, exchange: "topicType", routingKey: level);
            //如下是區別生產者的
            var consumer = new EventingBasicConsumer(channel);
            consumer.Received += (sender, e) =>
            {
                var body = e.Body;
                var message = Encoding.UTF8.GetString(body);
                var rk = e.RoutingKey;
                Console.WriteLine("Received {0},routingKey:{1}", message, rk);
                Thread.Sleep(3000);//模擬耗時任務 ，
                Console.WriteLine("Received over");
                channel.BasicAck(deliveryTag: e.DeliveryTag, multiple: false);
            };
            channel.BasicConsume(queue: queueName, autoAck: false, consumer: consumer);
            Console.WriteLine("");
            Console.ReadLine();
        }

    }