请选择 进入手机版 | 继续访问电脑版
MSIPO技术圈 首页 IT技术 查看内容

阿里云RockMQ与SpringBoot的整合

2023-07-13

前言:

开源版本Rocket和商业版本的RocketMQ有些不同,研究的是商业版本的RocketMQ,阿里云的官方文档,感觉有点乱。看不咋明白,网上虽然有教程,大都还是有点缺少,有时候会突然跳了步骤,抹去了一些细节。

前置步骤

阿里云MQ开通及子Access账号的权限的生成

阿里云MQ开通

开通阿里云MQ(现在叫阿里云RocketMQ)百度的教程够用,不多记录,需要的参考该地址http://mtw.so/5Q5nHp,进行开通。PS:页面由于开发人员一直在更新,教程的页面不一定和现有页面完全一样,所以不要死脑筋。

子Access账号

阿里云可以为账号,创建两个字段,用于你身份的验证,下图中可以进入申请子账户

image-20211103143554371

跳出提示,选择开始使用子用户AccessKey

image-20211103143728935

点击 创建用户

image-20211103144038053

image-20211103144205700

点击确定,会要你验证手机,输入验证码即可

创建完以后会给你两个字段的值,一个是AccessKey IDAccessKey Secret一定要及时妥善保存,虽然可以重新创建

image-20211103144539923

ps:这里别忘了给账户赋予MQ的权限,不然无法进行消息的订阅和发送

如何设置权限?

image-20211103144907801

image-20211103145204332

点击添加权限,添加以下权限

image-20211103145226492

Topic和Group的创建(在阿里云控制台页面进行)

首先创建实例,点击创建实例

image-20211103151514954

image-20211103151801021

点击确定

image-20211103151839645

按提示创建Group和Topic 即可,然后将Group和Topic的名称,填入到application.properties对应字段中

nameSrvAddr的获取,在创建好Group和Topic后,从这进入到接入点的获取页面

image-20211103153043593

image-20211103153019978

接入点有两个,分别对应了不同的接入方式。TCP和HTTP,我这里用的TCP协议的接入方式

这里只能获取到公网的接入地址,没有内网

 

开始开发

SpringBoot整合阿里云RocketMQ(普通消息为例)

Maven工程

POM文件依赖

相关阅读

手机版|MSIPO技术圈 皖ICP备19022944号-2

Copyright © 2023, msipo.com

返回顶部