前言:
开源版本Rocket和商业版本的RocketMQ有些不同,研究的是商业版本的RocketMQ,阿里云的官方文档,感觉有点乱。看不咋明白,网上虽然有教程,大都还是有点缺少,有时候会突然跳了步骤,抹去了一些细节。
前置步骤
阿里云MQ开通及子Access账号的权限的生成
阿里云MQ开通
开通阿里云MQ(现在叫阿里云RocketMQ)百度的教程够用,不多记录,需要的参考该地址http://mtw.so/5Q5nHp,进行开通。PS:页面由于开发人员一直在更新,教程的页面不一定和现有页面完全一样,所以不要死脑筋。
子Access账号
阿里云可以为账号,创建两个字段,用于你身份的验证,下图中可以进入申请子账户
跳出提示,选择开始使用子用户AccessKey
点击 创建用户
点击确定,会要你验证手机,输入验证码即可
创建完以后会给你两个字段的值,一个是AccessKey ID
和AccessKey Secret
一定要及时妥善保存,虽然可以重新创建
ps:这里别忘了给账户赋予MQ的权限,不然无法进行消息的订阅和发送
如何设置权限?
点击添加权限,添加以下权限
Topic和Group的创建(在阿里云控制台页面进行)
首先创建实例,点击创建实例
点击确定
按提示创建Group和Topic 即可,然后将Group和Topic的名称,填入到application.properties
对应字段中
nameSrvAddr的获取,在创建好Group和Topic后,从这进入到接入点的获取页面
接入点有两个,分别对应了不同的接入方式。TCP和HTTP,我这里用的TCP协议的接入方式
这里只能获取到公网的接入地址,没有内网
开始开发
SpringBoot整合阿里云RocketMQ(普通消息为例)
Maven工程
POM文件依赖
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/1592.shtml
如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!