版本说明
5.x版本实例默认都有命名空间，4.x版本实例可在 云消息队列 RocketMQ 版 控制台 实例详情 页面的 基础信息 区域查看是否有命名空间。3.x.x 发布时间 发布内容 下载链接 2021-10-18 功能优化 负载均衡：以消息为粒度进行负载，负载更加均衡...
使用Canal和RocketMQ实现数据库变更订阅处理
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
发送消息（多线程）
云消息队列 RocketMQ 版 的消费者和生产者客户端对象是线程安全的，可以在多个线程之间共享使用。您可以在服务器上（或者多台服务器）部署多个生产者和消费者实例，也可以在同一个生产者或消费者实例里采用多线程发送或接收消息，从而提高...
准备环境
在使用Node.js SDK收发消息前，您需按照本文提供的内容来准备环境。环境要求 安装Node.js 7.6.0或以上版本。更多信息，请参见 安装Node.js。安装完成后，您可以执行 node-V 命令查看Node.js语言版本。安装Node.js SDK 执行以下命令安装Node...
快速使用MQTT的Java SDK收发消息（终端和云端消息收发...
本文介绍如何快速使用 云消息队列 MQTT 版 的Java SDK实现MQTT终端和云端服务的消息收发。前提条件 创建资源 获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 MQTT终端和...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的C#SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装C#SDK。更多信息，请参见 准备环境。...
微消息队列MQTT版推送事件到函数计算
MQ4IOT 消息的一级Topic，需要在控制台申请才能使用。如果使用了没有申请或者没有被授权的Topic会导致鉴权失败，服务端会断开客户端连接。final String parentTopic="XXXXX;MQ4IOT支持子级Topic，用来做自定义的过滤，此处为示意，可以填写...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Java SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Java SDK。更多信息，请参见 准备...
授权信息
操作（Action）下表是 消息队列 MQ（RocketMQ）定义的操作，这些操作可以在RAM权限策略语句的 Action 元素中使用，用来授予执行该操作的权限。下面对表中的具体项提供说明：操作：是指具体的权限点。API：是指操作对应的API接口。访问级别...
权限策略示例
注意事项 在阅读本文前，建议您可先查看在访问控制RAM中支持的 云消息队列 MQTT 版 相关的 权限策略。如需直接复制示例代码，使用时请删除注释内容，即双斜杠（/）及以后的文字说明。示例中的取值均需替换为您实际的资源信息：post-...
关于TCP内网接入点设置的公告
为了进一步提升 云消息队列 RocketMQ 版 服务的稳定性，并以此保障您应用的稳定性，针对部署在某地域（Region）的应用，如果您使用的是TCP协议下的SDK，则需使用该地域的 云消息队列 RocketMQ 版 服务的TCP内网接入点。本文提供对应地域的...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的PHP SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装PHP SDK。更多信息，请参见 准备环境...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的Python SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照...
使用Canal和RocketMQ实现数据库变更订阅处理
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
确认消息API
使用确认消息API确认消息消费状态。请求构造 请求行 DELETE/topics/TopicName/messages?ns=INSTANCE_ID&consumer=GID HTTP/1.1 参数说明如下。参数 是否必选 说明 TopicName 是 将消息发送至的Topic名称。ns 否 实例ID，针对有命名空间的...
权限策略示例
注意事项 在阅读本文前，建议您可先查看在访问控制RAM中支持的 云消息队列 MQTT 版 相关的 权限策略。如需直接复制示例代码，使用时请删除注释内容，即“/”及以后的文字说明。示例中的{mqttinstanceId}、{storeinstanceId}、{topic}和{...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的C++ SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装C++ SDK。更多信息，请参见 准备环境...
云消息队列 RocketMQ 版
本文介绍如何在 事件总线EventBridge 控制台添加 云消息队列 RocketMQ 版 作为事件流中的事件提供方。前提条件 开通事件总线EventBridge并授权。您已购买并部署 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 ...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的C#SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的...
收发顺序消息
消息内容。设置消息的自定义属性。publishMessage->putProperty("a",$i);设置分区顺序消息的Sharding Key，用于标识不同的分区。Sharding Key与消息的Key是完全不同的概念。publishMessage->setShardingKey($i%2);result=$this->producer...
收发顺序消息
消息内容。MessageTag:"",/消息标签。Properties:map[string]string{},/消息属性。}/设置消息的Key。msg.MessageKey="MessageKey"/设置消息的自定义属性。msg.Properties["a"]=strconv.Itoa(i)/设置分区顺序消息的Sharding Key，用于...
消息队列RocketMQ版
查看任务详情：单击 详情，在 消息流出详情 页面，查看任务的源端配置、目标端配置及资源信息。编辑任务配置：单击 编辑，在 消息流出编辑 面板，修改 资源配置 和 规则配置。启停任务：单击 启用 或者 停用，然后在 提示 对话框，单击 ...
收发定时消息和延时消息
消息内容。MessageTag:"",/消息标签。Properties:map[string]string{},/消息属性。}/设置消息的Key。msg.MessageKey="MessageKey"/设置消息自定义属性。msg.Properties["a"]=strconv.Itoa(i)/延时消息，发送时间为10s后。该参数格式为...
收发定时消息和延时消息
消息内容。设置消息的自定义属性。publishMessage->putProperty("a",$i);设置消息的Key。publishMessage->setMessageKey("MessageKey");延时消息，发送时间为10s后。该参数格式为毫秒级别的时间戳。若发送定时消息，设置该参数时需要计算...
发送普通消息（三种方式）
云消息队列 RocketMQ 版 提供三种方式来发送普通消息：同步（Sync）发送、异步（Async）发送和单向（Oneway）发送。本文介绍了每种发送方式的原理、应用场景、示例代码，以及三种发送方式的对比。前提条件 安装Java SDK。更多信息，请参见 ...
准备环境
在使用Go SDK收发消息前，您需按照本文提供的内容来准备环境。环境要求 安装Golang。更多信息，请参见 安装Golang。安装完成后，您可以执行 go version 命令查看Go语言版本。安装Go SDK 执行以下命令启用Go mod。go env-w GO111MODULE=on ...
功能特性
自动化规则与MQ推送都可以进行自动化告警并推送通知，主要区别在于：自动化规则 站内推送，通知消息在物联网SIM控制台 自动化规则>通知 页面展示，不需要二次开发。具体请参见 自动化规则。MQ推送 直接将通知推送到用户自己的系统中，可以...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的Java SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格...
收发事务消息
def_init_(self):threading.Thread._init_(self)self.count=0#重新New一个Client self.mq_client=MQClient(#设置HTTP接入域名，进入消息队列RocketMQ版控制台实例详情页面的HTTP接入点区域查看。{HTTP_ENDPOINT}",#AccessKey ID阿里云...
OnsConsumerAccumulate-查询消息消费堆积情况
查询指定Group ID的消息消费堆积情况，包括当前消息堆积数量和消费延迟时间等。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 Open...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Node.js SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Node.js SDK。更多信息，请参见 ...
收发定时消息和延时消息
背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时消息。定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端...
微消息队列MQTT版
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流入源为 云消息队列 MQTT 版 的消息流入任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已创建 云消息队列 MQTT 版 实例...
准备环境
在使用PHP SDK收发消息前，您需按照本文提供的内容来准备环境。环境要求 安装PHP 5.5.0或以上版本，更多信息，请参见 安装PHP 。重要 对于PHP版本小于7.2.5的运行环境，需要将Composer依赖降低到2.2.x或以下版本。安装Composer，更多信息，...
节点分组
消息队列（MQ）：数据流转到MQ的Topic。调试转发 当 数据出口 为 阿里云物联网平台 时，出现此参数。用于控制调试开关。开：数据流转至基础Topic和物模型Topic。关：数据仅流转至物模型Topic。数据目的地 当 数据出口 为 阿里云物联网平台 ...
收发定时消息和延时消息
背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时消息。定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端...
上下线通知规则管理
云消息队列 MQTT 版 实例版本 仅内核版本为V3.x.x的实例支持使用规则，V2.x.x的实例不支持使用规则。云消息队列 MQTT 版 实例的内核版本可在 控制台 实例列表或实例详情页面查看。云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云...
状态不一致
查看目标 Group ID 的消费者状态（具体操作方法详见 查看消费者状态），连接信息中出现了不在预期范围内的客户端 IP，同时存在部分消息只堆积在非预期范围内的客户端上的情况。可能的原因：以错误的方式（AccessKeyId、AccessKeySecret、...
数据流出规则管理
云消息队列 MQTT 版 实例版本 仅内核版本为V3.x.x的实例支持使用规则，V2.x.x的实例不支持使用规则。云消息队列 MQTT 版 实例的内核版本可在 控制台 实例列表或实例详情页面查看。云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云...
数据流入规则管理
云消息队列 MQTT 版 实例版本 仅内核版本为V3.x.x的实例支持使用规则，V2.x.x的实例不支持使用规则。云消息队列 MQTT 版 实例的内核版本可在 控制台 实例列表或实例详情页面查看。云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云...
- 产品推荐
- 这些文档可能帮助您