rabbitMQ简单模拟

1、模拟服务端（发送者）

static void Main(string[] args)
        {
            var factory = new ConnectionFactory();
            factory.HostName = "localhost";//主机名，Rabbit会拿这个IP生成一个endpoint，这个很熟悉吧，就是socket绑定的那个终结点。
            factory.UserName = "guest";//默认用户名,用户可以在服务端自定义创建，有相关命令行
            factory.Password = "guest";//默认密码

            using (var connection = factory.CreateConnection())//连接服务器，即正在创建终结点。
            {
                //创建一个通道，这个就是Rabbit自己定义的规则了，如果自己写消息队列，这个就可以 
                开脑洞设计了
                //这里Rabbit的玩法就是一个通道channel下包含多个队列Queue
                using (var channel = connection.CreateModel())
                {
                    //channel.QueueDeclare("kibaQueue", false, false, false, null);//创建 
                    一个名称为kibaQueue的消息队列
                    //var properties = channel.CreateBasicProperties();
                    //properties.DeliveryMode = 1;
                    //string message = "I am Kiba518"; //传递的消息内容
                    //channel.BasicPublish("", "kibaQueue", properties, 
                    Encoding.UTF8.GetBytes(message)); //生产消息
                    //Console.WriteLine($"Send:{message}");
                    
                    //模拟100次
                    for (int i = 0; i < 100; i++)
                    {
                        channel.QueueDeclare("kibaQueue", false, false, false, null);//创 
                        建一个名称为kibaQueue的消息队列
                        var properties = channel.CreateBasicProperties();
                        properties.DeliveryMode = 1;
                        string message = "I am Kiba518"; //传递的消息内容
                        channel.BasicPublish("", "kibaQueue", properties, 
                        Encoding.UTF8.GetBytes(message)); //生产消息
                        Console.WriteLine($"Send:{message}");
                        Thread.Sleep(3000);
                    }
                }
            }
        }

2、下面是客户端（消费者）

static void Main(string[] args)
        {
            var factory = new ConnectionFactory();
            factory.HostName = "localhost";
            factory.UserName = "guest";
            factory.Password = "guest";

            using (var connection = factory.CreateConnection())
            {
                using (var channel = connection.CreateModel())
                {
                    channel.QueueDeclare("kibaQueue", false, false, false, null);

                    var consumer = new EventingBasicConsumer(channel);
                    channel.BasicConsume("kibaQueue", false, consumer);
                    consumer.Received += (model, ea) =>
                    {
                        var body = ea.Body;
                        var message = Encoding.Default.GetString(body.ToArray());
                        Console.WriteLine("已接收： {0}", message);
                    };
                    Console.ReadLine();
                }
            }
        }