消息优先级为1,就一定优先吗?

消息服务MNS 发送消息时,可以指定消息的优先级权值(取值范围1~16,1为最高优先级,默认优先级为8)。优先级越高的消息,越容易更早被消费。如果顺序发送100条消息,第50条消息的优先级置为1(其余消息优先级默认为8)。CloudQueue queue=...

消息优先级为1,就一定优先吗?

消息服务MNS 发送消息时,可以指定消息的优先级权值(取值范围1~16,1为最高优先级,默认优先级为8)。优先级越高的消息,越容易更早被消费。如果顺序发送100条消息,第50条消息的优先级置为1(其余消息优先级默认为8)。CloudQueue queue=...

OpenService

调用OpenService开通 消息服务MNS。使用说明 本接口用于第一次使用 消息服务MNS 的场景。开通服务后,您才能使用 消息服务MNS。只要调用任意可用地域的接入点就可以开通全地域。说明 可用地域包括英国(伦敦)、美国(弗吉尼亚)、华东1...

MNS是否可以与其他阿里云产品协作使用?

本文介绍 消息服务MNS 是否可以与其他阿里云产品协作使用的问题。消息服务MNS 可以与ECS、OSS和OTS等阿里云服务一起使用,从而让应用程序具有更好的灵活性和可扩展性。常见的使用案例如:创建需要互相通信却又不能同时处理相同工作量的多个...

日志服务事件通知概述

通过创建事件通知规则,消息服务MNS 可以将日志服务指定资源上产生的事件以消息的方式主动推送到指定的接收端。本文介绍 日志服务 SLS(Simple Log Service)事件通知的前提条件和背景信息。前提条件 已创建日志服务Project和Logstore。...

日志管理

消息服务MNS 可以为队列和主题开启日志管理功能,支持将队列或主题的消息操作日志推送到 日志服务 SLS(Simple Log Service)。在成功将MNS日志推送到 SLS 后,MNS支持通过日志查询特定信息。例如在消息发送、消费、确认等环节出现异常时,...

通过创建默认规则实现OSS事件通知

可以消息服务MNS 控制台查看和管理这些主题与订阅(例如创建新的订阅)。登录 消息服务MNS控制台。在左侧导航栏,单击 事件通知。在顶部菜单栏,选择地域。在 事件通知 页面,单击 对象存储OSS 页签,然后单击 创建规则。在 创建规则-...

通过创建自定义规则实现OSS事件通知

可以消息服务MNS 控制台查看和管理这些主题与订阅(例如创建新的订阅)。登录 消息服务MNS控制台。在左侧导航栏,单击 事件通知。在顶部菜单栏,选择地域。在 事件通知 页面,单击 对象存储OSS 页签,然后单击 创建规则。在 创建规则-...

邮件推送事件通知概述

通过创建事件通知规则,消息服务MNS 可以将邮件推送产生的事件以消息的方式推送到指定的接收端。本文介绍邮件推送事件通知的背景信息、适用场景、事件类型以及消息格式。背景信息 如下图所示,如果您在 邮件推送服务控制台 打开异步通知...

OSS事件通知概述

通过创建事件通知规则,消息服务MNS 可以将对象存储OSS指定资源上产生的事件以消息的方式主动推送到指定的接收端。本文介绍对象存储OSS事件通知的背景信息、适用场景、事件类型以及消息格式。背景信息 如下图所示,如果您创建了事件通知...

查看消息清单

消息发送后您可以通过 ChatApp消息服务 控制台查看消息发送和接收详情、状态报告、批量发送详情等信息。本文为您介绍如何在 ChatApp消息服务 控制台查看消息发送和接收详情等操作。查看消息清单 登录 ChatApp消息服务控制台。在左侧导航栏...

计费常见问题

