Java项目整合RabbitMQ

 创建一个maven项目。

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

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

 然后我们去运行它：

 

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

 

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

我们去写消费者代码：

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

运行结果：

 

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

 

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

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

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

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

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

 

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

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

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

 

 

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

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

 

 

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

再同样运行一次：
 

 

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