RabbitMQ的简单使用

C#使用RabbitMQ

　rabbitmqctl list_queues可以查看所有的消息队列，以及里面的消息个数，可以看到，目前Rabbitmq上只有一个消息队列，里面只有一条消息：

一个简单的例子如下链接

[c#]RabbitMQ的简单使用

发送消息

创建工程后，先引用RabbitMQ的库RabbitMQ.Client.dll，即第一个dll文件

   //定义连接工厂

    ConnectionFactory factory = new ConnectionFactory();

//指定要连接的RabbitMQ服务地址

        factory.HostName = "localhost";

 //创建一个 AMQP 连接

        using (IConnection connection = factory.CreateConnection())

            using (IModel channel = connection.CreateModel())

 //在MQ上定义一个队列

                channel.QueueDeclare("esbtest.rmq.consoleserver", false, false, false, null);

channel.QueueDeclare("MyRabbitMQ", true, false, false, null);

queueDeclare（名字，是否持久化，独占的queue，不使用时是否自动删除，其他参数）；

RabbitMQ连接报错（1）—— None of the specified endpoints were reachable

1、清空队列中的积压的消息

一、手动删除队列中指定个数的消息
打开RabbitMq管理页面，进入队列。
点击 Get messages
Requeue 改成No

Mesaages 设置一个值

点击Get messages
二、一次清理队列中的所有消息
打开RabbitMq管理页面，进入队列。
点击Purge

点击按钮Purge Messages
————————————————
版权声明：本文为CSDN博主「qq_34004088」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。
原文链接：https://blog.csdn.net/qq_34004088/article/details/90380733

界面属性

Queues

image.png

队列的属性

Virtual host：所属的虚拟主机。
Name：名称。
Features：功能。可以是以下之一，或者不是：D: 持久化。
State：当前的状态，running：运行中；idle：空闲。
Ready：待消费的消息总数。
Unacked：待应答的消息总数。
Total：总数 Ready+Unacked。
incoming：消息进入的速率。
deliver/get：消息获取的速率。
ack：消息应答的速率。

https://blog.csdn.net/vbirdbest/article/details/78577043

RabbitMQ系列文章

详解

RabbitMQ 管理界面解析框架 (一)

RabbitMQ系列（二）深入了解RabbitMQ工作原理及简单使用