消息服务MNS之初见

本文涉及的产品
日志服务 SLS,月写入数据量 50GB 1个月
简介: 简要介绍阿里云消息服务MNS(Message Service)及基础操作

消息服务MNS

说到消息服务MNS,那么消息服务MNS是什么呢?为什么会有消息服务MNS这款产品的产生呢?

什么是消息服务MNS

消息服务-阿里云消息服务MNS(Message Service)是一种高效、可靠、安全、便捷和可弹性扩展的分布式消息服务。消息服务MNS能够帮助开发者在应用的分布式组件之间自由地传递数据、通知消息,从而构建松耦合系统。消息服务MNS支持队列模型和主题模型。

消息服务MNS产生

简单来说就是说传统的单体系统架构、单体数据库已经无法满足海量的用户需求,这个时候就需要对原有系统进行升级改造,对大规模的流量进行分解到不同的应用服务中,各个应用服务之间通过消息服务的方式来实现数据传递、通知消息,从而达到松耦合的目的。

消息服务MNS的模型

队列模型和主题模型,其中对列模型就是和我们经常听到的消息队列中间件Kafka、RocketMQ、ActiveMQ、RabbitMQ的基本原理相似,生产者发送消息到队列中,消费者去队列中取出消息进行消费,消息消费完成之后从队列中删除,关于消息服务MNS队列模型的更多术语可以参考文档 https://help.aliyun.com/document_detail/34954.html;那么主题模型呢?主题模型就是说比队列模型多了一步,就是在生产者发送消息之前需要先有主题,然后生产者往主题发布消息,消息消费者需要先订阅主题,之后才能从从主题接收消息消费消息。


消息服务MNS基本操作

控制台地址: https://home.console.aliyun.com/home/dashboard/ProductAndService,打开控制台,搜索消息服务MNS

image.png

免费开通【消息服务MNS】

image.png

注意:这里消息服务MNS默认是按量收费。如果使用量较大的建议选择合适的套餐开通。

队列模型基本操作

创建队列

点击【队列列表】,选择【创建队列】,打开如图页面

image.png

参数说明:

  • 名称:队列名称。
  • 消息最大长度:发送到队列的消息体的最大长度。
  • 长轮询时间:当队列中没有消息时,该队列的ReceiveMessage请求的最大等待时长。
  • 消息可见性超时时间:消息从队列中取出后从Active状态变成Inactive状态后的持续时间。
  • 消息保存时长:消息在队列中的最长存活时间。从发送到队列开始经过此参数指定的时间后,不论消息是否被取出都将被删除。
  • 消息定时时间:发送到队列的所有消息将延后此参数指定的时间后被消费。
  • 启用日志功能:是否开启日志管理功能。

这里是测试用,参数无需特别设置,默认的即可,点击【确定】。

收发消息

点击【消息队列】列表右侧【更多】,选择【收发消息】

image.png

输入消息内容,点击【发送消息】,消息发送成功后会收到返回的消息id,同时刷新页面会看到可用消息变为1

image.png

点击【接收消息】,会看到刚才的消息被消费,同时可用消息为0

image.png

当然,如果你想删除当前队列,可以直接返回列表页选择【更多】-【删除】即可。

主题模型基本操作

主题模型比队列模型多了一步主题的操作,当然也是需要先有消息队列的

创建队列

创建队列的操作和上面一样,这里创建topic01的队列,参数选择默认参数,

image.png

这里是个人测试,可以不用开启日志服务,毕竟日志服务也是收费的。

创建主题

点击【主题列表】-【创建主题】,输入主题名称确认。

image.png

主题创建完成之后会自动跳转的主题详情页

创建订阅

点击【创建订阅】,输入对应内容,点击【确定】

image.png

参数说明:

  • 名称:订阅名称。
  • 推送类型:订阅的推送类型。默认为队列。
  • 接收端地址:推送类型的接收端地址。
  • 可选:消息过滤标签:通过设置的标签对消息进行过滤。
  • 重试策略:向接收端推送消息出现错误时的重试策略。重试策略支持选择以下任一类型:
  • 退避重试
  • 指数衰减重试
  • 消息推送格式:设置推送消息到接收端的消息格式。消息推送格式可以选择以下任一类型:
  • SIMPLIFIED
  • JSON
  • XML

这里的接受端地址不是普通的地址,不是说你把公司的应用地址拿来就可以正常接入消息服务MNS,而是需要满足一定的条件,同时需要与你的消息服务MNS同地域。

接收端地址:Endpoint消息服务MNS的访问域名地址,格式如下:

http://$AccountId.mns.$Region.aliyuncs.com

  • mns..aliyuncs.comRegion消息服务MNS服务部署的地域,您可以根据应用需要选择不同的地域。
  • AccountId:队列所有者的账号ID,调用API请求时需替换成实际的账号ID。

关于订阅的另外

由于我们是测试用的,在主题模型开始之初也创建了用于接收消息的队列,所有这里在创建订阅时需要选择【队列】,同时接收端地址是队列名称【topic01】

image.png

发布消息

回到主题列表页,点击【发布消息】

image.png

image.png

接收消息

回到创建的队列列表点击【收发消息】-【接收消息】,可以看到

image.png