我没有使用 云消息队列 RocketMQ 版 服务,为什么会扣费?我在控制台上看到没有开通 云消息队列 RocketMQ 版 服务,为什么会有扣费?如何关闭 云消息队列 RocketMQ 版 服务?我该如何为我的 云消息队列 RocketMQ 版 企业铂金版实例续费?...

顺序消息

顺序消息可以保证消息的消费顺序和发送的顺序一致,即先发送的先消费,后发送的后消费,常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的...

消息处理时长自适应

背景信息 消息服务MNS 的规范中,每条消息都有个默认的VisibilityTimeout,Worker在接收到消息后,Timeout就开始计时了。如果Worker在Timeout时间内没能处理完消息,那么消息就有可能被其他Worker接收到并处理。Timeout计时的好处在于消息...

消费幂等

为了防止消息重复消费导致业务处理异常,消息队列RocketMQ版 的消费者在接收到消息后,有必要根据业务上的唯一Key对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么消息幂等 当出现消费者对某条消息重复消费的情况...

主题+HTTP Endpoint使用手册

服务器功能:对 消息服务MNS 推送消息请求签名验证。如果错误,返回MNS 403。说明 示例中HTTP Endpoint的针对Authorization的校验不能完全规避掉恶意伪造的MNS请求,需要从业务层面上设计从发送端到HTTP Endpoint的安全校验机制。解析推...

顺序消息

如上图所示,消息组1和消息组4的消息混合存储在队列1中,云消息队列 RocketMQ 版 保证消息组1中的消息G1-M1、G1-M2、G1-M3是按发送顺序存储,且消息组4的消息G4-M1、G4-M2也是按顺序存储,但消息组1和消息组4中的消息不涉及顺序关系。...

什么是云消息队列 RocketMQ 版?

稳定性SLA 多可用区部署,提供业内领先的稳定性SLA保障,消息服务可用性最高99.99%;消息数据多副本存储,数据可靠性最高99.99999999%。弹性低成本 消息计算处理提供预留+突发弹性的组合能力,业务无需再为突发流量预留大量Buffer资源,...

消费者负载均衡

因此,即使多个消费者同时消费同一队列的消息服务端也可保证消息不会被多个消费者重复消费。顺序消息负载机制 在顺序消息中,消息的顺序性指的是同一消息组内的多个消息之间的先后顺序。因此,顺序消息场景下,消息粒度负载均衡策略还...

什么是云消息队列 Confluent 版?

消息队列 Confluent 版 全托管服务可以解决以下痛点:正版全托管云上企业级Kafka服务:云消息队列 Confluent 版 提供正版Confluent Platform license,并且只需较低成本即可享受。搭建Kafka集群复杂性的问题:使用阿里云商业版Confluent...

队列模型基本概念

当消息发送到 消息服务MNS 的队列,消息服务MNS 会生成一个Message ID,此ID一旦产生就不会改变,并在请求响应中返回,您主要可以使用此Message ID来数据校对,但是删除消息必须使用ReceiptHandle。临时句柄(ReceiptHandle)由 消息服务...

普通消息

普通消息为 云消息队列 RocketMQ 版 中最基础的消息,区别于有特性的顺序消息、定时/延时消息和事务消息。本文为您介绍普通消息的应用场景、功能原理、使用方法和使用建议。应用场景 普通消息一般应用于微服务解耦、事件驱动、数据集成等...

创建FC Sink Connector

函数计算能做什么?利用函数实现业务消息的处理,通过函数计算平台开发、运行业务消息处理逻辑,订单处理,任务执行。利用函数对消息进行快速加工处理,ETL清洗。利用函数计算灵活扩展将消息转储到指定VPC中的其他下游系统。利用函数连接...

收发事务消息

消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。本文提供使用HTTP协议下的Go SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。更...

收发事务消息

本文提供使用TCP协议下的C/C++ SDK收发事务消息的示例代码供您参考。云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图...

应用场景

