标签：Console string Exchange RabbitMQ Topic exchangeName using channel

 介绍

　　通配符模式和路由模式其实差不多,不同于配符模式中的路由可以声明为模糊查询.

•  符号 # 匹配一个或多个词.
•  符号 * 匹配一个词。

　　RabbitMQ中通配符的通配符是用"."来分割字符串的.比如a.*只能匹配到a.b,a.c,而a.#可以匹配到a.a.c,a.a.b.

 .net 5.0 代码实现

•  生产者实现

using RabbitMQ.Client;
using System;
using System.Text;

namespace RabbitMQTest.Producer
{
    /// <summary>
    /// RabbitMQ测试_Producer生产者
    /// </summary>
    class Program
    {
        static void Main(string[] args)
        {
            // 1、创建连接工厂
            IConnectionFactory factory = new ConnectionFactory()
            {
                UserName = "admin",
                Password = "admin",
                HostName = "192.168.1.101", //rabbitmq server ip
                Port = 5672,
                VirtualHost = "testhost" //在此连接期间要访问的虚拟主机。 默认值[ / ]
            };
            // 2、创建连接
            IConnection connection = factory.CreateConnection();
            // 3、创建通道
            IModel channel = connection.CreateModel();

            // 交换机名称
            string exchangeName = "exchangeTest";
            string routeKey = "key.a";
            // 4、把交换机设置成 Topic 路由模式
            channel.ExchangeDeclare(exchangeName, type: ExchangeType.Topic);

            Console.WriteLine("\n RabbitMQ连接成功，请输入消息，输入exit退出！");
            string input;
            do
            {
                input = Console.ReadLine();
                byte[] sendBytes = Encoding.UTF8.GetBytes(input);
                //发布消息
                channel.BasicPublish(exchangeName, routeKey, null, sendBytes);
            } while (input.Trim().ToLower() != "exit");
            Console.WriteLine("\n RabbitMQ测试完毕！");
            // 6、关闭通道
            channel.Close();
            // 7、关闭连接
            connection.Close();
        }
    }
}

•  消费者实现

using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System;
using System.Text;
using System.Threading;

namespace RabbitMQTest.Consumer
{
    /// <summary>
    /// RabbitMQ测试_Consumer消费者
    /// </summary>
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("输入接受key的名称");
            string routekey = Console.ReadLine();
            // 1、创建连接工厂
            ConnectionFactory factory = new ConnectionFactory()
            { 
                UserName = "admin", //用户名
                Password = "admin", //密码
                HostName = "192.168.1.101", //rabbitmq server ip
                Port = 5672, //端口号
                VirtualHost = "testhost" //在此连接期间要访问的虚拟主机。

            };
            // 2、创建连接
            IConnection connection = factory.CreateConnection();
            // 3、创建通道
            IModel channel = connection.CreateModel(); 

            // 交换机名称
            string exchangeName = "exchangeTest";
            // 4、声明交换机
            channel.ExchangeDeclare(exchangeName, ExchangeType.Topic);
            // 消息队列名称
            string queueName = DateTime.Now.Year.ToString();
            // 5、声明队列
            channel.QueueDeclare(queueName, false, false, false, null);
            // 5.1、将队列，交换机和key绑定
            channel.QueueBind(queueName, exchangeName, routekey, null);
            // 6、定义消费者
            EventingBasicConsumer consumer = new EventingBasicConsumer(channel);
            Console.WriteLine($"队列名称：{queueName}");
            // 7、接收到消息事件
            consumer.Received += (ch, ea) =>
              {
                  string message = Encoding.Default.GetString(ea.Body.ToArray());
                  Console.WriteLine($"接受到消息：{message}");
                  // 8、确认该消费已被消费
                  channel.BasicAck(ea.DeliveryTag, true);
              };
            // 9、启动消费者 设置为自动应答消息
            channel.BasicConsume(
                queue: queueName, // 消息队列名称
                autoAck: false, // 两种消息确认模式false 手动模式 true自动模式
                consumer: consumer);

            Console.WriteLine("消费者1已启动");
            Console.ReadKey();
            channel.Close();
            connection.Close();
        }
    }
}

　　只有在通配符匹配通过的情况下才会接收消息

标签：Console,string,Exchange,RabbitMQ,Topic,exchangeName,using,channel
来源： https://www.cnblogs.com/gygtech/p/14918302.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。