一分钟了解阿里云产品:消息队列

简介:

2000元阿里云代金券免费领取,2核4G云服务器仅664元/3年,新老用户都有优惠,立即抢购>>>


阿里云采购季(云主机223元/3年)活动入口:请点击进入>>>,


阿里云学生服务器(9.5元/月)购买入口:请点击进入>>>,

一、             概述

 

阿里云发布的产品种类繁多,今天让我们一起来了解下消息队列(Message Queue,简称MQ)吧。

 

 

什么是消息队列呢?

 

消息队列是企业级互联网架构的核心服务,基于高可用分布式集群技术,搭建了包括发布订阅、接入、管理、定时(延时)、监控报警等一套完整的高性能、高性价比消息云服务。MQ是阿里云正式商用的互联网消息中间件,帮您实现分布式计算场景中所有异步解耦功能。MQ由阿里巴巴集团中间件技术部自主研发,是原汁原味的阿里集团中间件技术精华之沉淀,是可靠的企业级消息中间件产品。

 

 

那么,消息队列有什么优势呢?

 

  • 消息队列经过双11阿里交易、商品、营销等核心链路真实场景验证。阿里集团内部1000+核心应用使用,每天流转几千亿条消息,稳定可靠。
  • 消息队列历史超过7年,消息保证不丢,技术体系丰富成熟。
  • 消息队列支持专有云独立输出,支持物理机和虚拟机,最小部署仅几台机器
  • 消息队列一份消息多份落盘存储,经过严格断电测试,消息依然保证不丢失。支持消息轨迹,消息从生产到消费轨迹,可清晰排查。海量消息堆积,单个Topic可堆积100亿+条消息,防止系统高流量崩溃。
  • 消息队列性能很高,同一网络内,消息传输RT在10毫秒之内,性能测试下,网卡可被打满。支持大量消息并发发送,超过5万个队列,性能依然卓越。支持消息海量堆积,单Topic可堆积100+亿条消息,单条消息默认最大支持256K。
  • 消息队列支持跨网络调用,HTTP公网接入支持跨网络调用,HTTP Restful接口公网接入。MQTT接入,支持主动推送模,多级Topic模型支持一次触达1000万+终端。可广泛应用于物联网和社交即时通信场景,可跟JStorm等实时计算完美结。

 

 

可能您会问到,“我处在什么样的应用或服务场景时,可以选择消息队列呢?”

 

消息队列Message Queue可应用在多个领域,包括异步通信解耦、企业解决方案、金融支付、电信、电子商务、快递物流、广告营销、社交、即时通信、移动应用、手游、视频、物联网、车联网等。

 

  • 通用场景:一对多,多对多异步解耦,削峰场景,日志监控。

 

  • 行业应用:消息推送,金融报文,电信信令。


目前,已有钉钉、上海网聚宝、杭州安存科技、天猫双十一等在使用消息队列。

 

消息队列典型特性介绍:

https://www.aliyun.com/product/ons/?spm=5176.7400024.3.54.THw5e7

 

 

 

二、             技术点(消息队列五大热点技术问题分析)

 

在上一篇文章中,我们为大家介绍消息队列的概况,消息队列(Message Queue,简称MQ)是企业级互联网架构的核心服务,基于高可用分布式集群技术,搭建了包括发布订阅、接入、管理、定时(延时)、监控报警等一套完整的高性能、高性价比消息云服务。那在使用过程中,经常遇到的热门技术问题有哪些呢?

 

MQ 发送消息:

https://help.aliyun.com/document_detail/ons/quick-start/send.html?spm=5176.docons/quick-start/apply.6.85.ixfbeh

 

MQ 查询消息:

https://help.aliyun.com/document_detail/ons/quick-start/track.html?spm=5176.docons/quick-start/delete.6.88.9FFLOJ

 

问题定位:

https://help.aliyun.com/document_detail/ons/quick-start/check.html?spm=5176.docons/quick-start/track.6.89.fsbN7t

 

MQ常见问题:

https://help.aliyun.com/document_detail/ons/faq/faq.html?spm=5176.docons/quick-start/check.6.168.zxvHm0

 

消息队列控制台TOPIC异常处理方法:

https://help.aliyun.com/knowledge_detail/6562887.html?spm=5176.789006200.2.2.c8PUFu#%E6%B6%88%E6%81%AF%E9%98%9F%E5%88%97%E6%8E%A7%E5%88%B6%E5%8F%B0TOPIC%E5%BC%82%E5%B8%B8%E5%A4%84%E7%90%86%E6%96%B9%E6%B3%95

 

 

希望上面的内容,能够对大家有所帮助。

 

 

 

三、             体验(消息队列服务MQS使用分享)

 

消息队列MQS,顾名思义,是用于发送接收消息用的。废话不说,直接进入主题。

 

 

使用场景:服务添加了一个新功能,主要用于生成图片,本人用的开发语言是PHP,生成图片比较耗服务器性能,如果使用一台服务器生成的话,生成大量图片时速度就会很慢。

由此决定使用3台服务器同时处理,将任务分布到3台服务器中。另外有一台服务器用于提交任务。

