RabbitMQ3：Java客户端快速入门

欢迎来到“雪碧聊技术”CSDN博客！

在这里，您将踏入一个专注于Java开发技术的知识殿堂。无论您是Java编程的初学者，还是具有一定经验的开发者，相信我的博客都能为您提供宝贵的学习资源和实用技巧。作为您的技术向导，我将不断探索Java的深邃世界，分享最新的技术动态、实战经验以及项目心得。

让我们一同在Java的广阔天地中遨游，携手提升技术能力，共创美好未来！感谢您的关注与支持，期待在“雪碧聊技术”与您共同成长！

目录

一、快速入门

1、什么是AMQP？

2、什么是Spring AMQP？

3、快速入门案例

①案例介绍

②具体操作

第一步：引入Spring AMQP的依赖

第二步：使用控制台，创建队列simple.queue

第三步：在服务端，进行rabbitMQ的配置

第四步：编辑代码，使用rabbitTemplate对象，发送消息到队列中

第五步：编写监听消息的类，使用@RabbitListener注解声明要监听的队列，从队列中获取消息

4、总结

---

一、快速入门

1、什么是AMQP？

        AMQP：Advanced Message Queuing Protocol（高级消息队列协议）。

        解读：首先AMQP是一种协议，类似于http这种，规定了应用程序之间传递消息的标准。

        该协议与语言、平台无关，因此可实现跨语言、跨平台。

2、什么是Spring AMQP？

        Spring AMQP：是基于AMQP协议，定义的一套API规范。提供了模板来发送和接收消息。

        Spring AMQP官方网址：Spring AMQPhttps://spring.io/projects/spring-amqp

3、快速入门案例

①案例介绍

此时是生产者直接将消息放入队列，都没经过交换机这一环节。

可见此入门案例，是helloworld级别的。

②具体操作

• 第一步：引入Spring AMQP的依赖

<!--引入Spring AMQP的依赖-->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId><version>3.2.8</version>
</dependency>

• 第二步：使用控制台，创建队列simple.queue

• 第三步：在服务端，进行rabbitMQ的配置

        注意：端口15672，是之前我们打开的那个rabbitMQ页面。

                   端口5672，是用来发送消息的。 

        操作我们自己的配置文件：

• 第四步：编辑代码，使用rabbitTemplate对象，发送消息到队列中

         手动编写：

        代码执行效果：

        去网页上，查看simple.队列中是否有消息：

第五步：编写监听消息的类，使用@RabbitListener注解声明要监听的队列，从队列中获取消息

@Component //交给spring管理
public class MqListener {@RabbitListener(queues = "simple.queue")public void listenSimpleQueue(String msg){System.out.println("收到了simple.queue队列的消息："+msg);}
}

 注意：这一步，我们只需要写好这个监听类，在项目启动时，就能随时监听到simple.queue队列的消息：

 

4、总结