迁移上云操作
注意事项 云消息队列 RocketMQ 版 迁移工具按照最小范围粒度仅访问源自建集群如下信息：Topic元数据配置信息 Group元数据配置信息 Topic动态路由注册信息 消费者连接信息及消费堆积信息 不会访问源集群其他信息，也不会对源自建集群的配置...
图算法
下一轮迭代时，邻接点 根据收到的消息，更新其当前 最短距离值，当所有 点 的当前 最短距离值 不再变化时，迭代结束。初始化：源点s到s自身的距离为0（d[s]=0），其他点u到s的距离为无穷（d[u]=∞）。迭代：如果存在一条从u到v的边，则从s...
单源最短距离
单源最短距离是指给定图中一个源点，计算源点到其它所有节点的最短距离。Dijkstra算法是求解有向图中单源最短距离SSSP（Single Source Shortest Path）的经典算法。算法原理 Dijkstra算法是通过 点 去更新 最短距离值，每个 点 维护到 源点...
使用Android SDK上传短视频
短视频上传是指将文件从客户端上传至点播存储。通过短视频上传完成的视频，上传SDK会返回 videoId。在集成阿里云播放器的情况下，此ID可用作 vid+playauth播放方式 的参数设置，不用再单独获取播放地址和凭证。本文介绍如何使用Android端...
发布者最佳实践
本文介绍 云消息队列 Kafka 版 发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息 发送消息的示例代码如下：Future...
应用场景
云消息队列 Kafka 版 用于网站活动跟踪具备以下优势：高吞吐：网站用户产生的行为信息较为庞大，需要较高的吞吐量来支持。弹性扩容：网站活动导致行为数据激增，云平台可以快速按需扩容。大数据分析：可对接Storm、Spark等实时数据处理引擎...
CreateTopic
Name Value API CreateTopic RAM授权操作 mns:CreateTopic 资源 acs:mns:$region:$accountid:/topics/$topicName 使用限制 主题名称是一个不超过255个字符的字符串，必须以字母或数字为首字符，剩余部分可以包含字母、数字和短划线（-）。...
公版APP《软件许可及服务协议》国际版
短趣可能会根据相关的食材营养、平衡膳食、运动等信息，向您推荐对应的食材、食物、运动目标等信息，但您知悉并同意，该等信息但仅供参考并不作为认为专业或职业意见、结论，同时您需要自行评估合理性以及做好运动过程中的自身防护。...
包年包月EIP变配
短时升配 短时升配前，您需要了解以下信息：短时升配限制 生效时间 计费影响 适用场景 包年包月 EIP 实例到期后不支持短时升配。在当前的短时升配到期前不支持再次短时升配。短时升配功能支持最短升配间隔为2小时，每次支持最短升配1小时，...
包年包月实例变配
短时升配 短时升配前，您需要了解以下信息：短时升配限制 生效时间 计费影响 适用场景 已到期包年包月类型的共享带宽不支持短时升配。在当前的短时升配到期前不支持再次短时升配。短时升配功能支持最短升配间隔为2小时，每次支持最短升配2...
变更EIP带宽
短时升配 短时升配前，您需要了解以下信息：短时升配限制 生效时间 计费影响 适用场景 包年包月 EIP 实例到期后不支持短时升配。在当前的短时升配到期前不支持再次短时升配。短时升配功能支持最短升配间隔为2小时，每次支持最短升配1小时，...
4.x和5.x版本差异及兼容性说明
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云 云消息队列 RocketMQ 版 将为您提供更加稳定可靠的服务端5...
4.x和5.x版本差异及兼容性说明
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云 云消息队列 RocketMQ 版 将为您提供更加稳定可靠的服务端5...
使用限制
云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时，云消息队列 RocketMQ 版 仅4.0系列实例支持消息流入或流出规则，5.0系列实例不支持。消息...
消息处理时长自适应
背景信息 消息服务MNS 的规范中，每条消息都有个默认的VisibilityTimeout，Worker在接收到消息后，Timeout就开始计时了。如果Worker在Timeout时间内没能处理完消息，那么消息就有可能被其他Worker接收到并处理。Timeout计时的好处在于消息...
重置消费位点
您可通过重置消费位点，按需清除堆积的或不想消费的这部分消息再从最新位点开始消费，或直接跳转到某个时间点消费该时间点之后的消息。重要 广播消费模式不支持重置消费位点。目前不支持指定 Message ID、Message Key 和 Tag 来重置消息的...
创建和管理 Topic
Topic 是 SOFAStack 消息队列里对消息的一级归类，消息生产者将消息发送到 Topic，而消息消费者则通过订阅该 Topic 来获取和消费消息。创建 Topic 登录 SOFAStack 控制台。在左侧导航栏，选择 中间件>消息队列>Topic 管理。单击 创建 Topic...
Topic管理
MQTT协议基于Pub/Sub模型，因此任何消息都属于一个Topic。根据MQTT协议，Topic存在多级，定义第一级Topic为父级Topic，在使用 云消息队列 MQTT 版 前，需先创建该父级Topic资源。注意事项 Topic不能跨实例使用，例如不能使用实例B的接入点...
设置消息通知
设置单任务消息通知 设置工作流消息通知 步骤一、开通消息服务MNS 重要 媒体处理的消息通知是绑定MNS产品推送的，媒体处理侧不产生费用，但是会产生MNS费用。计费详情请参见 价格说明。开通消息服务MNS并授权。详细操作请参见 开通消息服务...
Group操作
Group用于指定一组逻辑功能完全一致的节点共用的组名，代表一类相同功能的设备。在进行消息收发前，请先创建Group，...相关文档 创建Topic和Group后可进行消息收发，详细信息，请参见 快速使用MQTT的Java SDK收发消息（终端和云端消息收发）。
顺序消息
与顺序消息相关的常见问题如下：顺序消息是否支持集群消费和广播消费？同一条消息是否可以既是顺序消息，同时又支持定时消息和事务消息？顺序消息支持哪些地域（Region）？顺序消息的使用范围是什么？顺序消息支持哪种消息发送方式？顺序...
订阅消息API
订阅者可通过调用订阅消息API来消费 云消息队列 RocketMQ 版 服务端中的消息。请求构造 请求行 GET/topics/TopicName/messages?ns=INSTANCE_ID&consumer=GID&tag=taga&numOfMessages=3&waitseconds=3 HTTP/1.1 重要 请求行总长度不能超过...
RAM跨云账号授权
背景信息 企业A开通了 云消息队列 Kafka 版，该企业需要企业B代为操作 云消息队列 Kafka 版 的资源，例如实例、Topic、Group。企业A的需求如下：企业A希望能专注于业务系统，仅作为 云消息队列 Kafka 版 所有者。企业A希望可以授权企业B来...
什么是云消息队列 RocketMQ 版？
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台，面向互联网分布式应用场景提供微服务异步解耦、流式数据处理、事件驱动处理等核心能力。为什么选择云...
RAM跨云账号授权
背景信息 企业A开通了 云消息队列 RabbitMQ 版，该企业需要企业B代为操作 云消息队列 RabbitMQ 版 的资源，例如实例、Topic、Consumer Group。企业A的需求如下：企业A希望能专注于业务系统，仅作为 云消息队列 RabbitMQ 版 所有者。企业A...
短轮询和长轮询
消息服务MNS 提供短轮询（Short Polling）和长轮询（Long Polling）两种方式来获取队列中的消息。短轮询 创建队列时，长轮询时间设置为0，且发起popMessage请求时 waitSeconds 设置为0。使用短轮询获取队列中的消息，popMessage请求会向...
Subscribe
mns:Subscribe 资源 acs:mns:$region:$accountid:/topics/$topicName/subscriptions/$subscriptionName 使用说明 Subscription名称是一个不超过255个字符的字符串，必须以字母或者数字为首字符，剩余部分可以包含字母、数字和短划线（-）。...
RAM主子账号授权
背景信息 企业A开通了 云消息队列 Kafka 版 服务，该企业需要员工操作 云消息队列 Kafka 版 服务所涉及的资源，例如实例、Topic、Consumer Group。由于每个员工的工作职责不一样，需要的权限也不一样。企业A的需求如下：出于安全或信任的...
RAM主子账号授权
背景信息 企业A开通了 云消息队列 RabbitMQ 版 服务，该企业需要员工操作 云消息队列 RabbitMQ 版 服务所涉及的资源，例如实例、Vhost、Queue和Exchange。由于每个员工的工作职责不一样，需要的权限也不一样。企业A的需求如下：出于安全或...
开源对比
本文从稳定性、内核能力、治理能力以及使用习惯等方面，对比阿里云 云消息队列 Kafka 版 与开源Apache Kafka。稳定性 项目 云消息队列 Kafka 版 Apache Kafka 磁盘水位 磁盘写满删除旧数据。磁盘写满直接宕机。线程池隔离 读冷数据仍可以...
Group导入/导出
云消息队列 RocketMQ 版 支持将指定实例的Group列表信息导出，再导入至其他的 云消息队列 RocketMQ 版 实例，实现Group的跨实例迁移。你可以在更换实例或者克隆实例时，使用Group导入/导出功能快速批量创建出相同的Group。背景信息 您可以...
生产者（Producer）
预绑定主题列表 定义：云消息队列 RocketMQ 版 的生产者需要将消息发送到的目标主题列表，主要作用如下：事务消息（必须设置）：事务消息场景下，生产者在故障、重启恢复时，需要检查事务消息的主题中是否有未提交的事务消息。避免生产者...
Subscribe
Subscription名称是一个不超过255个字符的字符串，必须以字母或者数字为首字符，剩余部分可以包含字母、数字和短划线（-）。创建Subscription时，需要指定对应的Endpoint，否则不合法。Request 请求消息由以下几部分组成：请求行 PUT/...
短信营销概述
短信营销支持对接 阿里云短信平台 和第三方短信平台，您可以向人群发送定时或即时的推广短信、短信通知、数字短信：推广短信：文本类型的短信，支持插入若干短链接。适用于新品宣传、会员关怀、生日祝福、商品促销、活动邀请等应用场景。...
订阅消息
例如某个Topic有9条消息，一个Group ID有3个Consumer实例，那么在广播消费模式下每个实例都会各自消费9条消息。广播订阅方式设置 factoryInfo.setFactoryProperty(ONSFactoryProperty.MessageModel,ONSFactoryProperty.BROADCASTING);示例...
概述
概念介绍—消息流出（Sink）消息流出的主要能力是将消息产品的数据流出到各类数据目标，消息集成模块对消息产品的消息进行可靠分发，同时在分发时对消息数据进行清洗和过滤。概念介绍—数据处理（Transform）数据处理是消息集成的重要功能...
概述
概念介绍—消息流出（Sink）消息流出的主要能力是将消息产品的数据流出到各类数据目标，消息集成模块对消息产品的消息进行可靠分发，同时在分发时对消息数据进行清洗和过滤。概念介绍—数据处理（Transform）数据处理是消息集成的重要功能...
概述
概念介绍—消息流出（Sink）消息流出的主要能力是将消息产品的数据流出到各类数据目标，消息集成模块对消息产品的消息进行可靠分发，同时在分发时对消息数据进行清洗和过滤。概念介绍—数据处理（Transform）数据处理是消息集成的重要功能...
消费者（Consumer）
消费者通常被集成在业务系统中，从 云消息队列 RocketMQ 版 服务端获取消息，并将消息转化成业务可理解的信息，供业务逻辑处理。在消息消费端，可以定义如下传输行为：消费者身份：消费者必须关联一个指定的消费者分组，以获取分组内统一...
集群消费和广播消费
集群消费和广播消费是 云消息队列 RocketMQ 版 的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息 云消息队列 ...
- 产品推荐
- 这些文档可能帮助您