登录Aliyun主账号,进入访问控制页面,点击【用户管理】,选择右上角的【新建用户】

创建完成后【管理】用户,找到用户AccessKey那一列,选择创建AccessKey并将相关参数保存,结果如下:
这个参数在后面访问MQ服务的时候会用到。

授权用户使用mq的权限,如下图:

开启中间件消息队列服务(MQ),创建Topic并申请发布,申请订阅,定义好对应的标识。基本流程如下:




接下来就是按照对应Producer、Consumer集成方式和接入点进行接入,完成基本配置了。
如果所有的你都做了,最后一步授权忘了做,这很可能无法接入,会报错。

1
2
3
4
5
Exception in thread "main" com.aliyun.openservices.ons.api.exception.ONSClientException: Receive a broker exception, Topi=kaoshi, msgId=null, com.aliyun.openservices.ons.api.impl.authority.exception.AuthenticationException: valid resource owner failed. maybe the resource kaoshi not created, com.alibaba.ons.open.auth.validator.PermissionValidator.check(PermissionValidator.java:66)
See http://docs.aliyun.com/cn#/pub/ons/faq/exceptions&broker_response_exception for further details.
at com.aliyun.openservices.ons.api.impl.rocketmq.ProducerImpl.checkProducerException(ProducerImpl.java:198)
at com.aliyun.openservices.ons.api.impl.rocketmq.ProducerImpl.send(ProducerImpl.java:107)
at com.ksxing.tmp.MqTest.main(MqTest.java:38)

话说回来,要想相对安全的使用阿里云,真的要好好研究一下这个RAM授权机制,所以有时间还得巴拉巴拉文章!
https://ram.console.aliyun.com


简单记录,有待深入挖坑!欢迎留言交流!