MQS支持多个生产者、多个消费者并发访问一个队列(本例是一个生产者,3个消费者)。

 

简单的服务器部署情况如下图:

 7df2b7c327c64d172d61932603bf0b9339fa12f8

 

具体的代码实现这里就不再说明了,个人是根据官方的API文档稍微封装了一下:http://www.aliyun.com/product/mqs/?spm=5176.383338.201.16.ZoLW8Q#Help

 

服务器部署完之后,封装好API之后,接下来使用就很简单了, 管理后台可以添加修改队列配置。

 

过程比较简单:

 

1.生产者添加消息

2.消费者取出消息,完成业务逻辑后通知队列已经完成。

 

添加队列如下:

 503f2c9c6e240ab43194fe1d8afe01ab89ec5cf1

 

说明一下隐藏时长的个人理解:消费者取出消息,过了(隐藏时长)未通知队列处理完成,那认为消息还没消耗掉,可以再取出!

 

关于具体如何使用这里就不多做介绍,官方文档也比较齐全,而且对接小二热情周到!

本人使用MQS三个多月,还没出现消息遗漏的情况,解决了大量任务分布处理的需要,非常稳定方便!

总体来说,相当满意!以上就是我使用消息队列的一点体会,希望大家能有所收获。

 

 

如果您想详细了解消息队列,请访问:

https://bbs.aliyun.com/read/179164.html?pos=5

 

大型网站架构系列:分布式消息队列(一):

https://yq.aliyun.com/articles/7534?spm=5176.100240.searchblog.8.mRjsRI

相关实践学习
RocketMQ一站式入门使用
从源码编译、部署broker、部署namesrv,使用java客户端首发消息等一站式入门RocketMQ。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
9天前
|
分布式计算 大数据 BI
MaxCompute产品使用合集之MaxCompute项目的数据是否可以被接入到阿里云的Quick BI中
MaxCompute作为一款全面的大数据处理平台,广泛应用于各类大数据分析、数据挖掘、BI及机器学习场景。掌握其核心功能、熟练操作流程、遵循最佳实践,可以帮助用户高效、安全地管理和利用海量数据。以下是一个关于MaxCompute产品使用的合集,涵盖了其核心功能、应用场景、操作流程以及最佳实践等内容。
|
9天前
|
分布式计算 大数据 MaxCompute
MaxCompute产品使用合集之使用pyodps读取OSS(阿里云对象存储)中的文件的步骤是什么
MaxCompute作为一款全面的大数据处理平台,广泛应用于各类大数据分析、数据挖掘、BI及机器学习场景。掌握其核心功能、熟练操作流程、遵循最佳实践,可以帮助用户高效、安全地管理和利用海量数据。以下是一个关于MaxCompute产品使用的合集,涵盖了其核心功能、应用场景、操作流程以及最佳实践等内容。
|
1天前
|
消息中间件 人工智能 监控
|
6天前
|
数据库 云计算
电子好书发您分享《阿里云产品手册2024版》
**阿里云2024产品手册电子版分享:** 探索最新云计算解决方案,涵盖智能计算、视觉智能与云数据库ClickHouse。了解阿里云在新的一年中提供的核心产品与服务升级,包括适用于初学者的云服务器选项。查看完整手册:[阿里云产品手册2024版](/ebook/8326/116556?spm=a2c6h.26392459.ebook-detail.4.50ae272a22gHxh)。
34 9
|
9天前
|
数据采集 分布式计算 DataWorks
DataWorks产品使用合集之在阿里云的DataWorks中,使用CREATE AS创建分区表的步骤如何解决
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
25 2
|
9天前
|
分布式计算 DataWorks 调度
DataWorks产品使用合集之阿里云的DataWorks中,提交手动业务流程的步骤如何解决
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
23 0
|
9天前
|
分布式计算 DataWorks Java
DataWorks产品使用合集之阿里云DataWorks专有云环境下,上传MaxCompute的UDF(用户自定义函数)的JAR包的步骤如何解决
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
20 0
|
9天前
|
缓存 分布式计算 DataWorks
DataWorks产品使用合集之阿里云DataWorks中,天任务依赖小时任务的调度运行如何解决
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
20 1
|
10天前
|
SQL 分布式计算 DataWorks
MaxCompute产品使用合集之阿里云MaxCompute对SQL语句的长度的长度限制是多少
MaxCompute作为一款全面的大数据处理平台,广泛应用于各类大数据分析、数据挖掘、BI及机器学习场景。掌握其核心功能、熟练操作流程、遵循最佳实践,可以帮助用户高效、安全地管理和利用海量数据。以下是一个关于MaxCompute产品使用的合集,涵盖了其核心功能、应用场景、操作流程以及最佳实践等内容。
|
10天前
|
SQL 数据管理 API
数据管理DMS产品使用合集之阿里云DMS提供API接口来进行数据导出功能吗
阿里云数据管理DMS提供了全面的数据管理、数据库运维、数据安全、数据迁移与同步等功能,助力企业高效、安全地进行数据库管理和运维工作。以下是DMS产品使用合集的详细介绍。
http://www.vxiaotou.com