返回

Spring Boot快速集成RocketMQ实战教程

前言

RocketMQ是目前主流的消息中间件之一,并且自身就支持分布式功能。最初由阿里巴巴团队开发,并且经历过双十一等海量消息场景的考验,后捐赠给Apache开源基金会,这也是为什么我们经常听说RocketMQ是阿里巴巴的消息中间件,项目却在Apache的顶级项目中。

网络上通过SpringBoot集成RocketMQ的教程很多,但大多数都无法做到快速、通用的进行集成。本篇文章带大家快速完成基于Spring Boot的集成使用,同时针对一些集成过程中的概念和使用方法以实例进行讲解。

RocketMQ的部署

关于RocketMQ的部署,通常有单Master模式、多Master模式、多Master多Slave模式(异步复制或同步双写)等。

本文重点介绍RocketMQ的集成部分,就不再这里讲解如何部署Master的部署过程,读者学习时只需部署单机模式或基于Docker部署即可。

依赖集成

首先创建一个SpringBoot项目,为了方便通过浏览器访问测试,引入web对应的starter。


    org.springframework.boot
    spring-boot-starter-parent
    2.4.0
     


    
        org.springframework.boot&
复制

相关知识