Demo工程
Demo工程包含普通消息、顺序消息、事务消息、定时和延时消息的测试代码，以及相关Spring的配置。前提条件 安装IDE。您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。请下载IntelliJ IDEA Ultimate版本，并参见IntelliJ IDEA...
Demo工程
Java 场景 下载地址 单独使用MQTT消息收发示例 mqtt.demo.java MQTT签名示例 mqtt.signature.mode.demo.java MQTT Token示例 mqtt.token.mode.demo.java MQTT SSL加密示例 mqtt.ssl.demo.java MQTT发送消息RocketMQ订阅消息示例 mqtt.to....
Demo工程
Java 场景 下载地址 单独使用MQTT消息收发示例 mqtt.demo.java MQTT签名示例 mqtt.signature.mode.demo.java MQTT Token示例 mqtt.token.mode.demo.java MQTT SSL加密示例 mqtt.ssl.demo.java MQTT发送消息RocketMQ订阅消息示例 mqtt.to....
.NET/C# Demo
阿里云SDK核心库 dybaseapi Demo如下：说明 调用接口前需配置环境变量，通过环境变量读取访问凭证。AccessKey ID和AccessKey Secret的环境变量名：SECRET_AK_ENV、SECRET_SK_ENV。配置详情请参见 配置访问凭证。阿里云账号AccessKey拥有...
Demo工程
Demo工程包含普通消息、顺序消息、事务消息的测试代码。前提条件 安装IDE。您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。在 IntelliJ IDEA官网 下载IntelliJ IDEA Ultimate版本，并参考IntelliJ IDEA说明进行安装。下载...
10 分钟本地试用公有云消息队列
消息类型：此处选择 普通消息。单击 确定。创建分组。在左侧导航栏，单击 Group 管理。单击 创建 Group ID，然后在 创建 Group ID 对话框配置 Group ID 信息：Group ID：此处填写 SOFAMQ_DEMO_GROUP。协议类型：此处选择 TCP 协议类型。...
Demo 工程
Demo 工程包含普通消息、顺序消息、事务消息和定时、延时消息的配置以及测试代码。前提条件 安装 IDE。您可以使用 IntelliJ IDEA 或者 Eclipse，本文以 IntelliJ IDEA 为例。在 https://www.jetbrains.com/idea/ 下载 IntelliJ IDEA ...
发送消息到用户
AppId String 是 demo 发送消息的互动消息应用ID。ReceiverId String 是 uid2 消息接收用户的ID。SenderId String 是 uid1 发送消息的用户ID，长度不超过64字节。SenderInfo String 否 uid1meta1 发送消息用户的扩展信息，长度不超过512...
发送消息到群组
AppId String 是 demo 接收消息的互动消息应用ID。GroupId String 是 grouptest 接收消息的GroupID。SenderId String 是 uid1 发送消息的用户ID，长度不超过64字节。SenderMetaInfo String 否 uid1meta1 发送消息用户的扩展信息，长度不...
使用Spring Cloud框架收发消息
您可以通过此Topic在控制台发送消息，Demo程序会消费消息，并将消息打印在日志中。kafka.ssl.truststore.location SSL根证书 kafka.client.truststore.jks 的存放路径。执行以下命令，打开 kafka_client_jaas.conf 文件，配置实例的用户名...
使用MNS服务集成及回调编排任意任务类型
version:v1 type:flow steps:type:task name:Task_1 resourceArn:acs:mns:/queues/fnf-demo/messages#表示该任务（Task）步骤会向同区域，同账号下的MNS队列fnf-demo发送消息。pattern:waitForCallback#表示该任务步骤在发送MNS消息成功后...
MQTT快速入门
Demo下载地址，请参见 Demo工程。目前的Demo程序库只覆盖了一部分主流语言，后续会陆续更新。如果没有覆盖对应的开发语言，可以参考Java语言的Demo来修改。Demo工程仅提供一个基本的功能展示，具体应用到线上环境，务必修改所有参数。更多...
Java SDK接入示例
本文介绍使用AMQP协议的JMS客户端接入阿里云物联网平台，接收服务端订阅消息的示例。前提条件 已获取消费组ID，并订阅Topic消息。管理消费组：您可使用物联网平台默认消费组（DEFAULT_GROUP）或创建消费组。配置AMQP服务端订阅：您可通过...
开发场景：基于消息队列RocketMQ版实现环境隔离
步骤一：为应用开启RocketMQ消息灰度 Demo中的spring-cloud-c、spring-cloud-a应用分别为消息的生产者和消费者，通过添加启动参数-Dprofiler.micro.service.mq.gray.enable=true，在 SAE 上为其开启RocketMQ消息灰度。说明 RocketMQ消息...
SmsUp
只能用于接收云通信的消息，不能用于接收其他业务的消息*短信上行消息接收demo*/public class ReceiveDemo { private static Log logger=LogFactory.getLog(ReceiveDemo.class);static class MyMessageListener implements MessageListener...
物模型通信
设备端SDK上报属性和事件 配置设备端SDK连接物联网平台，上报属性和事件消息。Demo中，java/src/main/com.aliyun.iot.api.common.deviceApi 目录下的 ThingTemplate 文件是设备端上报属性和事件的Demo。设置连接信息。将代码中 productKey...
云端Demo工程
Demo工程包含发送消息、接收消息以及接收客户端上下线消息的示例代码及相关配置。前提条件 安装IDEA。请下载IntelliJ IDEA Ultimate版本，并参见IntelliJ IDEA说明进行安装。更多信息，请参见 下载地址。您也可以使用Eclipse，本文以...
Spring集成
云消息队列 RocketMQ 版 支持集成Spring框架的Java SDK收发消息，本文为您介绍如何使用 云消息队列 RocketMQ 版 提供的Spring框架的Demo工程。背景信息 云消息队列 RocketMQ 版 支持以下消息类型的生产者和消费者与Spring集成：普通消息的...
在Knative上实现Kafka消息推送
在 消息 Key 文本框中输入消息的Key值，例如demo。在 消息内容 文本框输入测试的消息内容，例如 {"key":"test"}。设置 发送到指定分区，选择是否指定分区。单击 是，在 分区 ID 文本框中输入分区的ID，例如0。如果您需查询分区的ID，请参见...
如何快速测试云消息队列 Kafka 版服务端是否正常？
在创建并部署 云消息队列 Kafka 版 实例后，您可以使用 云消息队列 Kafka 版 控制台直接发送消息，快速测试服务端是否正常。前提条件 您已创建并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。操作流程 快速测试 云消息队列 ...
作为Input接入
在 消息 Key 文本框中输入消息的Key值，例如demo。在 消息内容 文本框输入测试的消息内容，例如 {"key":"test"}。设置 发送到指定分区，选择是否指定分区。单击 是，在 分区 ID 文本框中输入分区的ID，例如0。如果您需查询分区的ID，请参见...
作为Input接入
在 消息 Key 文本框中输入消息的Key值，例如demo。在 消息内容 文本框输入测试的消息内容，例如 {"key":"test"}。设置 发送到指定分区，选择是否指定分区。单击 是，在 分区 ID 文本框中输入分区的ID，例如0。如果您需查询分区的ID，请参见...
作为Input接入
在 消息 Key 文本框中输入消息的Key值，例如demo。在 消息内容 文本框输入测试的消息内容，例如 {"key":"test"}。设置 发送到指定分区，选择是否指定分区。单击 是，在 分区 ID 文本框中输入分区的ID，例如0。如果您需查询分区的ID，请参见...
作为Input接入
在 消息 Key 文本框中输入消息的Key值，例如demo。在 消息内容 文本框输入测试的消息内容，例如 {"key":"test"}。设置 发送到指定分区，选择是否指定分区。单击 是，在 分区 ID 文本框中输入分区的ID，例如0。如果您需查询分区的ID，请参见...
共享订阅
在上图中，订阅者C、订阅者D、发布者A都遵循标准流程，订阅topic：demo/topic 和发布消息topic：demo/topic。因为订阅者A、订阅者B使用了共享订阅的能力，所以只会随机发给A或者B其中一个。共享订阅topic：$share/group/demo/topic 包含：...
将云消息队列 Kafka 版接入阿里云Elasticsearch
在 消息 Key 文本框中输入消息的Key值，例如demo。在 消息内容 文本框输入测试的消息内容，例如 {"key":"test"}。设置 发送到指定分区，选择是否指定分区。单击 是，在 分区 ID 文本框中输入分区的ID，例如0。如果您需查询分区的ID，请参见...
使用示例
} 步骤四：接收应答 设备接收NTP服务消息后，触发回调函数 demo_ntp_recv_handler，根据回调函数的设置，执行对应处理。您可以参考以下内容，编写回调函数的处理逻辑：物联网平台通过Topic/ext/ntp/${YourProductKey}/${YourDeviceName}/...
消息检索
在 消息 Key 文本框中输入消息的Key值，例如demo。在 消息内容 文本框输入测试的消息内容，例如 {"key":"test"}。设置 发送到指定分区，选择是否指定分区。单击 是，在 分区 ID 文本框中输入分区的ID，例如0。如果您需查询分区的ID，请参见...
设备数据订阅
背景介绍：该文档适用于多租户和单租户两种模式，发布和订阅已授权给应用的设备端的消息。物联网平台提供HTTPS/2 (Java)设备SDK进行建联，用于建立设备端与物联网平台的通信。参考SDK链接：...
使用示例
本文以C Link SDK中的 demos/mqtt_rrpc_demo.c 为例，介绍如何调用Link SDK的API，展示设备的RRPC功能。背景信息 RRPC功能的更多信息，请参见 概述。RRPC 功能基于MQTT接入，开发过程中涉及MQTT接入的代码说明，请参见 MQTT接入。配置流程 ...
Kafka数据接入
具体信息，请参见 云消息队列 Kafka 版Demo库。Compact 标签 Topic的标签。demo 创建完成后，在 Topic 管理 页面的列表中显示已创建的Topic。创建Tablestore Sink Connector依赖的 Group。您可以在 云消息队列 Kafka 版 控制台手动创建...
网关与子设备
监听topo关系变化的回调 def on_gateway_topo_change（self,request_id,params,userdata）Demo说明 网关上线后，需要先添加子设备的拓扑关系并进行子设备登录操作，子设备才能收发消息。在Demo的 gateway_demo.py 文件中（在 环境要求与...
最佳实践：订阅实例状态变更消息
author dataworks demo*/RestController@RequestMapping("/event")public class ExtensionsController {/*接收eventBridge推送过来的消息*@param jsonParam*/PostMapping("/consumer")public void consumerEventBridge(@RequestBody String...
消息收发功能
云消息队列 MQTT 版 支持多语言的消息收发。本文提供单独使用 云消息队列 MQTT 版 收发消息以及与 云消息队列 RocketMQ 版 结合使用时需使用的代码示例的链接。单独使用 云消息队列 MQTT 版 收发消息 语言 链接 Java ...
客户端首次接入云消息队列 Kafka 版时出现异常的排查...
关于客户端Demo，请参见 云消息队列 Kafka 版Demo库。说明 云消息队列 Kafka 版对客户端版本有限制。例如，如果服务端版本为0.10.2.2，建议客户端版本也为0.10.2.2。具体以服务端版本为准。配置问题：默认接入点配置错误、RAM用户未授权等...
步骤三：创建资源
具体信息，请参见 云消息队列 Kafka 版Demo库。Compact 标签 Topic的标签。demo 创建完成后，在 Topic 管理 页面的列表中显示已创建的Topic。步骤二：创建Group 登录 云消息队列 Kafka 版 控制台。在 概览 页面的 资源分布 区域，选择地域...
基本概念
具体信息，请参见 云消息队列 Kafka 版Demo库。普通消息 默认情况下，保证相同Key的消息分布在同一个分区中，且分区内消息按照发送顺序存储。集群重启或者宕机时，会导致极少量乱序。更多信息，请参见 存储引擎对比。分区顺序消息 默认情况...
作为Output接入
具体信息，请参见 云消息队列 Kafka 版Demo库。Compact 标签 Topic的标签。demo 创建完成后，在 Topic 管理 页面的列表中显示已创建的Topic。步骤三：Logstash发送消息 在安装了Logstash的机器上启动Logstash，向创建的Topic发送消息。执行...
- 产品推荐
- 这些文档可能帮助您