标签：false 队列 factory RabbitMQ var 案例 dotnet using

案例来源：https://www.rabbitmq.com/getstarted.html 

项目能否运行的前提是本地已搭建好RabbitMQ环境

1.新建生产者控制台项目

使用nuget添加RabbitMQ.Client引用

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

namespace RabbitMQ.Producer
{
    class Program
    {
        static void Main(string[] args)
        {
            var factory = new ConnectionFactory();
            factory.HostName = "127.0.0.1";
            factory.Port = 5672;//是服务端的端口号，与页面的端口号15672区分开
            factory.UserName = "guest";
            factory.Password = "guest";
            //factory.VirtualHost = "/";
            //获取TCP长连接
            using (var connection = factory.CreateConnection())
            {
                //创建通信“通道”，相当于TCP的虚拟连接
                using (var channel = connection.CreateModel())
                {
                    /*
                     *创建队列，声明并创建一个队列，如果队列存在，则使用这个队列
                     *第一个参数：队列名称ID
                     *第二个参数：是否持久化，false对应不持久化数据，MQ停掉数据就会数据丢失
                     *第三个参数：是否队列私有化，false则代表所有的消费者都可以访问，true代表只有第一次拥有它的消费者才能一直使用
                     *第四个参数：是否自动删除，false代表连接停掉后不自动删除这个队列
                     *其他额外参数为null
                     */
                    channel.QueueDeclare("hello", true, false, false, null);
                    string message = "hello hobe";
                    var body = Encoding.UTF8.GetBytes(message);
                    /*
                     * exchange：交换机，暂时用不到，在进行发布订阅时才会用到
                     * 路由key
                     * 额外的设置属性
                     * 最后一个参数是要传递的消息字节数组
                     */
                    channel.BasicPublish("", "hello", null, body);
                    Console.WriteLine($"生产者消息：{message}已发送");
                    Console.WriteLine("Press [Enter] to exit");
                    Console.ReadLine();
                }
            }
        }
    }
}

2.新建消费者控制台项目

使用nuget添加RabbitMQ.Client引用

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

namespace RabbitMQ.Consumer
{
    class Program
    {
        static void Main(string[] args)
        {
            var factory = new ConnectionFactory();
            factory.HostName = "127.0.0.1";
            factory.Port = 5672;//是服务端的端口号，与页面的端口号15672区分开
            factory.UserName = "guest";
            factory.Password = "guest";
            //factory.VirtualHost = "/";
            //获取TCP长连接
            using (var connection = factory.CreateConnection())
            {
                //创建通信“通道”，相当于TCP的虚拟连接
                using (var channel = connection.CreateModel())
                {
                    /*
                     *创建队列，声明并创建一个队列，如果队列存在，则使用这个队列
                     *第一个参数：队列名称ID
                     *第二个参数：是否持久化，false对应不持久化数据，MQ停掉数据就会数据丢失
                     *第三个参数：是否队列私有化，false则代表所有的消费者都可以访问，true代表只有第一次拥有它的消费者才能一直使用
                     *第四个参数：是否自动删除，false代表连接停掉后不自动删除这个队列
                     *其他额外参数为null
                     */
                    channel.QueueDeclare("hello", true, false, false, null);

                    EventingBasicConsumer consumers = new EventingBasicConsumer(channel);
                    //触发事件
                    consumers.Received += (model, ea) =>
                    {
                        var body = ea.Body.ToArray();
                        var message = Encoding.UTF8.GetString(body);
                        //false只是确认签收当前的消息，true则代表签收该消费者所有未签收的消息
                        channel.BasicAck(ea.DeliveryTag, false);
                        Console.WriteLine($"消费者接收消息：{message}");
                    };
                    /*
                     * 从MQ服务器中获取数据
                     * 创建一个消息消费者
                     * 第一个参数：队列名
                     * 第二个参数：是否确认自动确认收到消息，false代表手动确认消息，这是MQ推荐的做法
                     * 第三个参数：要传入的BasicConsumer接口
                     */
                    channel.BasicConsume("hello", false, consumers);
                    Console.WriteLine("Press [Enter] to exit");
                    Console.ReadLine();
                }
            }
        }
    }
}

3.运行

两种方式运行都可以：

（1）VS解决方案--属性设置多个项目启动

 运行结果：

标签：false,队列,factory,RabbitMQ,var,案例,dotnet,using
来源： https://www.cnblogs.com/hobelee/p/15730938.html

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