vlambda博客
学习文章列表

经过近四个月的迭代，万众期待的Apach RocketMQ V4.6.0版终于发布啦！该版本发布了多个重磅特性，包括全面支持IPv6，支持请求响应（Request-Reply）模式和轻量级PullConsumer等特性，并做了7项优化、修复了多处bug。

长久以来，该特性被广泛应用在企业集成，金融服务等场景。尤其在金融机构，通常会在内部网络划分很多网络隔离区，隔离区之间通过硬件防火墙隔离。通常情况下，分区可划分为三大类业务区、隔离区、特定功能区。隔离区是用来承载各类前置机，面向互联网或第三方机构提供服务。这个时候，可以把Broker部署在隔离区，而服务提供方隐藏在后方，通过堡垒主机的形式对外提供点对点的可靠服务。具体的流程如图所示：服务请求方根据服务提供方的协议将请求内容设置到Request消息体中，并将该Request消息发送到Broker指定的Topic中；服务提供方订阅相应的Topic，从Broker上获取到服务请求消息，服务提供方收到请求消息后，执行相应的处理后，将该请求的处理结果设置到响应消息Reply的消息体中，并将响应消息发送到Broker上对应的Reply Topic中，之后Broker会将响应消息推送给该服务请求的发送方。

全新的轻量级PullConsumer客户端保留了原有的subsrcibe方法，用户可以订阅感兴趣的topic，并在集群模式下提供自动负载均衡功能。新增assign订阅方式，用户可根据需求自行指定需要被拉取的队列。在消费位点提交方面，提供更加自由的提交方式，包括自动提交消费位点和手动提交消费位点。此外新的pull consumer提供seek接口，用户可以针对特定的队列完成拉取位点的重置；提供pause/resume接口，用户可以暂停和恢复指定队列的拉取。LitePullConsumer提供了更多接收消息的选择，用户能更加自由地控制消息拉取，使Apache RocketMQ更好地应用于大数据、流计算领域。

据不完全统计，有近20位RocketMQ社区的Contributor参与了该版本的贡献，感谢大家的积极参与。近段时间，蚂蚁消息团队也积极活跃在RocketMQ 社区。据透漏，近期会有事件处理等方面的特性回馈给到社区。也非常期待更多的用户、厂商参与到RocketMQ建设中来，共同打造下一代云原生时代消息数据处理平台。

点击阅读原文下载Apache RocketMQ V4.6.0试用