java 使用rabbitmq_java操作RabbitMQ整个过程介绍

落日映苍穹つ 2022-11-02 11:40 100阅读 0赞

一 环境安装

1、安装java工具 IntelliJ IDEA 2019.3 x64

2、安装erl10.7,并配置好path等环境变量，同时验证是否安装成功，见图1、图2.

![3fbb926ce8ceea706fd630fb1cc13cb8.png][]图1

![fea9cf9110f19d9b40de2f2aea6ef6e2.png][]图2

3、安装RabbitMQ3.8.3

![23fad7c1d02460223716a9e81d833432.png][]图3

cmd进入上述路径，执行 rabbitmqctl status命令，部分截图如下：说明mq未启动

![c8792d49c68cc0887c735a229dd41acd.png][]图4

我们将mq启动下，执行rabbitmq-server.bat，浏览器输入127.0.0.1:15672/

用户名和密码默认guest,输入后进入MQ管理控制台。

![446bde9d84f45cd7aee04646021accb2.png][]图5

![944f9cb9c39bfc7a3376ffc94ef934ab.png][]图6

二java操作MQ

实际项目中，如果有大量的操作我们不需要即时拿到结果，因此不用等待它执行结束，使用异步操作。将操作放入队列里，按部就班的执行队列里的任务，将结果储存起来，以便后续需要这部分数据时，再取出来应用。RabbitMQ里有队列，使用队列储存信息，因此，我们要学的就是如何操作RabbitMQ的队列，使之为我们服务。

1、导入mq包

org.springframework.boot

spring-boot-starter-amqp

2、增加配置

\#配置 rabbitmq

spring.rabbitmq.host=127.0.0.1

spring.rabbitmq.port=15672

spring.rabbitmq.username=guest

spring.rabbitmq.password=guest

spring.rabbitmq.listener.concurrency=10

spring.rabbitmq.listener.max-concurrency=20

spring.rabbitmq.listener.prefetch=5

3 java代码

java配置：

![f9d1bcf2308b649c83c11ac95548b85b.png][]图7

向队列发送信息：

![940c9b940b10ce4af8855fa2cb8aaddc.png][]图8

接收信息：

![e7153537044d16a7a068ae345982dafa.png][]图9

三 测试

postman发送请求：

![661f356b8569d208494b6e6733661cf3.png][]图10

接收消息：

![1805b160b4565a7b02794de6abc1e144.png][]图11

发送消息时，rabbitMQ界面上有管道发送消息速度和接收消息速度，发送和接收都完成后，速度恢复为0.

![3a90487287e1ad029f668595eb999984.png][]图12

四总结

本节介绍了RabbitMQ的安装过程，并且用java实际操作验证了rabbitMQ队列的功能。

[3fbb926ce8ceea706fd630fb1cc13cb8.png]: /images/20221024/b05f66cba88c4ac19454a3f6e62566db.png
[fea9cf9110f19d9b40de2f2aea6ef6e2.png]: /images/20221024/ec0b696b8c50462188ea9982e952ffef.png
[23fad7c1d02460223716a9e81d833432.png]: /images/20221024/c1b8a43973274ce9a9f19f9bdce3069d.png
[c8792d49c68cc0887c735a229dd41acd.png]: /images/20221024/460c3ada90c04bf89178397f2f196e9c.png
[446bde9d84f45cd7aee04646021accb2.png]: /images/20221024/460bca6260764847987c59d1edc9745a.png
[944f9cb9c39bfc7a3376ffc94ef934ab.png]: /images/20221024/0bcceb46a4224e39ab26f5c79210797f.png
[f9d1bcf2308b649c83c11ac95548b85b.png]: /images/20221024/1dd6d88584954ef2a66f6fe99e1c2ef7.png
[940c9b940b10ce4af8855fa2cb8aaddc.png]: /images/20221024/f04f1729b74c41d5abc612c696103c66.png
[e7153537044d16a7a068ae345982dafa.png]: /images/20221024/297069a3d46a4f7fb57d0c886b464a7c.png
[661f356b8569d208494b6e6733661cf3.png]: /images/20221024/fa8168e1bb7c48739d0bf7ab9854d581.png
[1805b160b4565a7b02794de6abc1e144.png]: /images/20221024/60b1317d8a614d81abf2f63267aecfb5.png
[3a90487287e1ad029f668595eb999984.png]: /images/20221024/210b623843d841f88ced66b143510f4f.png