详解AMQP协议以及JAVA体系中的AMQP
目录
1.概述
1.1.简介
1.2.抽象模型
2.spring中的amqp
2.1.spring amqp
2.2.spring boot amqp
1.概述
1.1.简介
AMQP,Advanced Message Queuing Protocol,高级消息队列协议。
百度百科上的介绍:
一个提供统一消息服务的应用层标准高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息,并不受客户中间件不同产品,不同的开发语言等条件的限制。
将上面的话翻译成人话,AMQP就是一个协议,核心内容就是为消息中间件提出了一个抽象模型,规定了消息中间件应该有哪些实体组成。当前市面上的消息中间件五花八门,其架构也是五花八门,AMQP其实就是希望能为消息中间件提供一个统一的标准。使用统一标准的消息中间件更便于管理,就算大型的系统中有多种消息中间件,因为其架构中实体是一样的,都能抽象出一套统一的API来操作。
1.2.抽象模型
AMQP定义的抽象模型如下:
-
Broker(消息代理)
-
Producer(生产者)
-
Consumer(消费者)
-
Exchange(交换器)
-
Queue(队列)
-
Binding(绑定)
-
Connection(连接)
-
Channel(信道)
Broker(消息代理)
可以理解为一个MQ节点即可。AMQP 中的消息代理是消息传递的核心组件。它负责接收、存储和传递消息,并将消息路由到正确的目的地。消息代理可以有多个,形成一个消息代理集群,用于分布式和高可用的消息传递。
Producer(生产者)
生产者是消息的发送者,它负责创建并发送消息到消息代理。生产者不需要关心消息的具体路由,只需将消息发送到指定的交换器即可。
Consumer(消费者)
消费者是消息的接收者,它订阅感兴趣的消息,从消息代理中接收并处理消息。消费者可以订阅一个或多个队列,接收符合条件的消息。
Exchange(交换器)
交换器是消息的路由器,它接收从生产者发送的消息,并根据消息的路由键将消息路由到一个或多个队列中。交换器根据不同的路由策略将消息发送到不同的队列。
Queue(队列)
队列是消息的存储位置,它保存待被消费的消息。消息代理将消息发送到队列后,等待消费者从队列中取出消息进行处理。
Binding(绑定)
绑定是交换器和队列之间的关联关系。通过绑定,交换器将消息路由到队列中,使得生产者发送的消息能够被消费者接收。
Connection(连接)
连接是客户端和消息代理之间的物理连接。客户端使用连接与消息代理进行通信,发送和接收消息。
Channel(信道)
信道是 AMQP 连接内的一个虚拟连接,用于在客户端和消息代理之间进行通信。通过信道,客户端可以创建和使用交换器、队列、绑定,发送和接收消息,而无需在每次通信时都创建新的 TCP 连接。
2.spring中的amqp
2.1.spring amqp
spring作为一个java后端的一个”粘合剂“其对各个JAVA EE场景都提供了自己的支持,如访问数据库的Spring Data,用于安全保障的Spring Security等等,当然也有用来访问MQ的spring amqp,顾名思义spring amqp就是用来操作满足amqp协议标准的MQ的Spring提供的默认支持。
Spring AMQP 提供了一个简单而强大的抽象层,使得在 Spring 应用程序中使用消息队列变得更加容易。它的主要目标是提供统一的 API,让开发者可以轻松地与不同消息队列系统交互,而无需关注底层实现细节。
主要特点和功能:
-
连接管理和资源抽象:Spring AMQP 管理与消息代理的连接,并提供了一组抽象类和接口来管理消息传递的资源,如交换器、队列、绑定等。
-
消息监听容器:Spring AMQP 提供消息监听容器,用于在应用程序中注册消息监听器,并处理从消息队列接收到的消息。
-
消息转换:Spring AMQP 支持消息转换,使得将消息从 Java 对象转换为消息队列所需的格式(如 JSON 或字节)变得更加简单。
-
事务支持:Spring AMQP 允许将消息传递操作与 Spring 的声明式事务管理结合使用,确保消息的可靠传递和处理。
-
消息发送和接收:Spring AMQP 提供发送和接收消息的 API,使得在应用程序中进行消息的发送和接收变得简单而灵活。
-
异步处理:Spring AMQP 支持异步消息处理,使得应用程序能够更高效地处理大量消息。
-
与 Spring 生态系统集成:Spring AMQP 与其他 Spring 项目紧密集成,例如 Spring Boot 和 Spring Integration,使得在 Spring 生态系统中构建分布式和消息驱动的应用程序更加容易。
spring amqp的使用在官网上有详细的官方文档的说明,此处不展开讲解。
需要注意的是,Spring AMQP 是专门用于支持符合 AMQP 协议的消息队列系统,如 RabbitMQ。如果要与不符合 AMQP 协议的消息队列系统(如 Kafka、RocketMQ)进行交互,则要用他们官方或者社区提供的自己实现的Spring集成库。
2.2.spring boot amqp
现在开发,我们用的更多的当然是spring boot,其实其底层封装的就是spring amqp,这里给出一个用spring-boot-starter-amqp去操作rabbitmq的示例感受一下。关于更详细的内容,有兴趣可以移步博主的另一片文章其中有详细介绍:
SpringBoot RabbitMq 六大模式_springboot整合rabbitmq六种模式__BugMan的博客-CSDN博客
这里我们以RabbitMQ的路由模式为例:
RabbitMQ的路由模式就是发布订阅模式,通过routing key将不同的消息投递到不同的队列中去,消费者根据想要订阅的routing key去找不同的队列即可。
依赖:
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId> </dependency>
RabbitMQ的配置:
spring:rabbitmq:host: 192.168.31.10port: 5672 #通过控制台可以查看username: guestpassword: guestvirtual-host: /vhost_sys_logs #可以不配置,会使用的是默认virtual-host
配置类:
import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class RabbitMQConfig {@Beanpublic Queue queue_01() {//durable,是否开启持久化return new Queue("queue_01",false);}@Beanpublic Queue queue_02(){return new Queue("queue_02",false);}//路由模式的交换机@Beanpublic DirectExchange directExchange(){return new DirectExchange("direct_exchange",false,false);}//将队列绑定到交换机上@Beanpublic Binding bindingSmsQueue_01(@Qualifier("queue_01") Queue logsAccess, DirectExchange directExchange) {return BindingBuilder.bind(logsAccess).to(directExchange).with("routing_key_01");}@Beanpublic Binding bindingSmsQueue_02(@Qualifier("queue_02") Queue logsError, DirectExchange directExchange) {return BindingBuilder.bind(logsError).to(directExchange).with("routing_key_02");}
}
生产者:
@SpringBootTest(classes=PrivilegeSystemMain.class)
public class RabbitMQTest {@Autowiredprivate RabbitTemplate rabbitTemplate;@Testpublic void simpleTest() {rabbitTemplate.convertAndSend("direct_exchange","routing_key_01","helo world!");}
}
消费者:
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Component
@Slf4j
public class ConsumeBean {@RabbitListener(queues={"queue_01"})public void consumer_01(String message){log.info("consumer_01 get message "+message);}@RabbitListener(queues={"queue_02"})public void consumer_02(String message){log.info("consumer_02 get message "+message);}
}
相关文章:

详解AMQP协议以及JAVA体系中的AMQP
目录 1.概述 1.1.简介 1.2.抽象模型 2.spring中的amqp 2.1.spring amqp 2.2.spring boot amqp 1.概述 1.1.简介 AMQP,Advanced Message Queuing Protocol,高级消息队列协议。 百度百科上的介绍: 一个提供统一消息服务的应用层标准高…...

跨境电商外贸常态下,深度分析Live Market的优势
据统计,今年上半年,面对复杂严峻的外部环境,我国外贸进出口规模在历史同期首次突破20万亿元,展现较强韧性。我国正处于大力支持跨境电商发展的时代节点。在此背景下,无数商家准备抓住时代机遇,将品牌影响力从国内延伸至全世界。同…...
vue2企业级项目(八)
vue2企业级项目(八) 组件封装(二) 4、searchForm 创建components/searchForm/index.js import XSearchForm from "./index.vue"; export default XSearchForm;使用案例 <template><div class"wrap"…...

小研究 - 主动式微服务细粒度弹性缩放算法研究(二)
微服务架构已成为云数据中心的基本服务架构。但目前关于微服务系统弹性缩放的研究大多是基于服务或实例级别的水平缩放,忽略了能够充分利用单台服务器资源的细粒度垂直缩放,从而导致资源浪费。为此,本文设计了主动式微服务细粒度弹性缩放算法…...

【雕爷学编程】Arduino动手做(177)---ESP-32 掌控板
37款传感器与执行器的提法,在网络上广泛流传,其实Arduino能够兼容的传感器模块肯定是不止这37种的。鉴于本人手头积累了一些传感器和执行器模块,依照实践出真知(一定要动手做)的理念,以学习和交流为目的&am…...

使用Gunicorn+Nginx部署Flask项目
部署-开发机上的准备工作 确认项目没有bug。用pip freeze > requirements.txt将当前环境的包导出到requirements.txt文件中,方便部署的时候安装。将项目上传到服务器上的/srv目录下。这里以git为例。使用git比其他上传方式(比如使用pycharmÿ…...

【12】STM32·HAL库开发-STM32时钟系统 | F1/F4/F7时钟树 | 配置系统时钟
目录 1.认识时钟树(掌握)1.1什么是时钟?1.2认识时钟树(F1)1.2.1STM32F103时钟树简图1.2.2STM32CubeMX时钟树(F103) 1.3认识时钟树(F4)1.3.1F407时钟树1.3.2F429时钟树1.3…...

Kotlin基础(十):函数进阶
前言 本文主要讲解kotlin函数,之前系列文章中提到过函数,本文是kotlin函数的进阶内容。 Kotlin文章列表 Kotlin文章列表: 点击此处跳转查看 目录 1.1 函数基本用法 Kotlin 是一种现代的静态类型编程语言,它在函数的定义和使用上有一些特点…...

计算机视觉(四)神经网络与典型的机器学习步骤
文章目录 神经网络生物神经元人工神经元激活函数导数 人工神经网络“层”的通俗理解 前馈神经网络Delta学习规则前馈神经网络的目标函数梯度下降输出层权重改变量 误差方向传播算法误差传播迭代公式简单的BP算例随机梯度下降(SGD)Mini-batch Gradient De…...

使用easyui的tree组件实现给角色快捷分配权限功能
这篇文章主要介绍怎么实现角色权限的快捷分配功能,不需要像大多数项目的授权一样,使用类似穿梭框的组件来授权。 具体实现:通过菜单树的勾选和取消勾选来给角色分配权限,在这之前,需要得到角色的菜单树,角色…...
Postman打不开/黄屏/一直转圈/Windows
环境背景 内网环境Postman-win64-8.11.1-Setup.exe 问题描述 电脑重启后,打开Postman后,出现加载弹窗:Preparing your workspaces…This might take a few minutes; 等待数分钟后,还是没有反应,于是关闭…...

使用SVM模型完成分类任务
SVM,即支持向量机(Support Vector Machine),是一种常见的机器学习算法,用于分类和回归分析。SVM的基本思想是将数据集映射到高维空间中,在该空间中找到一个最优的超平面,将不同类别的数据点分开…...

计算机毕设 深度学习实现行人重识别 - python opencv yolo Reid
文章目录 0 前言1 课题背景2 效果展示3 行人检测4 行人重识别5 其他工具6 最后 0 前言 🔥 这两年开始毕业设计和毕业答辩的要求和难度不断提升,传统的毕设题目缺少创新和亮点,往往达不到毕业答辩的要求,这两年不断有学弟学妹告诉…...
开发经验分享之:import引入包和@Autowired注入类有什么区别
大家好,我是三叔,很高兴这期又和大家见面了,一个奋斗在互联网的打工人。 import 和 Autowired 想必大家在 Java 开发中使用频率最多的关键字之一了把,这篇博客将解释这两个概念的区别和作用,帮助你更好地理解它们在Ja…...

MySQL和Oracle区别
由于SQL Server不常用,所以这里只针对MySQL数据库和Oracle数据库的区别 (1) 对事务的提交 MySQL默认是自动提交,而Oracle默认不自动提交,需要用户手动提交,需要在写commit;指令或者点击commit按钮 (2) 分页查询 MySQL是直接在SQL…...

QT--day6(人脸识别、图像处理)
人脸识别: /***********************************************************************************头文件****************************************************************************************/#ifndef WIDGET_H #define WIDGET_H#include <QWidget>…...

深度学习:常用优化器Optimizer简介
深度学习:常用优化器Optimizer简介 随机梯度下降SGD带动量的随机梯度下降SGD-MomentumSGDWAdamAdamW 随机梯度下降SGD 梯度下降算法是使权重参数沿着整个训练集的梯度方向下降,但往往深度学习的训练集规模很大,计算整个训练集的梯度需要很大…...
【算法心得】二维dp的状态转移狂练
LCS: LCS变式:使两个字符串变成一样的,删除的和最小 https://leetcode.cn/problems/minimum-ascii-delete-sum-for-two-strings/ 建表 m ∗ n m*n m∗n or ( m 1 ) ∗ ( n 1 ) (m1)*(n1) (m1)∗(n1)? 感觉 ( m 1 ) ∗ ( n …...

JMeter常用内置对象:vars、ctx、prev
在前文 Beanshell Sampler 与 Beanshell 断言 中,初步阐述了JMeter beanshell的使用,接下来归集整理了JMeter beanshell 中常用的内置对象及其使用。 注:示例使用JMeter版本为5.1 1. vars 如 API 文档 所言,这是定义变量的类&a…...

【C++从0到王者】第十四站:list基本使用及其介绍
文章目录 一、list基本介绍二、list基本使用1.尾插头插接口使用2.insert接口使用3.查找某个值所在的位置4.erase接口使用以及迭代器失效5.reverse6.sort7.merge8.unique9.remove11.splice 三、list基本使用完整代码 一、list基本介绍 如下所示,是库里面对list的基本…...

SpringBoot-17-MyBatis动态SQL标签之常用标签
文章目录 1 代码1.1 实体User.java1.2 接口UserMapper.java1.3 映射UserMapper.xml1.3.1 标签if1.3.2 标签if和where1.3.3 标签choose和when和otherwise1.4 UserController.java2 常用动态SQL标签2.1 标签set2.1.1 UserMapper.java2.1.2 UserMapper.xml2.1.3 UserController.ja…...

IDEA运行Tomcat出现乱码问题解决汇总
最近正值期末周,有很多同学在写期末Java web作业时,运行tomcat出现乱码问题,经过多次解决与研究,我做了如下整理: 原因: IDEA本身编码与tomcat的编码与Windows编码不同导致,Windows 系统控制台…...
React 第五十五节 Router 中 useAsyncError的使用详解
前言 useAsyncError 是 React Router v6.4 引入的一个钩子,用于处理异步操作(如数据加载)中的错误。下面我将详细解释其用途并提供代码示例。 一、useAsyncError 用途 处理异步错误:捕获在 loader 或 action 中发生的异步错误替…...

python打卡day49
知识点回顾: 通道注意力模块复习空间注意力模块CBAM的定义 作业:尝试对今天的模型检查参数数目,并用tensorboard查看训练过程 import torch import torch.nn as nn# 定义通道注意力 class ChannelAttention(nn.Module):def __init__(self,…...

无法与IP建立连接,未能下载VSCode服务器
如题,在远程连接服务器的时候突然遇到了这个提示。 查阅了一圈,发现是VSCode版本自动更新惹的祸!!! 在VSCode的帮助->关于这里发现前几天VSCode自动更新了,我的版本号变成了1.100.3 才导致了远程连接出…...
系统设计 --- MongoDB亿级数据查询优化策略
系统设计 --- MongoDB亿级数据查询分表策略 背景Solution --- 分表 背景 使用audit log实现Audi Trail功能 Audit Trail范围: 六个月数据量: 每秒5-7条audi log,共计7千万 – 1亿条数据需要实现全文检索按照时间倒序因为license问题,不能使用ELK只能使用…...

Psychopy音频的使用
Psychopy音频的使用 本文主要解决以下问题: 指定音频引擎与设备;播放音频文件 本文所使用的环境: Python3.10 numpy2.2.6 psychopy2025.1.1 psychtoolbox3.0.19.14 一、音频配置 Psychopy文档链接为Sound - for audio playback — Psy…...

C++ Visual Studio 2017厂商给的源码没有.sln文件 易兆微芯片下载工具加开机动画下载。
1.先用Visual Studio 2017打开Yichip YC31xx loader.vcxproj,再用Visual Studio 2022打开。再保侟就有.sln文件了。 易兆微芯片下载工具加开机动画下载 ExtraDownloadFile1Info.\logo.bin|0|0|10D2000|0 MFC应用兼容CMD 在BOOL CYichipYC31xxloaderDlg::OnIni…...

优选算法第十二讲:队列 + 宽搜 优先级队列
优选算法第十二讲:队列 宽搜 && 优先级队列 1.N叉树的层序遍历2.二叉树的锯齿型层序遍历3.二叉树最大宽度4.在每个树行中找最大值5.优先级队列 -- 最后一块石头的重量6.数据流中的第K大元素7.前K个高频单词8.数据流的中位数 1.N叉树的层序遍历 2.二叉树的锯…...

android13 app的触摸问题定位分析流程
一、知识点 一般来说,触摸问题都是app层面出问题,我们可以在ViewRootImpl.java添加log的方式定位;如果是touchableRegion的计算问题,就会相对比较麻烦了,需要通过adb shell dumpsys input > input.log指令,且通过打印堆栈的方式,逐步定位问题,并找到修改方案。 问题…...