如此关于消息服务的队列模型和主题模型的基本操作便完成了,文档整体说明比较详细,参数以及后台设置都讲解的比较到位,赞一个

JAVA项目接入

这里官方文档有详细的代码示例和接入操作智囊:https://help.aliyun.com/document_detail/27508.html,整体接入比较简单,可以直接引入pom即可,这里需要在不同系统对应位置创建配置文件.aliyun-mns.properties

image.png

配置文件中的AccessKeyId和AccessKeySecret可以通过控制台配置,方便管理,控制台地址:https://ram.console.aliyun.com/manage/ak,点击【创建】,验证身份之后就可以创建AccessKeyId和AccessKeySecret

image.png

创建完成之后配置完对应的文件之后,可以直接参考API文档进行业务开发,整体文档比较详细,示例代码也很明白,接入很丝滑。

总结

整体使用消息服务MNS下来,通过控制台操作MNS比较容易上手,除了在操作时需要知道具体参数的意义才有必要去查看文档时,其他从创建队列,收发消息、删除等都简单容易上手,新手可以直接参考文档就能全程操作下来不卡顿,当然如果有卡顿的可以参考我这篇文章的哈,本人亲测没毛病...

对于刚接触消息服务MNS的同学们,个人觉得不必担心学习成本高的问题,参考文档操作10分钟足够掌握通过控制台操作消息服务MNS的全部操作,当然,在实际接入应用过程中可能会遇到各种各样的问题,同样也不用担心,首先可以去文档中查找,觉得浪费时间的话也可以直接提工单,作为阿里系的产品,每一款产品背后都有一个强大的技术团队支撑,只要业务需要,可以放心接入阿里云消息服务MNS,关于消息服务中消息数据的安全性,可靠性,可以完全交给阿里云消息服务去处理,作为业务方,专注业务即可,专注业务即可,专注业务即可。



相关实践学习
消息队列+Serverless+Tablestore:实现高弹性的电商订单系统
基于消息队列以及函数计算,快速部署一个高弹性的商品订单系统,能够应对抢购场景下的高并发情况。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
消息中间件 存储 缓存
3分钟白话RocketMQ系列—— 如何消费消息
3分钟白话RocketMQ系列—— 如何消费消息
725 0
|
2天前
|
消息中间件 BI
轻量消息队列(原 MNS)——云产品间的消息通道
快来报名吧!轻松上手,高效集成轻量消息队列(原MNS),解锁云产品间消息通道的典型场景,赢取丰厚奖品!访问活动页面,完成配置和上传截图即可获得保温杯,限量500个,先到先得!邀请好友还有机会赢取木制音响!活动时间:即日起至2024年12月2日。
|
5月前
|
消息中间件 网络协议 物联网
消息队列 MQ产品使用合集之如何让消费者不从最开始进行消费,而是从最后一条消息开始消费
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。
|
5月前
|
消息中间件 Serverless Windows
消息队列 MQ产品使用合集之MQTT协议是否可以应用于社交软件的系统通知场景
阿里云消息队列MQ(Message Queue)是一种高可用、高性能的消息中间件服务,它允许您在分布式应用的不同组件之间异步传递消息,从而实现系统解耦、流量削峰填谷以及提高系统的可扩展性和灵活性。以下是使用阿里云消息队列MQ产品的关键点和最佳实践合集。
|
消息中间件 存储 运维
厚积薄发--一文带您了解阿里云消息队列(MNS)
MNS 重点聚焦在基准消息队列的核心能力建设,MNS 经过多年迭代与打磨,尽管内部极为复杂,但一直努力保持其在客户端的简单易用,围绕轻量和集成两个命题,着力建设更易用的消息队列产品。
1834 0
厚积薄发--一文带您了解阿里云消息队列(MNS)
|
消息中间件 运维 RocketMQ
消息队列 MNS 简史|学习笔记
快速学习消息队列 MNS 简史
402 0
消息队列 MNS 简史|学习笔记
|
消息中间件 安全 Serverless
消息队列 MNS 特性|学习笔记
快速学习消息队列 MNS 特性
238 0
|
消息中间件 存储 运维
厚积薄发--一文带您了解阿里云消息队列(MNS)
MNS 重点聚焦在基准消息队列的核心能力建设,MNS 经过多年迭代与打磨,尽管内部极为复杂,但一直努力保持其在客户端的简单易用,围绕轻量和集成两个命题,着力建设更易用的消息队列产品。
厚积薄发--一文带您了解阿里云消息队列(MNS)
|
消息中间件 存储 运维
云栖发布|阿里云消息队列 RocketMQ 5.0:消息、事件、流融合处理平台
RocketMQ5.0 的发布标志着阿里云消息正式从消息领域正式迈向了“消息、事件、流”场景大融合的新局面。
907 0
云栖发布|阿里云消息队列 RocketMQ 5.0:消息、事件、流融合处理平台
|
消息中间件 分布式计算 物联网
阿里云物联网平台数据转发到消息服务(MNS)示例
本文主要演示通过规则引擎将消息流转到MNS Topic,然后通过Queue订阅Topic中的消息。
阿里云物联网平台数据转发到消息服务(MNS)示例
下一篇
无影云桌面