RabbitMQ学习-第一个dotnet案例

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

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

RabbitMQ学习-第一个dotnet案例

 

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解决方案--属性设置多个项目启动

  RabbitMQ学习-第一个dotnet案例

 运行结果:

RabbitMQ学习-第一个dotnet案例

 

上一篇:PostgreSQL 10.1 手册_前言_4. 进一步的信息


下一篇:『Java』设计模式(Design pattern)之工厂模式(Factory Pattern)