本文为您介绍 云消息队列 RocketMQ 版 的应用场景,以便您更好地判断如何在业务中使用 云消息队列 RocketMQ 版。例如,针对一家互联网电商企业,其业务涉及广泛,如注册、订单、库存、物流等;同时,也会涉及许多业务峰值时刻,如秒杀活动...

收发事务消息

本文提供使用TCP协议下的社区版Java SDK收发事务消息的示例代码供您参考。交互流程 事务消息交互流程如下图所示。更多信息,请参见 事务消息。前提条件 您已完成以下操作:下载4.5.2或以上版本的社区版 Java SDK。准备工作。获取阿里云访问...

Token客户端接口

客户端监听即将失效的Token信息(无需订阅)服务端为方便业务调试和监控,会在Token即将失效的时候以系统Topic的形式推送通知消息到MQTT客户端,客户端可以监控该消息来判断是否有出现过Token即将到期的情况。接收Topic:$SYS/...

Token客户端接口

客户端监听即将失效的Token信息(无需订阅)服务端为方便业务调试和监控,会在Token即将失效的时候以系统Topic的形式推送通知消息到MQTT客户端,客户端可以监控该消息来判断是否有出现过Token即将到期的情况。接收Topic:$SYS/...

事务消息

事务消息为 云消息队列 RocketMQ 版 中的高级特性消息,本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行,同时需要调用多个下游业务...

收发事务消息

当步骤1半事务消息发送完成,但本地事务返回状态为 TransactionStatus.Unknow 时,亦或是应用退出导致本地事务未提交任何状态时,从Broker的角度看,这条半状态的消息的状态是未知的,因此Broker会定期向消息发送方即消息生产者集群中的...

基于Flink的资讯场景实时数仓

部署架构图 选用的产品 云消息队列 Kafka 版 云消息队列 Kafka 版 是阿里云基于Apache Kafka构建的高吞吐量、高可扩展性的分布式消息队列服务,广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等,是大数据生态中不可或缺的...

收发事务消息

消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。本文提供使用HTTP协议下的C#SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。更多...

资源包说明

消息队列 RocketMQ 版 的标准版实例按照按量付费方式对API请求资源和Topic资源进行计费,针对这两个计费项,云消息队列 RocketMQ 版 分别推出API请求次数和Topic次数资源包,帮助您以更优惠的价格享受等量资源。使用的资源在资源包规格内...

收发事务消息

消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。本文提供使用HTTP协议下的Java SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。...

收发事务消息

instance_id="${INSTANCE_ID}"consumer=mq_client.get_consumer(instance_id,topic_name,group_id)#长轮询表示如果Topic没有消息,则客户端请求会在服务端挂起3秒,3秒内如果有消息可以消费则立即返回响应。长轮询时间3秒(最多可设置为30...

订阅者最佳实践

本文主要介绍 云消息队列 Kafka 版 订阅者的最佳实践,帮助您减少消费消息出错的可能性。消费消息基本流程 云消息队列 Kafka 版 订阅者在订阅消息时的基本流程为:Poll数据→执行消费逻辑→再次Poll数据,详情参见下图。负载均衡 每个 ...

服务等级协议

消息服务MNS 规定了阿里云向客户提供的 消息服务MNS 的服务可用性等级指标及赔偿方案。如需查看 消息服务MNS 的服务可用性等级指标及赔偿方案,请参见 消息服务MNS服务等级协议。

常见问题

计费相关 删除队列后,是否继续计费 删除主题后,是否继续计费 消息问题 消息服务MNS的订阅成功后收不到消息 删除消息时报“message not exist”的错误 HttpEndpoint接口接收不到消息 使用消息服务MNS的HTTPEndpoint接口时签名认证失败 ...

收发顺序消息

顺序消息(FIFO消息)是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的Node.js SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类:全局顺序:对于指定的一个Topic,所有消息按照...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
商标服务 短信服务 云服务器 ECS 物联网无线连接服务 弹性公网IP 人工智能平台 PAI
新人特惠 爆款特惠 最新活动 免费试用