当前位置: 首页 > article >正文

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 AMQPicon-default.png?t=O83Ahttps://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、总结


http://www.kler.cn/a/408456.html

相关文章:

  • 基于SSM的婚庆管理系统+LW示例参考
  • 2.2_3 纠错编码—海明码
  • wordpress调用文章上一篇 下一篇的标题和链接
  • AMD(Xilinx) FPGA配置Flash大小选择
  • JavaScript数据类型判断之Object.prototype.toString.call() 的详解
  • uiautomator案例
  • MariaDB面试题及参考答案
  • 【OpenGL】GLFW环境配置 + 扩展GLFW使其可以成为MFC子窗口
  • C0033.在Ubuntu中配置clion的环境
  • 数据集-目标检测系列- 安全背心 检测数据集 safety_vests >> DataBall
  • docker desktop上下载的镜像传到虚拟机上使用
  • Python编程整理汇总(基础汇总版)
  • sed使用扩展正则表达式时, -i 要写在 -r 或 -E 的后面
  • Window11系统下修改Anaconda3默认安装虚拟环境在C盘问题
  • C++设计模式——Singleton单例模式
  • Flask服务封装+Docker服务部署
  • Android OpenGL ES详解——Renderer接口介绍
  • 12-表的约束
  • JVM标量替换
  • mysql-分析并解决可重复读隔离级别发生的删除幻读问题
  • uniapp的列表渲染v-for 与正确写法,循环二维数组
  • 开源网络安全检测工具——伏羲 Fuxi-Scanner
  • 机器学习入门-Scikit-learn
  • 46.坑王驾到第十期:vscode 无法使用 tsc 命令
  • 04 - 尚硅谷 - MQTT 客户端编程
  • 一加ACE 3 Pro手机无法连接电脑传输文件问题