详解AMQP协议以及JAVA体系中的AMQP

这篇具有很好参考价值的文章主要介绍了详解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定义的抽象模型如下:

详解AMQP协议以及JAVA体系中的AMQP,中间件,java,中间件,java ee,原力计划

  • 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,让开发者可以轻松地与不同消息队列系统交互,而无需关注底层实现细节。

主要特点和功能:

  1. 连接管理和资源抽象:Spring AMQP 管理与消息代理的连接,并提供了一组抽象类和接口来管理消息传递的资源,如交换器、队列、绑定等。

  2. 消息监听容器:Spring AMQP 提供消息监听容器,用于在应用程序中注册消息监听器,并处理从消息队列接收到的消息。

  3. 消息转换:Spring AMQP 支持消息转换,使得将消息从 Java 对象转换为消息队列所需的格式(如 JSON 或字节)变得更加简单。

  4. 事务支持:Spring AMQP 允许将消息传递操作与 Spring 的声明式事务管理结合使用,确保消息的可靠传递和处理。

  5. 消息发送和接收:Spring AMQP 提供发送和接收消息的 API,使得在应用程序中进行消息的发送和接收变得简单而灵活。

  6. 异步处理:Spring AMQP 支持异步消息处理,使得应用程序能够更高效地处理大量消息。

  7. 与 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去找不同的队列即可。

详解AMQP协议以及JAVA体系中的AMQP,中间件,java,中间件,java ee,原力计划

依赖:

<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

RabbitMQ的配置:

spring:
  rabbitmq:
    host: 192.168.31.10
    port: 5672 #通过控制台可以查看
    username: guest
    password: guest
    virtual-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 {
    @Bean
    public Queue queue_01() {
        //durable,是否开启持久化
        return new Queue("queue_01",false);
    }
    @Bean
    public Queue queue_02(){
        return new Queue("queue_02",false);
    }
 
    //路由模式的交换机
    @Bean
    public DirectExchange directExchange(){
        return new DirectExchange("direct_exchange",false,false);
    }
 
    //将队列绑定到交换机上
    @Bean
    public Binding bindingSmsQueue_01(@Qualifier("queue_01") Queue logsAccess, DirectExchange directExchange) {
        return BindingBuilder.bind(logsAccess).to(directExchange).with("routing_key_01");
    }
    @Bean
    public 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 {
    @Autowired
    private RabbitTemplate rabbitTemplate;
 
    @Test
    public void simpleTest() {
        rabbitTemplate.convertAndSend("direct_exchange","routing_key_01","helo world!");
    }
}

消费者:文章来源地址https://www.toymoban.com/news/detail-621753.html

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的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • go gin 全局中间件,以及设置值

    2024年02月11日
    浏览(37)
  • django中的中间件

    在Django中,中间件(Middleware)是一个轻量级的、底层的“插件”系统,用于全局地修改Django的输入或输出。每个中间件组件都负责执行一些特定的任务,比如检查用户是否登录、处理日志、GZIP压缩等。Django的中间件提供了一种方便的方式来处理一些全局的任务,而不需要在

    2024年02月19日
    浏览(45)
  • Ubuntu配置基本环境以及docker安装基本中间件

    提示:ip地址请改为自己的本地ip 为了安全性,建议都给一些中间件设置密码(本文也会教大家如何设置密码) 此处如果安装失败,apt要换源。 docker版本为24.0.2 首先,更新软件包索引,并且安装必要的依赖软件,来添加一个新的 HTTPS 软件源: 使用下面的 curl 导入源仓库的

    2024年02月01日
    浏览(54)
  • 82 # koa-bodyparser 中间件的使用以及实现

    安装依赖 koa 文档:https://koajs.cn/# koa 中不能用回调的方式来实现,因为 async 函数执行的时候不会等待回调完成 koa 中所有的异步都必须是 promise,只有 promise 才有等待效果,必须所有的 next 方法前需要有 await、return 否则没有等待效果 实现一个表单提交功能 server.js : 启动服

    2024年02月09日
    浏览(47)
  • 【视频中间件】国标(GB28181)协议接入并输出标准FLV/RTSP/HLS流

    在安防行业发展的今天,现目前很多企业单位均建设有视频管理平台,跨部门、跨系统的视频资源联网共享需求也越来越多,随着网络高速提升与发展,视频数据的互联互通共享也变得更加的便捷。目前视频平台互联最为常见的互通协议就是GB/T 28181,随着协议的不断完善及成

    2024年04月12日
    浏览(31)
  • 消息中间件RabbitMQ详解

    消息中间件利用高效可靠的消息传递机制进行平台无关的数据交流,并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息排队模型,它可以在分布式环境下扩展进程间的通信。 消息中间件适用于需要可靠的数据传送的分布式环境。采用消息中间件机制的系统中

    2024年02月16日
    浏览(77)
  • 消息中间件面试题详解

      延迟队列:进入队列的消息会被延迟消费的队列 场景:超时订单,限时优惠,定时发布 延迟队列 = 死信交换机 + TTL(生存时间)     kafka高可用机制  kafka数据清理机制    kafka高性能设计

    2024年02月12日
    浏览(46)
  • 消息中间件之AcitveMQ详解

    前面我们有一篇关于A c t i v e M Q的安装教程,相信有很多小伙伴已经都了解到怎么安装了!今天我们看一下如何使用这一老牌的消 息 中 间 件 使用之前我们先了解一下消 息 中 间 件的定义,看一下百度百科给我们的定义! 应用系统间消 息 传 输 服 务 软 件 消 息 中 间 件

    2024年02月08日
    浏览(54)
  • 虹科教程 | Linux网络命名空间与虹科PROFINET协议栈的GOAL中间件结合使用

    PROFINET是由PI推出的开放式工业以太网标准,它使用TCP/IP等IT标准,并由IEC 61158和IEC 61784 标准化,具有实时功能,并能够无缝集成到现场总线系统中。凭借其技术的开放性、灵活性和性能优势,PROFINET可应用于过程/工厂自动化、运动控制等领域。通过PROFINET,可实现确定性响应

    2024年02月13日
    浏览(48)
  • 视频中间件:大华IPC/NVR 主动注册协议接入并输出标准FLV/RTSP/HLS流

    大华主动注册协议是类似海康E-home、ISUP协议,也是前端设备向中心平台和服务注册的一种主动注册协议,对于前端网络无固定IP情况下对视频的联网、视频上云等场景应用尤为适用。行业主动注册标准协议还有GB28181、JTT1078等,如何实现多协议的兼容适配,并输出标准化通用

    2024年02月12日
    浏览(51)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包