RabbitMQ的工作模式


工作模式

rabbitmq

工作模式下的生产者将消息发送至队列,多个消费者从队列中获取消息并处理,但每条消息只能被一个消费者处理,这种模式可以实现任务的并行处理。

工作模式适用于需要高并发处理的任务,如红包发放、资源调度等。

使用示例

应用测试

1、生产者P1与P2分别发送消息至队列test.work.queue中。

1.1、生产者P1发送消息。

rabbitmq

1.2、生产者P2发送消息。

rabbitmq

2、消费者C1与C2在队列test.work.queue消费端读取消息,每一条消息只能被一个消费者读取。

2.1、消费者C1读取了第一条消息。

rabbitmq

2.2、消费者C2读取了第二条消息。

rabbitmq

查看后台

1、查看连接Connections,两个生产者与两个消费者共计四个连接,所有连接的状态(State)均为运行中(running)。

rabbitmq

2、查看信道Channels,每一个连接可以有多个信道,示例中的每个连接只有一个信道,状态(State)均为空闲(Idle)。

rabbitmq

3、查看交换机Exchanges,工作队列模式不需要使用交换机,所以Exchages表格只有系统默认交换机。

rabbitmq

4、查看队列Queues,Queues表格中显示了队列test.work.queue的当前状态(State)为空闲(Idle)。

rabbitmq

发表评论

评论数量:0