揭秘 RocketMQ 的新特性及其在金融场景中的实践

2019 年末，RocketMQ 正式发布了 4.6.0 版本，新增了"Request-Reply"的同步调用的新特性。这一特性是由微众银行的开发者总结实践经验，反馈给社区的成果。本文将深入解析该特性，探讨其在金融场景下的应用实践。

背景

传统的消息中间件通常采用异步消息处理模式，即消息发送方将消息发送到队列后，立即返回，而消息接收方则在收到消息后进行处理。这种模式虽然能提高消息吞吐量，但对于需要即时响应的场景并不适用。

针对这一痛点，RocketMQ 4.6.0 引入了"Request-Reply"特性，支持同步调用模式。在该模式下，消息发送方在发送消息后会阻塞等待接收方的响应，从而实现类似于 RPC 的同步通信。

"Request-Reply"特性详解

"Request-Reply"特性基于 RocketMQ 的原有机制，实现了同步调用的功能。其核心原理如下：

1. 消息发送： 消息发送方将消息发送到指定队列，同时指定一个唯一的 Correlation ID。
2. 消息接收： 消息接收方监听队列，收到消息后根据 Correlation ID 识别出对应的请求消息。
3. 响应消息发送： 消息接收方处理完请求消息后，发送一条响应消息，并将 Correlation ID 设置为与请求消息相同的 Correlation ID。
4. 响应消息接收： 消息发送方收到响应消息后，通过 Correlation ID 匹配出对应的请求消息，并获取响应结果。

在金融场景中的实践

"Request-Reply"特性在金融场景中具有广泛的应用价值，可以满足以下需求：

• 订单查询： 用户发起订单查询时，可以通过"Request-Reply"特性同步获取订单状态，实现实时查询。
• 账户余额查询： 用户查询账户余额时，可以使用"Request-Reply"特性同步获取余额信息，提高查询效率。
• 交易确认： 在交易过程中，可以使用"Request-Reply"特性进行交易确认，确保交易的安全性和可靠性。

微众银行在实践中将"Request-Reply"特性应用于多个金融业务场景，显著提升了系统性能和用户体验。

使用指南

使用 RocketMQ 的"Request-Reply"特性需要进行如下配置：

1. 消息发送： 在发送消息时，设置 replyTo 属性指定响应队列。
2. 消息接收： 在消费消息时，根据 replyTo 属性监听响应队列，并根据 correlationId 识别出对应的请求消息。
3. 响应消息发送： 在处理完请求消息后，通过 correlationId 设置响应消息的 replyTo 属性，并将响应消息发送到请求队列。

总结

RocketMQ 4.6.0 的"Request-Reply"特性为消息中间件提供了同步调用模式，扩展了其应用场景。在金融场景中，该特性可以显著提升系统性能和用户体验，为金融业务创新提供坚实的基础。