Spring AMQP 源码分析 06 - 手动消息确认

### 准备

## 目标

了解 Spring AMQP 如何手动确认消息已成功消费

## 前置知识

《Spring AMQP 源码分析 04 - MessageListener》

## 相关资源

Offical doc:<http://docs.spring.io/spring-amqp/docs/1.7.3.RELEASE/reference/html/_reference.html#message-listener-adapter>

Sample code:<https://github.com/gordonklg/study>,rabbitmq module

源码版本:Spring AMQP 1.7.3.RELEASE

## 测试代码

gordon.study.rabbitmq.springamqp.AsyncConsumerManualAck.java

### 分析

## 手动消息确认的实现

对于手动消息确认模式(AcknowledgeMode.MANUAL),Spring AMQP 选择让开发者在消息处理逻辑中自己调用 RabbitMQ java client 的 basicAck 方法确认消息。

MessageListener 接口无法满足要求,因为 onMessage 回调方法无法获取 Channel 对象。

Spring AMQP 提供了 ChannelAwareMessageListener 接口,其 onMessage 回调方法包含 Channel 参数,可用于手动确认消息。

示例代码第25行将 SimpleMessageListenerContainer 的消息确认模式设为 MANUAL,第28行实现 ChannelAwareMessageListener 接口,在 onMessage 回调函数中消费消息,并在第33行调用 basicAck 方法确认消息。

调用栈与前篇极为相似:

## 消息转化?

在使用 MessageListener 接口或  ChannelAwareMessageListener 接口时,框架没有做过任何消息转化。

示例代码创建了一用就会出错的 ScornMessageConverter,将之设置给 SimpleMessageListenerContainer。从程序打印可见,ScornMessageConverter 从未被使用。

这也是显而易见的,毕竟 onMessage 回调方法接受的参数是 Message 类型,根本不需要转化。

时间: 2024-12-26 08:51:21

Spring AMQP 源码分析 06 - 手动消息确认的相关文章

Spring AMQP 源码分析 05 - 异常处理

### 准备 ## 目标 了解 Spring AMQP Message Listener 如何处理异常 ## 前置知识 <Spring AMQP 源码分析 04 - MessageListener> ## 相关资源 Offical doc:<http://docs.spring.io/spring-amqp/docs/1.7.3.RELEASE/reference/html/_reference.html#exception-handling> Sample code:<ht

Spring AMQP 源码分析 07 - MessageListenerAdapter

### 准备 ## 目标 了解 Spring AMQP 如何用 POJO 处理消息 ## 前置知识 <Spring AMQP 源码分析 04 - MessageListener> ## 相关资源 Offical doc:<http://docs.spring.io/spring-amqp/docs/1.7.3.RELEASE/reference/html/_reference.html#message-listener-adapter> Sample code:<https:

Spring AMQP 源码分析 08 - XML 配置

### 准备 ## 目标 通过 XML 配置文件使用 Spring AMQP ## 前置知识 <Spring AMQP 源码分析 07 - MessageListenerAdapter> ## 相关资源 Sample code:<https://github.com/gordonklg/study>,rabbitmq module 源码版本:Spring AMQP 1.7.3.RELEASE ## 测试代码 gordon.study.rabbitmq.springamqp.XmlC

Spring AMQP 源码分析 04 - MessageListener

### 准备 ## 目标 了解 Spring AMQP 如何实现异步消息投递(推模式) ## 前置知识 <RabbitMQ入门_05_多线程消费同一队列> ## 相关资源 Quick Tour for the impatient:<http://docs.spring.io/spring-amqp/docs/1.7.3.RELEASE/reference/html/_reference.html#async-consumer> Sample code:<https://git

Spring AMQP 源码分析 01 - Impatient

### 准备 ## 目标 了解 Spring AMQP 核心代码 ## 前置知识 RabbitMQ 入门 ## 相关资源 Quick Tour for the impatient:<http://docs.spring.io/spring-amqp/docs/1.7.3.RELEASE/reference/html/_introduction.html#quick-tour> Sample code:<https://github.com/gordonklg/study>,rabb

spring事务源码分析结合mybatis源码(一)

最近想提升,苦逼程序猿,想了想还是拿最熟悉,之前也一直想看但没看的spring源码来看吧,正好最近在弄事务这部分的东西,就看了下,同时写下随笔记录下,以备后查. spring tx源码分析 这里只分析简单事务也就是DataSourceTransactionManager 首先肯定找入口了,看过spring源码的同学一定都会找spring tx的入口就是在TxAdviceBeanDefinitionParser这里将解析tx的配置,生成TransactionInterceptor对象,这个也就是一

Spring IoC 源码分析 (基于注解) 之 包扫描

在上篇文章Spring IoC 源码分析 (基于注解) 一我们分析到,我们通过AnnotationConfigApplicationContext类传入一个包路径启动Spring之后,会首先初始化包扫描的过滤规则.那我们今天就来看下包扫描的具体过程. 还是先看下面的代码: AnnotationConfigApplicationContext类 //该构造函数会自动扫描以给定的包及其子包下的所有类,并自动识别所有的Spring Bean,将其注册到容器中 public AnnotationConf

spring transaction源码分析--事务架构

1. 引言  事务特性 事务是并发控制的单元,是用户定义的一个操作序列.这些操作要么都做,要么都不做,是一个不可分割的工作单位.通过事务将逻辑相关的一组操作绑定在一起,以便服务器 保持数据的完整性.事务通常是以begin transaction开始,以commit或rollback结束.Commint表示提交,即提交事务的所有操作.具体地说就是将事务中所有对数据的更新写回到磁盘上的物理数据库中去,事务正常结束.Rollback表示回滚,即在事务运行的过程中发生了某种故障,事务不能继续进行,系统将

Spring IOC源码分析之-刷新前的准备工作

目录 ClassPathXmlApplicationContext的注册方式 加载父子容器 配置路径解析 容器刷新 刷新容器之刷新预处理 ClassPathXmlApplicationContext的注册方式 源码分析基于Spring4.3 从ClassPathXmlApplicationContext入口,最终都会调用到 /* * 使用给定父级创建新的ClassPathXmlApplicationContext,从给定的XML文件加载定义信息. * 加载所有的bean 定义信息并且创建所有的单