这里用的是最新的spring-rabbit版本2.0.0.M5 最新的spring-rabbit要求Spring Framework的最低版本为5.0.x,amqp-client的最低版本为4.1.x(
上篇《Spring集成RabbiMQ-Spring AMQP新特性》我们了解了最新spring-rabbit的2.0.0.M5版本相较于之前有哪些变化。 其实使用Spring-amqp确实简单,其主要就一些jar包,比如spring-amqp,spring-rabbit等。
scope> </dependency> </dependencies> </dependencyManagement> 如果你想使用RabbitMQ 或者Kafka 替代 HTTP ,需先引入 spring-rabbit 如果你使用的是RabbitMQ,需要添加 spring-cloud-starter-zipkin 和 spring-rabbit 依赖。 artifactId> </dependency> <dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit 如果你依赖的是spring-rabbit,那么应用程序会将追踪记录发送到Rabbit MQ代理,而不是HTTP。
Spring AMQP Spring AMQP包括两个模块:spring-amqp和spring-rabbit。 Maven 依赖 为了将spring-amqp和spring-rabbit模块添加到我们的项目中,我们将spring-boot-starter-amqp依赖项添加到我们的pom.xml: <dependencies
客户端增加依赖 以下两个依赖任选其一就可以 <dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit
我们使用的spring-rabbit的版本是当前官方最新的2.0.0.M5,这篇主要介绍下最新版本的spring amqp相对老版本有哪些新特性和升级。
13. spring-rabbit 版本兼容 升级之后,由于中间件封装了 rabbit 的一些功能,去掉了 spring-rabbit的自动装配,导致基本上整个中间件包不可用,大量方法不兼容。
Spring-amqp是对AMQP协议的抽象实现,而spring-rabbit 是对协议的具体实现,也是目前的唯一实现。底层使用的就是RabbitMQ。
Spring Boot 整合 RabbitMQ 简介 在Spring项目中,可以使用Spring-Rabbit去操作RabbitMQ 尤其是在spring boot项目中只需要引入对应的amqp启动器依赖即可
dependency> <dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit
/artifactId> </dependency> <dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit
准备 开始之前,首先添加上必要的依赖,主要利用 spring-rabbit 来实现,这个依赖中,内部又依赖的Spring相关的模块,下面统一改成5.0.4版本 <dependencies> <dependency dependency> <dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit
RabbitHandler;可以按照队列的名字作为web的url;实现会很简单, 项目的代码中并不需要做改动 消费者在转发web接口后,可以发送一个成功/失败的事件,这样子就避免了部分项目认为所有消息都不可丢失的问题 spring-rabbit
Spring支持 • spring-jms提供了对JMS的支持 • spring-rabbit提供了对AMQP的支持 • 需要ConnectionFactory的实现来连接消息代理 • 提供JmsTemplate
AMQP,只需要引入spring-boot-starter-amqp,spring-boot-starter-amqp会自动的集成spring-boot-starter、spring-messaging和spring-rabbit
<dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit <dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit e) { e.printStackTrace(); } } } 二、Spring Boot整合RabbitMQ 1.简介 在Spring项目中,可以使用Spring-Rabbit
异步链路追踪 官方文档 jar依赖 额外增加mq的依赖 <dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit
<dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit <dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit
spring-boot-starter:核心启动器,包含了自动配置、日志和YAML spring-boot-starter-web:构建Web应用,使用 Tomcat 作为内嵌容器 spring-boot-starter-amqp:通过spring-rabbit
3)spring-boot-starter-amqp 通过spring-rabbit来支持AMQP协议(Advanced Message Queuing Protocol)。