队列模型基本概念
本文对 消息服务MNS 的队列模型涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用队列模型。Account 用户的阿里云账号ID。队列（Queue）消息存储的目的地，分成普通队列和延时队列两类。消息包含数据和属性，可以分成...
常见问题
消息发送时出现有关消息不合法的异常信息 消息消费常见问题 客户端首次接入连接不上服务端，收不到消息如何排查？订阅关系不一致如何处理？如何处理消息堆积？消费者消费不到消息如何处理？若某个消费组下的机器宕机，机器重启期间，消息...
集成概述
概念介绍—消息流出（Sink）消息流出的主要能力是将 云消息队列 Kafka 版 的数据流出到各类数据目标，Connector生态集成模块对 云消息队列 Kafka 版 的消息进行可靠分发，同时在分发时对消息数据进行清洗和过滤。概念介绍—数据处理...
收发普通消息
普通消息是指阿里云 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时消息、顺序消息和事务消息。本文提供使用TCP协议下的社区版C++ SDK收发普通消息的示例代码供您参考。前提条件 安装CPP动态库 获取阿里云访问密钥AccessKey ...
ChatAppInbound
您可以通过MNS消息队列接收 ChatApp 消息服务 的上行消息（ChatAppInbound）。前提条件 您已经注册阿里云账号并生成访问密钥（AccessKey），详情请参见 创建AccessKey。您已仔细阅读 回执消息简介与配置流程，了解回执消息模式、类型和配置...
配置消息监控告警实现风险预警
背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格的实例都有明确的 SLA保障，您购买实例后即可保证消息收发TPS、消息存储、网络吞吐等指标达到规格规定的能力。您无需担心实例性能问题，但实际生产环境中仍需要关注...
常见问题
消息发送时出现有关消息不合法的异常信息 消息消费常见问题 客户端首次接入连接不上服务端，收不到消息如何排查？订阅关系不一致如何处理？如何处理消息堆积？消费者消费不到消息如何处理？若某个消费组下的机器宕机，机器重启期间，消息...
Subscription
Subscription描述一个订阅关系，包括被订阅的主题和接收消息的Endpoint。订阅者通过Subscribe接口创建订阅，消息服务MNS 根据订阅的描述给用户端推送消息，推送的起点是订阅时Topic中最新的消息。订阅创建成功后，消息服务MNS 会向指定的...
Subscription
Subscription描述一个订阅关系，包括被订阅的主题和接收消息的Endpoint。订阅者通过Subscribe接口创建订阅，消息服务MNS 根据订阅的描述给用户端推送消息，推送的起点是订阅时Topic中最新的消息。订阅创建成功后，消息服务MNS 会向指定的...
SendMessage-向云消息队列 MQTT 版发送单条消息
从服务端应用向云消息队列 MQTT 版发送单条消息。接口说明 SendMessage 接口为服务端应用调用，与 MQTT 客户端发送消息互补。服务端和客户端的使用场景区别，请参见 开发指南使用指引。调用 SendMessage 接口前，请确认您的云消息队列 MQTT...
OnsTopicCreate-创建Topic
取值说明如下：0：普通消息 1：分区顺序消息 2：全局顺序消息 4：事务消息 5：定时/延时消息 各类型消息的详细说明，请参见 消息类型列表。0 Remark string 否 需创建的 Topic 的描述信息。测试 InstanceId string 是 需创建的 Topic 所...
OnsMessagePush-向指定的消费者推送消息
调用OnsMessagePush向指定的消费者推送消息。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生...
PublishMessage
调用PublishMessage接口向指定的主题发布消息，消息发布到主题后随即会被推送给Endpoint消费。请求头 该接口使用公共请求头，无特殊请求头。更多信息，请参见 公共参数。请求语法 POST/topics/$TopicName/messages HTTP/1.1 说明 当您调用...
OnsMessageTrace-查看消息消费结果
调用OnsMessageTrace根据Message ID来判断目标消息是否曾被消费过。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，...
什么是云消息队列 Confluent 版？
什么是Confluent Platform Confluent Platform是一个全面的数据流企业级平台，使您能够以连续、实时的流形式轻松访问、存储和管理数据。Confluent由Apache Kafka的原始创建者构建，通过企业级功能扩展了Kafka的优势，同时消除了Kafka管理或...
关于视觉智能开放平台部分商业化产品定价调价的公告
000次 125,000次 10,000元 无 5,000,000点 2,500,000次 625,000次 50,000元 无 10,000,000点 5,000,000次 1,250,000次 100,000元 无 20,000,000点 10,000,000次 2,500,000次 200,000元 无 50,000,000点 25,000,000次 6,250,000次 500,000元...
OnsConsumerResetOffset-重置Group ID消费位点
调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 Action 元素中使用，用来给RAM用户或RAM角色授予调用此API的权限。具体说明如下：操作：是指具体的权限点。访问级别：是指每个操作的访问级别，取值为写入（Write）、读取...
使用Canal将MySQL的数据同步至云消息队列 Kafka 版
本教程介绍如何使用Canal将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Canal的主要用途是基于MySQL数据库增量日志解析，提供增量数据订阅和消费。Canal伪装自己为MySQL Slave，向MySQL Master发送dump请求。MySQL Master收到dump...
授权信息
本文为您介绍 消息队列Kafka版（AliKafka）为RAM权限策略定义的操作（Action）、资源（Resource）和条件（Condition）。消息队列Kafka版（AliKafka）的RAM代码（RamCode）为 alikafka，支持的授权粒度为 RESOURCE。权限策略通用结构 权限...
实例支持哪些开源版本？
云消息队列 Kafka 版 标准版与专业版实例支持的开源版本是2.2.0、2.6.2版本，同时兼容对应的2.2.x、2.6.x的客户端。您在购买实例后，可在部署实例时选择2.2.0或2.6.2版本。建议您使用2.2.0及以上的版本。如需升级版本，请参见 升级实例版本...
二次认证
本文介绍如何使用二次认证以及在登录时绑定二次认证方式。IDaaS EIAM 支持在使用密码登录后，要求用户进行二次认证，提高管理安全性，满足合规要求。二次认证配置 为了保障您的使用安全性，二次认证能力默认开启。开启模式 IDaaS EIAM 支持...
函数计算
更多信息，请参见 什么是函数计算。函数计算能做什么？利用函数实现业务消息的处理，通过函数计算平台开发、运行业务消息处理逻辑，订单处理，任务执行。利用函数对消息进行快速加工处理，ETL清洗。利用函数计算灵活扩展将消息转储到指定...
函数计算
更多信息，请参见 什么是函数计算。函数计算能做什么？利用函数实现业务消息的处理，通过函数计算平台开发、运行业务消息处理逻辑，订单处理，任务执行。利用函数对消息进行快速加工处理，ETL清洗。利用函数计算灵活扩展将消息转储到指定...
直播互动解决方案
在线直播教育的场景通常会涉及多个直播间，且每个直播间中也会有多名成员。本文以单直播间、一名老师、两名学生的场景为例，说明如何使用 云消息队列 MQTT 版 实现直播...直播场景需要传输流媒体服务，详细信息，请参见 什么是音视频通信。
权限策略
云消息队列 MQTT 版 权限管理是通过阿里云的访问控制RAM（Resource Access Management）实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即...更多信息 权限策略示例 什么是访问控制 为RAM用户授权 通过RAM限制用户的访问IP地址
AMQP和JMS差异
项目 AMQP 0-9-1协议 JMS 定义 线级协议 Java API 跨平台 是 否 跨语言 是 否 消息收发模型 4种消息收发模型：Direct Exchange Fanout Exchange Topic Exchange Header Exchange 2种消息收发模型：P2P Pub/Sub 消息类型 二进制数据类型 5种...
免费说明
云消息队列 RocketMQ 版 产品按量付费方式中，部分计费项提供一定的免费。以下项目暂时免费，正式收费前将以公告、短信、站内信等方式进行通知：说明 免费项目只针对按量付费，资源包与包年包月的付费方式不可享受以下项目。每个月免费拥有...
查看订阅关系
什么是订阅关系 云消息队列 RocketMQ 版 里的一个Group ID代表一个Consumer实例群组。对于大多数分布式应用来说，一个Group ID下通常会挂载多个Consumer实例。云消息队列 RocketMQ 版 的订阅关系主要由Topic+Tag共同组成，即一个Group ID下...
Terraform
更多信息，请参见 什么是Terraform。Terraform的命令行接口CLI（Command Line Interface）提供一种简单机制，用于将配置文件部署到阿里云或其他任意支持的云上，并对其进行版本控制。它编写了描述云资源拓扑的配置文件中的基础结构，例如...
OpenService
使用说明 本接口用于第一次使用 消息服务MNS 的场景。开通服务后，您才能使用 消息服务MNS。只要调用任意可用地域的接入点就可以开通全地域。说明 可用地域包括英国（伦敦）、美国（弗吉尼亚）、华东1（杭州）、华北2（北京）、华南1（深圳...
基本概念
Tag 消息标签，二级消息类型，用来进一步区分某个Topic下的消息分类。更多信息，请参见 Topic与Tag最佳实践。Producer 消息生产者，也称为消息发布者，负责生产并发送消息。Producer实例 Producer的一个对象实例，不同的Producer实例可以...
参数说明
消息订阅 表 2.消息订阅参数 参数 说明 firstTopic 您在 云消息队列 MQTT 版 控制台创建的父级Topic。更多信息，请参见 基本概念。重要 如果使用了未创建或未授权的Topic，会导致客户端鉴权失败，云消息队列 MQTT 版 服务端断开客户端的...
产品架构
发送的消息可以是网站的页面访问、服务器日志，也可以是CPU和内存相关的系统资源信息。Kafka Broker 用于存储消息的服务器。Kafka Broker支持水平扩展。Kafka Broker节点的数量越多，云消息队列 Kafka 版 集群的吞吐率越高。Group 通过pull...
消息查询
在使用Kafka的过程中遇到无法正确消费消息、消息丢失、消息延迟等消费问题时，您可通过消息查询功能查看指定消息的详细内容和相关属性，帮助您排查异常原因。若确定消息所在Topic的分区ID以及消息位点，可采用按位点查询消息；若不确定消息...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的Java SDK收发顺序消息的示例代码。前提条件 您已完成以下操作：下载1.2.7或以上版本的Java SDK。更多信息，请参见...
全球消息路由定价详情
消息传输费用 计费阶梯 消息条数（亿条/月）各地域单价（元/万条）中国大陆地域间路由 金融云地域间路由 跨国地域（除迪拜）间路由 跨国地域（含迪拜）间路由 第一阶梯 0~1 0.1 0.2 0.4 1.2 第二阶梯 1~10 0.09 0.18 0.36 1.08 第三阶梯 10...
接口和参数说明
本文介绍 云消息队列 MQTT 版 云端Java SDK提供的接口和相关的参数说明。使用说明 公共参数和网络参数可在 ChannelConfig.class 中设置。ChannelConfig.class 路径为 server-sdk-{SDK Version}\com\alibaba\mqtt\server\config ，其中 {SDK...
SOFAMQ 常见问题
第几次重试 每次重试间隔时间 1 10 秒 2 30 秒 3 1 分钟 4 2 分钟 5 3 分钟 6 4 分钟 7 5 分钟 8 6 分钟 9 7 分钟 10 8 分钟 11 9 分钟 12 10 分钟 13 20 分钟 14 30 分钟 15 1 小时 16 2 小时 广播消费方式 广播消费方式可以保证一条消息...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的C#SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的...
发送普通消息（三种方式）
消息发送方在发送了一条消息后，不需要等待服务端响应即可发送第二条消息。发送方通过回调接口接收服务端响应，并处理响应结果。应用场景 异步发送一般用于链路耗时较长，对响应时间较为敏感的业务场景，例如，您视频上传后通知启动转码...
- 产品推荐
- 这些文档可能帮助您