.NET 7使用RabbitMQ的最简入门

//docker 安装RabbitMQdocker search rabbitmq  //搜索docker pull rabbitmq: management //拉取镜像//*# 创建容器并运行（15672是管理界面的端口，5672是服务的端口。这里顺便将管理系统的用户名和密码设置为admin admin）docker run - dit--name rabbitmq -e RABBITMQ_DEFAULT_USER = admin - e RABBITMQ_DEFAULT_PASS = admin - p 15672:15672 - p 5672:5672 rabbitmq: management

Install-Package RabbitMQ.Client

using RabbitMQ.Client;using System.Text;Console.WriteLine("生产者, FirstMQ!");//调用Send();static void Send(){    //创建Factory连接请求 下面这块可以新建一个类或者方法。这里为了更直观    ConnectionFactory conFactory = new ConnectionFactory    {        UserName = "test",        Password = "123456",        HostName= "192.168.240.160",        // Port = 15672;//如果是默认不用设置        DispatchConsumersAsync = false//是否异步请求    };     //模拟请求10000次 处理    int[] intlist = new int[10000];    for (int i = 0; i < 10000; i++)    {        intlist[i] = i;    }    var NameKey = "MQfirst";//名称    var msg = "";//记录总的消费    using (var connection = conFactory.CreateConnection())//创建链接    {        using (var channel = connection.CreateModel())//创建信道，通信管道        {            //创建队列，参数1队列名称，参数2是否持久化, 队列的声明默认是存放到内存中的            //参数3队列中的数据消费完成后是否自动删除队列，参数4是否排外的队列，参数5是否等待服务器返回            channel.QueueDeclare(NameKey, false, false, false, null);            //没绑定交换机，使用rabbitmq默认交换机            foreach (var row in intlist)            {                string message = row.ToString();                var body = Encoding.UTF8.GetBytes(message);                msg += message + ",";                //发布消息队列 参数1交换器名称这里为空，参数2路由名称，参数3发送消息附带属性,参数4就是要处理数据                channel.BasicPublish("", NameKey, null, body);//                Console.WriteLine(row);                Thread.Sleep(100);            }        }    }    Console.WriteLine(msg);}

using RabbitMQ.Client.Events;using RabbitMQ.Client;using System.Text;using System.Runtime.CompilerServices;using System.Threading.Channels;
Console.WriteLine("消费者调用!");Consumption();Console.ReadLine();static void Consumption(){    //创建Factory连接请求 下面这块可以新建一个类或者方法。这里为了更直观    ConnectionFactory conFactory = new ConnectionFactory    {        UserName = "test",        Password = "123456",        HostName = "192.168.240.160",        // Port = 15672;//如果是默认不用设置        DispatchConsumersAsync = false//是否异步请求    };    var NameKey = "MQfirst";    using (var connection = conFactory.CreateConnection())    {        using (var channel = connection.CreateModel())//创建信道，通信管道        {            //声明一个队列            channel.QueueDeclare(NameKey, false, false, false, null);            int count = 1;            while (true)//循环作用便于测试用            {                //绑定交换机                var consumer = new EventingBasicConsumer(channel);                //设置消费者权重 参数一是可接收消息的大小的                //第二个参数是处理消息最大的数量                //第三个参数则设置了是不是针对整个Connection的,如果是false则说明只是针对于这个Channel                channel.BasicQos(0, 1, false);                consumer.Received += (model, ea) =>                {                    var message = "";                     message = Encoding.UTF8.GetString(ea.Body.ToArray());                     Console.WriteLine(message);                    count++;                    //确认该消息已被消费                    channel.BasicAck(ea.DeliveryTag, false);
                };               // BasicConsume方法会将信道（Channel）置为接收模式，直到取消队列的订阅                channel.BasicConsume(NameKey, false, consumer);                Thread.Sleep(1000);            }        }    }}