0


RabbitMQ学习笔记4(小滴课堂)RabbitMQ工作队列模型实战

Java项目整合RabbitMQ

创建一个maven项目。

然后我们在maven里加上jdk和rabbitmq的依赖设置:

我们写一段生产者的代码:

然后我们去运行它:

可以看到这里有一个队列。

现在我们是可以查看到队列的。

我们去写消费者代码:

这里的之前的代码都是固定的创建工厂和管道,然后在使用Consumer消费者去写自己的业务逻辑。

运行结果:

这里需要注意的是我们的这个要设置成在控制台页面中存在的,不然会报错找不到。

当我们消费完队列的时候我们再去查看,就会发现队列数为0.

我们在工作中可能一个生产者不止对应一个消费者,可能我们一个生产者要对应多个消费者。

所以这里我们来学习一下工作队列要怎么写呢?

我们去更改之前的生产者的代码:

然后我们去更改消费者的代码:

我们复制这个类然后去创建第二个消费者:
我们去启动这两个消费者。

我们可以看到现在的消息为0;

现在我们去运行我们的生产者:

如果我们的生产者时间比较长会导致消费者时间比较慢,这样就不太好。

我们先把之前的队列名称改一下用来区分是新的策略。

消费者2同理,我们只是把等待时间改成1秒。这里的改变只是加了一个消费者限制数。

再同样运行一次:

这就突出了一个能者多劳的特点。


本文转载自: https://blog.csdn.net/weixin_52618349/article/details/131301138
版权归原作者 抹茶味的西瓜汁 所有, 如有侵权,请联系我们删除。

“RabbitMQ学习笔记4(小滴课堂)RabbitMQ工作队列模型实战”的评论:

还没有评论