欢迎来到“雪碧聊技术”CSDN博客!
在这里,您将踏入一个专注于Java开发技术的知识殿堂。无论您是Java编程的初学者,还是具有一定经验的开发者,相信我的博客都能为您提供宝贵的学习资源和实用技巧。作为您的技术向导,我将不断探索Java的深邃世界,分享最新的技术动态、实战经验以及项目心得。
让我们一同在Java的广阔天地中遨游,携手提升技术能力,共创美好未来!感谢您的关注与支持,期待在“雪碧聊技术”与您共同成长!
一、快速入门
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、总结
版权归原作者 雪碧聊技术 所有, 如有侵权,请联系我们删除。