消息服务MNS
说到消息服务MNS,那么消息服务MNS是什么呢?为什么会有消息服务MNS这款产品的产生呢?
什么是消息服务MNS
消息服务-阿里云消息服务MNS(Message Service)是一种高效、可靠、安全、便捷和可弹性扩展的分布式消息服务。消息服务MNS能够帮助开发者在应用的分布式组件之间自由地传递数据、通知消息,从而构建松耦合系统。消息服务MNS支持队列模型和主题模型。
消息服务MNS产生
简单来说就是说传统的单体系统架构、单体数据库已经无法满足海量的用户需求,这个时候就需要对原有系统进行升级改造,对大规模的流量进行分解到不同的应用服务中,各个应用服务之间通过消息服务的方式来实现数据传递、通知消息,从而达到松耦合的目的。
消息服务MNS的模型
队列模型和主题模型,其中对列模型就是和我们经常听到的消息队列中间件Kafka、RocketMQ、ActiveMQ、RabbitMQ的基本原理相似,生产者发送消息到队列中,消费者去队列中取出消息进行消费,消息消费完成之后从队列中删除,关于消息服务MNS队列模型的更多术语可以参考文档 消息服务MNS队列模型的基本概念及解释_消息服务MNS-阿里云帮助中心;那么主题模型呢?主题模型就是说比队列模型多了一步,就是在生产者发送消息之前需要先有主题,然后生产者往主题发布消息,消息消费者需要先订阅主题,之后才能从从主题接收消息消费消息。
消息服务MNS基本操作
控制台地址: 阿里云登录 - 欢迎登录阿里云,安全稳定的云计算服务平台,打开控制台,搜索消息服务MNS
免费开通【消息服务MNS】
注意:这里消息服务MNS默认是按量收费。如果使用量较大的建议选择合适的套餐开通。
队列模型基本操作
创建队列
点击【队列列表】,选择【创建队列】,打开如图页面
参数说明:
- 名称:队列名称。
- 消息最大长度:发送到队列的消息体的最大长度。
- 长轮询时间:当队列中没有消息时,该队列的ReceiveMessage请求的最大等待时长。
- 消息可见性超时时间:消息从队列中取出后从Active状态变成Inactive状态后的持续时间。
- 消息保存时长:消息在队列中的最长存活时间。从发送到队列开始经过此参数指定的时间后,不论消息是否被取出都将被删除。
- 消息定时时间:发送到队列的所有消息将延后此参数指定的时间后被消费。
- 启用日志功能:是否开启日志管理功能。
这里是测试用,参数无需特别设置,默认的即可,点击【确定】。
收发消息
点击【消息队列】列表右侧【更多】,选择【收发消息】
输入消息内容,点击【发送消息】,消息发送成功后会收到返回的消息id,同时刷新页面会看到可用消息变为1
点击【接收消息】,会看到刚才的消息被消费,同时可用消息为0
当然,如果你想删除当前队列,可以直接返回列表页选择【更多】-【删除】即可。
主题模型基本操作
主题模型比队列模型多了一步主题的操作,当然也是需要先有消息队列的
创建队列
创建队列的操作和上面一样,这里创建topic01的队列,参数选择默认参数,
这里是个人测试,可以不用开启日志服务,毕竟日志服务也是收费的。
创建主题
点击【主题列表】-【创建主题】,输入主题名称确认。
主题创建完成之后会自动跳转的主题详情页
创建订阅
点击【创建订阅】,输入对应内容,点击【确定】
参数说明:
- 名称:订阅名称。
- 推送类型:订阅的推送类型。默认为队列。
- 接收端地址:推送类型的接收端地址。
- 可选:消息过滤标签:通过设置的标签对消息进行过滤。
- 重试策略:向接收端推送消息出现错误时的重试策略。重试策略支持选择以下任一类型:
-
- 退避重试
- 指数衰减重试
- 消息推送格式:设置推送消息到接收端的消息格式。消息推送格式可以选择以下任一类型:
-
- SIMPLIFIED
- JSON
- XML
这里的接受端地址不是普通的地址,不是说你把公司的应用地址拿来就可以正常接入消息服务MNS,而是需要满足一定的条件,同时需要与你的消息服务MNS同地域。
接收端地址:Endpoint消息服务MNS的访问域名地址,格式如下:
http://$AccountId.mns.$Region.aliyuncs.com
mns..aliyuncs.com
:Region
是消息服务MNS服务部署的地域,您可以根据应用需要选择不同的地域。AccountId
:队列所有者的账号ID,调用API请求时需替换成实际的账号ID。
关于订阅的另外
由于我们是测试用的,在主题模型开始之初也创建了用于接收消息的队列,所有这里在创建订阅时需要选择【队列】,同时接收端地址是队列名称【topic01】
发布消息
回到主题列表页,点击【发布消息】
接收消息
回到创建的队列列表点击【收发消息】-【接收消息】,可以看到
如此关于消息服务的队列模型和主题模型的基本操作便完成了,文档整体说明比较详细,参数以及后台设置都讲解的比较到位,赞一个
JAVA项目接入
这里官方文档有详细的代码示例和接入操作智囊:MNS支持的Java SDK有哪些版本_消息服务MNS-阿里云帮助中心,整体接入比较简单,可以直接引入pom即可,这里需要在不同系统对应位置创建配置文件.aliyun-mns.properties
配置文件中的AccessKeyId和AccessKeySecret可以通过控制台配置,方便管理,控制台地址:阿里云登录 - 欢迎登录阿里云,安全稳定的云计算服务平台,点击【创建】,验证身份之后就可以创建AccessKeyId和AccessKeySecret
创建完成之后配置完对应的文件之后,可以直接参考API文档进行业务开发,整体文档比较详细,示例代码也很明白,接入很丝滑。
总结
整体使用消息服务MNS下来,通过控制台操作MNS比较容易上手,除了在操作时需要知道具体参数的意义才有必要去查看文档时,其他从创建队列,收发消息、删除等都简单容易上手,新手可以直接参考文档就能全程操作下来不卡顿,当然如果有卡顿的可以参考我这篇文章的哈,本人亲测没毛病...
对于刚接触消息服务MNS的同学们,个人觉得不必担心学习成本高的问题,参考文档操作10分钟足够掌握通过控制台操作消息服务MNS的全部操作,当然,在实际接入应用过程中可能会遇到各种各样的问题,同样也不用担心,首先可以去文档中查找,觉得浪费时间的话也可以直接提工单,作为阿里系的产品,每一款产品背后都有一个强大的技术团队支撑,只要业务需要,可以放心接入阿里云消息服务MNS,关于消息服务中消息数据的安全性,可靠性,可以完全交给阿里云消息服务去处理,作为业务方,专注业务即可,专注业务即可,专注业务即可。