自定义鉴权模式
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的鉴权相关的请求以及消息收发业务。使用说明 无论使用何种鉴权模式，本质上可以归结为身份认证和资源权限两个基本功能。身份认证，即客户端的身份标识，...
收发延时消息
本文提供使用TCP协议下的Java SDK收发延时消息的示例代码供您参考。前提条件 您已完成以下操作：安装Java SDK。更多信息，请参见 准备环境。创建资源。代码中涉及的资源信息，例如实例、Topic和Group ID等，需要在控制台上提前创建。更多...
ListNodeGroupTransferPackets
DevEui String 0000000000000001 收发此数据包的节点的DevEUI。FPort Integer 99 收发此数据包时所使用的FPort。FcntDown Long 1111 下行帧计数。FcntUp Long 1123 上行帧计数。Freq Float 470.3 收发此数据包的频点。FreqBandPlanGroupId ...
概述
本文介绍使用RocketMQ 4.x/3.x系列的Java SDK访问阿里云 云消息队列 RocketMQ 版 实例收发消息的流程。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更...
快速使用MQTT的Java SDK收发消息（终端和终端消息收发...
本文介绍如何快速使用 云消息队列 MQTT 版 的Java SDK实现MQTT终端与终端消息的收发。前提条件 创建资源 获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 云消息队列 MQTT ...
使用限制
单实例的消息收发 TPS 4000 条/秒 说明 消息收发计算 TPS 规格是按照消息大小 1 KB 为基准计算消息收发之和。如需更高规格，请 提交工单。定时/延时消息的延时时长 3 天 默认最大限制 3 天，超过 3 天消息将发送失败。您可以在 msg....
消息收发功能
云消息队列 MQTT 版 支持多语言的消息收发。本文提供单独使用 云消息队列 MQTT 版 收发消息以及与 云消息队列 RocketMQ 版 结合使用时需使用的代码示例的链接。单独使用 云消息队列 MQTT 版 收发消息 语言 链接 Java ...
视频专区
本文为您介绍 云消息队列 RocketMQ 版 的操作视频。云消息队列 RocketMQ 版5.x系列 快速使用 云消息队列 RocketMQ 版5.x系列的Java SDK收发消息 云消息队列 RocketMQ 版4.x系列 快速使用云消息队列 RocketMQ 版4.x系列的Java SDK收发消息
Demo工程
public static final String ORDER_GROUP_ID="您已创建的用于收发顺序消息的Group ID;public static final String ACCESS_KEY="您的阿里云账号的AccessKey ID，获取方式，请参见 创建AccessKey;public static final String SECRET_KEY="您...
收发定时消息
本文提供使用TCP协议下的C/C++ SDK收发定时消息的示例代码供您参考。定时消息可以做到在指定时间戳之后才可被消费者消费，适用于对消息生产和消费有时间窗口要求，或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意...
收发事务消息
本文提供使用 TCP 协议下的 Java SDK 收发事务消息的示例代码供您参考。消息队列提供类似 X/Open XA 的分布式事务功能，通过消息队列事务消息，能达到分布式事务的最终一致。说明 对于新手用户，建议在正式收发消息前，阅读 Demo 工程来...
快速入门
如果您是首次使用 云消息队列 MQTT 版，您可以参考快速入门文档，了解如何购买实例并接入 云消息队列 MQTT 版 服务端完成基本的消息收发流程。操作流程 使用SDK收发消息流程如下图所示。云消息队列 MQTT 云消息队列 MQTT快速入门 云消息...
规格介绍
超分型 DDH规格 支持的ECS实例规格族 CPU数量（Socket数）物理CPU型号 物理CPU核数 vCPU核数 ② 内存（GiB）网络带宽能力（出/入，Gbit/s）④ 网络收发包能力（出/入，万PPS）④ 通用超分型g7s 自定义规格 2 Intel ® Xeon ® Platinum ...
收发定时消息
注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");deliver time，单位：ms。指定一个时刻，在这个时刻之后消息才能被消费，这个例子表示3s后才能被消费。long deliverTime=CurrentTimeMillis()+3000;msg....
快速入门概述
轻量消息队列（原 MNS）支持使用队列模型和主题模型收发消息，实现一对一或者一对多的消费模式，本文以简单明了的方式让您快速上手 轻量消息队列（原 MNS）。背景信息 轻量消息队列（原 MNS）提供队列模型和主题模型。队列模型：支持一对一...
收发普通消息
不同消息类型的Topic不能混用，例如普通消息的Topic只能用于收发普通消息，不能用于收发其他类型的消息。final String topic="${TOPIC};Topic所属的实例ID，在消息队列RocketMQ版控制台创建。若实例有命名空间，则实例ID必须传入；若实例无...
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....
通用型（g系列）
g8a实例规格指标明细 实例规格 vCPU 内存（GiB）网络带宽基础/突发（Gbit/s）网络收发包PPS 连接数 多队列 弹性网卡 单网卡私有IPv4地址数 单网卡IPv6地址数 云盘IOPS基础/突发 云盘带宽基础/突发（Gbit/s）ecs.g8a.large 2 8 1.5/12.5 90...
接口和参数说明
SOFAStack 消息队列提供 Java SDK 实现消息发送与订阅，您可通过本文了解消息发送和订阅相关接口的参数说明。通用参数 参数名 参数...更多信息 消息收发代码示例 发送普通消息（三种方式）收发顺序消息 收发延时消息 收发事务消息 订阅消息
信号保持
本文为您介绍信号保持组件。功能说明 信号保持组件实现对给定信号的保持功能，在保持周期内都将按照该信号给出。计算逻辑原理 将算法运行状态分为保持状态和非保持状态，初始化默认为非保持状态。保持状态下 若未达到保持周期，则输出上...
收发普通消息
本文提供使用TCP协议下的.NET SDK收发普通消息的示例代码。前提条件 您已完成以下操作：下载.NET SDK。更多信息，请参见 版本说明。环境准备。更多信息，请参见 环境准备。创建资源。代码中涉及的资源信息，例如实例、Topic和Group ID等，...
实例管理
查看实例数据统计 在 实例详情 页面单击 数据统计 页签并设置查询时间，可查询该实例在指定时间范围内的消息收发统计数据，包括实例的 消息收发 TPS、订阅关系数 和 客户端连接数。获取实例接入点 在 实例详情 页面单击 接入点 页签，即可...
收发顺序消息
本文提供使用 TCP 协议下的 Java SDK 收发顺序消息的示例代码供您参考。前提条件 您已完成以下操作：通过 Maven 方式引入依赖。Java SDK 的最新版本号，可参见 SDK 版本说明。dependencies dependency groupId ...
安装CPP动态库
在使用社区版C++ SDK接入阿里云 云消息队列 RocketMQ 版 来收发消息前，您需按本文提供的操作步骤安装CPP动态库。前提条件 在开始做准备工作前，请确保您的操作系统满足以下条件：Linux：CentOS 6.8、CentOS 7.2、RHEL 6.x、RHEL 7.x ...
ALIYUN:ROS:WaitConditionHandle
ALIYUN:ROS:WaitConditionHandle用于接收信号，与ALIYUN:ROS:WaitCondition配合使用以控制资源栈的执行流程。创建ECS实例时，在自定义数据执行过程中发送信号。语法 {"Type":"ALIYUN:ROS:WaitConditionHandle","Properties":{"Mode":String...
消息轨迹查询
当消息的收发不符合预期时，您可以使用消息轨迹查询功能，查询消息的收发轨迹，确保数据正常流转、快速定位异常。操作步骤 登录 云消息队列 MQTT 版 控制台，并在左侧导航栏单击 实例列表。在顶部菜单栏选择目标地域，然后在实例列表中单击...
实例规格族
g8a实例规格指标明细 实例规格 vCPU 内存（GiB）网络带宽基础/突发（Gbit/s）网络收发包PPS 连接数 多队列 弹性网卡 单网卡私有IPv4地址数 单网卡IPv6地址数 云盘IOPS基础/突发 云盘带宽基础/突发（Gbit/s）ecs.g8a.large 2 8 1.5/12.5 90...
收发事务消息
本文提供使用TCP协议下的Java SDK收发事务消息的示例代码。云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。说明 对于新手用户，建议在正式收发消息前，...
Ruby SDK收发消息
本文介绍如何使用Ruby SDK通过接入点接入 云消息队列 Kafka 版 并收发消息。环境准备 您已安装Ruby。更多信息，请参见 安装Ruby。安装Ruby依赖库 执行以下命令安装Ruby依赖库。gem install ruby-kafka-v 0.6.8 准备配置 可选：下载SSL根...
消息类型
TCP Java SDK 收发普通消息的示例代码 发送普通消息（三种方式）发送消息（多线程）订阅消息 定时和延时消息 定时消息：Producer 将消息发送到消息队列服务端，但并不期望这条消息立马投递，而是推迟到在当前时间点之后的某一个时间投递到 ...
DATASOURCE:ROCKETMQ:Groups
取值：tcp：表示该Group ID仅适用于TCP协议的消息收发。http：表示该Group ID仅适用于HTTP协议的消息收发。InstanceId String 否 是 需获取资源列表的Group ID所对应的实例ID。无 RefreshOptions String 否 是 当资源栈更新时，数据源资源...
收发顺序消息
不同消息类型的Topic不能混用，例如普通消息的Topic只能用于收发普通消息，不能用于收发其他类型的消息。final String topic="${TOPIC};Topic所属的实例ID，在消息队列RocketMQ版控制台创建。若实例有命名空间，则实例ID必须传入；若实例无...
计算型（c系列）
c8a实例规格指标明细 实例规格 vCPU 内存（GiB）网络带宽基础/突发（Gbit/s）网络收发包PPS 连接数 多队列 弹性网卡 单网卡私有IPv4地址数 单网卡IPv6地址数 云盘IOPS基础/突发 云盘带宽基础/突发（Gbit/s）ecs.c8a.large 2 4 1.5/最高12.5...
基础版/铂金版实例计费
请确保您购买的消息TPS上限的规格大于业务实际的消息收发TPS峰值，避免超过规格上限值触发限流，导致部分消息收发失败。计算规则 消息TPS仅涉及通过 云消息队列 MQTT 版 收发的消息，不涉及 云消息队列 RocketMQ 版 收发的消息。对于QoS=1...
API概览
队列消息收发 API 说明 支持方式 SendMessage 发送消息 控制台、API调用 BatchSendMessage 批量发送消息 API调用 ReceiveMessage 消费消息 控制台、API调用 BatchReceiveMessage 批量消费消息 API调用 DeleteMessage 删除消息 控制台、API...
收发定时消息和延时消息
不同消息类型的Topic不能混用，例如普通消息的Topic只能用于收发普通消息，不能用于收发其他类型的消息。final String topic="${TOPIC};Topic所属的实例ID，在消息队列RocketMQ版控制台创建。若实例有命名空间，则实例ID必须传入；若实例无...
基础版/铂金版实例计费
请确保您购买的消息TPS上限的规格大于业务实际的消息收发TPS峰值，避免超过规格上限值触发限流，导致部分消息收发失败。计算规则 消息TPS仅涉及通过 云消息队列 MQTT 版 收发的消息，不涉及 云消息队列 RocketMQ 版 收发的消息。对于QoS=1...
如何快速使用云消息队列RabbitMQ版的Java SDK收发消息
本文提供使用 云消息队列 RabbitMQ 版 的Java SDK收发消息的快速入门视频。
如何快速使用消息队列RocketMQ版的TCP Java SDK收发...
本文提供使用 云消息队列 RocketMQ 版 的TCP Java SDK收发消息的快速入门视频。
- 产品推荐
- 这些文档可能帮助您