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

  

 运行结果：