全球消息路由定价详情
计费项 全球消息路由的计费公式如下：消息传输费用 消息传输费用=消息传输量×消息传输单价 以进行消息路由传输的消息数量为维度计费，计费单价根据月消息传输总量阶梯变化。具体单价，请参见本文中的 计费单价。消息传输量=（普通消息+...
诊断分析
物联网平台针对指定设备提供异常项目诊断服务，包括设备离线异常、上下行消息异常、规则流转消息异常等，并根据诊断结果给出相应的排查处理建议。前提条件 设备已接入阿里云物联网平台。具体操作，请参见 设备接入。已开启设备诊断服务。...
计费概述
计费项 云消息队列 MQTT 版 的计费项目如下：计费项说明如下：基础版/铂金版实例计费 专业版实例计费 Serverless版实例计费 计价倍率 在使用MQTT协议传输消息时，QoS 和 cleanSession 参数的设置会影响实际的计费。每条消息（包含客户端和...
前言
BucketReplicationSample.java 数据复制 BucketTransferAccelerationSample.java 传输加速 CreateFolderSample.java 简单上传 PostObjectSample.java 表单上传 说明 PostObject 的实现不依赖Java SDK。AppendObjectSample.java 追加上传 ...
接入点对比
公网/VPC实例接入点对比 网络类型 端口 接入点 协议 适用场景 公网 9093 SSL接入点 SASL_SSL 消息传输过程需加密，消息收发需鉴权，支持以下两种机制验证身份：PLAIN SCRAM-SHA-256 专有网络VPC 9092 默认接入点 PLAINTEXT 消息传输过程...
计费常见问题
包年包月（预付费）实例的费用只限于 云消息队列 MQTT 版 所支持的协议，即 云消息队列 MQTT 版 的消息传输以及消息存储。若您使用 云消息队列 MQTT 版 的数据流入、数据流出规则和 云消息队列 RocketMQ 版 进行通信，云消息队列 RocketMQ ...
领域模型概述
产品定位 云消息队列 RocketMQ 版 是一款典型的分布式架构下的中间件产品，使用异步通信方式和发布订阅的消息传输模型。通信方式和传输模型的具体说明，请参见下文 通信方式介绍 和 消息传输模型介绍。云消息队列 RocketMQ 版 产品具备异步...
全球消息路由
全球消息路由功能可用于跨地域间的消息同步，通过路由规则将消息从源实例的Topic中同步到目标实例的Topic，并支持过滤规则，按照指定的Tag将消息过滤后再进行同步。在容灾备份或异地多活场景下，您可以创建全球消息路由任务，确保跨地域间...
默认接入点收发消息
本文以Java SDK为例介绍如何在VPC环境下使用SDK接入 云消息队列 Kafka 版 的默认接入点并收发消息。前提条件 步骤三：创建资源 安装1.8或以上版本JDK 安装2.5或以上版本Maven 安装编译工具。本文以 IntelliJ IDEA Ultimate 为例。安装Java...
消息服务消息批量操作注意事项
如果消息超过64 KB，请参见 超大消息传输。BatchReceiveMessage一次最多获取16条消息，有时候明明有10条消息，一次BatchReceiveMessage却只能获取5条消息。例如：在一个队列里顺序发送了10条消息(m1,m2,m3,m4,m5,m6,m7,m8,m9,m10)，第一次...
使用Spring Cloud框架收发消息
Spring Cloud是用于构建消息驱动的微服务应用程序的框架，提供服务发现、配置管理、消息传递、负载均衡等微服务相关的解决方案，可以更容易地构建分布式系统和进行服务间通信。本文介绍如何使用Spring Cloud框架接入 云消息队列 Kafka 版 ...
计费概述
全球消息路由功能的计费项如下：全球消息路由费用=消息传输费用+任务资源占用费用 详细的计费项说明和单价，请参见 全球消息路由定价详情。price-calculatorButton { width:700px;height:50px;border-radius:40px;border:1px solid#ff4a00;...
快速使用MQTT的Java SDK收发消息（终端和终端消息收发...
本文介绍如何快速使用 云消息队列 MQTT 版 的Java SDK实现MQTT终端与终端消息的收发。前提条件 创建资源 获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 云消息队列 MQTT ...
版本说明
本文介绍RocketMQ ONS 1.x系列Java SDK的版本信息，包含下载链接、发布时间、更新点等，以便您按需获取适用的Java SDK收发消息。重要 JDK 1.8适用于所有Java ons-client版本，JDK 1.6仅支持ons-client v1.8.4.Final及之前的版本使用。为...
版本说明
本文介绍Java SDK的版本信息，包含使用限制、下载链接、发布时间、更新点等，以便您按需获取适用的Java SDK收发消息。使用限制 JDK 1.8适用于所有Java ons-client版本，JDK 1.6仅支持ons-client v1.8.4.Final及之前的版本使用。为避免升级...
MQTT和RocketMQ进行数据互通（跨产品数据流入）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
快速使用MQTT的Java SDK收发消息（终端和云端消息收发...
本文介绍如何快速使用 云消息队列 MQTT 版 的Java SDK实现MQTT终端和云端服务的消息收发。前提条件 创建资源 获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 MQTT终端和...
RocketMQ全链路追踪解决方案
链路追踪功能可在多个服务进行交互时记录请求在系统的传输过程，并提供详细的日志和性能数据，云消息队列 RocketMQ 版 支持将符合OpenTelemetry标准的Trace数据集成至阿里云的链路追踪服务中，帮助您快速诊断异常问题。Trace定义 云消息...
使用实例接入点收发消息
当使用应用程序与Kafka集群建立连接时，可通过实例接入点接入 云消息队列 Kafka 版 并收发消息。Kafka实例提供默认接入点、SSL接入点和SASL接入点，以满足您不同的连接和安全需求。默认接入点适用于在保密性较高的VPC环境收发消息；SASL接...
告警规则指标说明
异常监控 指标说明 指标名称 单位 是否为常用指标 指标说明 异常发生次数 无 是 在软件系统运行过程中发生的各种异常的次数，如空指针异常、数组越界异常、IO异常等。可以根据该指标判断调用堆栈是否抛错，从而判断是否存在应用调用异常。...
普通消息
普通消息为 云消息队列 RocketMQ 版 中最基础的消息，区别于有特性的顺序消息、定时/延时消息和事务消息。本文为您介绍普通消息的应用场景、功能原理、使用方法和使用建议。应用场景 普通消息一般应用于微服务解耦、事件驱动、数据集成等...
客户端连接常见问题
消费消息需要保证在规定时间内完成，如果消费耗时超过服务端约定的超时时间，对于可靠传输的模式，服务端可能会重试推送，业务需要做好幂等去重处理。超时时间请参见 使用限制。System.out.println("receive msg from topic"+s+",body is"+...
使用Canal和RocketMQ实现数据库变更订阅处理
false 链路轨迹追踪设置 使用Canal发送变更事件到 云消息队列 RocketMQ 版 时，可以选择开启 云消息队列 RocketMQ 版 的云上消息轨迹功能，以便出现异常时可以快速定位链路问题。开启链路轨迹追踪功能，需要设置如下参数：rocketmq.enable....
版本说明
aliyun-mq-windows-cpp-sdk.zip aliyun-mq-linux-cpp-sdk.tar.gz 1.1.1 发布时间 发布内容 Windows版下载 Linux版下载 2018-07-31 新特性 新增SSL加密传输功能（只适用于消息队列RocketMQ版企业铂金版客户）。PushConsumer默认使用异步拉取...
版本说明
aliyun-mq-windows-cpp-sdk.zip aliyun-mq-linux-cpp-sdk.tar.gz 1.1.1 发布时间 发布内容 Windows版下载 Linux版下载 2018-07-31 新特性 新增SSL加密传输功能（只适用于消息队列RocketMQ版企业铂金版客户）。PushConsumer默认使用异步拉取...
日志配置
客户端日志用于记录客户端运行过程中的异常，帮助快速定位和修复问题。本文介绍 SOFAStack 消息队列的客户端日志的打印方式，以及默认和自定义配置。打印客户端日志 消息队列的 TCP Java SDK 基于 SLF4J 接口编程。依赖 log4j 或 logback ...
产品架构
Java应用：数据库、缓存、消息、JVM本身、微服务等，还可以指定任意类方法注入各种复杂的实验场景。云原生场景：节点上CPU、内存、网络、磁盘、进程实验场景。Pod网络和Pod本身实验场景。例如，删除Pod。容器的实验场景。例如：删除容器、...
顺序消息
如需保证消息生产的顺序性，则必须满足以下条件：同一消息组（MessageGroup）消息生产顺序性的范围为消息组，生产者发送消息时可以为每条消息设置消息组，只有同一消息组内的消息可以保证顺序性，不同消息组或未设置消息组的消息之间不保证...
迁移上云操作
注意事项 执行切流操作时，每切换一次Topic状态，请及时观察消息收发是否符合预期，若无异常再执行下一步切换操作，若消息收发出现异常可直接回滚操作，待异常原因排查后继续进行切流操作。请确保此次迁移任务范围内的Topic均完成切流操作...
直播互动解决方案
本文以单直播间、一名老师、两名学生的场景为例，说明如何使用 云消息队列 MQTT 版 实现直播互动消息、禁言、成员上下线通知以及系统消息通知，其中，老师和学生的客户端以HTML网页为例，后端应用以Java为例。背景信息 在直播互动的场景下...
使用Java实现Kafka消费
本文介绍如何使用Java实现Kafka消费。参数说明 参数 描述 示例 bootstrap.servers 初始连接的集群地址，格式为${project}.${endpoint}:${port}，请根据实际的Project名称及其所在的Endpoint进行配置。更多信息，请参见 服务入口。阿里云VPC...
App端性能体验功能说明
核心功能 错误捕获能力强，类型丰富 提供Java崩溃、Native崩溃、Swift崩溃、Objective-C崩溃、ANR、自定义异常的捕捉 快速定位错误根源 提供行为日志、详细日志、内存快照、设备信息、自定义字段，帮您快速发现问题原因，提升问题解决效率 ...
CDC问题
Postgres CDC提示未传输TOAST数据，是什么原因？发现PG服务器磁盘使用率高，WAL日志不释放是什么原因？Postgres CDC同步Postgres中DECIMAL类型数据精度超过最大精度时，会返回什么结果？在DataStream API中构建Postgres CDC Source时如何...
示例代码
MaxCompute[python3]无 无 访问云原生大数据计算服务 MaxCompute[java11]向消息队列 Kafka 投递消息[node.js14]向消息队列 Kafka 投递消息[python3]无 向消息队列 Kafka 投递消息[go1]向消息队列 Kafka 投递消息[java11]向消息服务 MNS ...
视频专区
本文为您介绍 云消息队列 RocketMQ 版 的操作视频。云消息队列 RocketMQ 版5.x系列 快速使用 云消息队列 RocketMQ 版5.x系列的Java SDK收发消息 云消息队列 RocketMQ 版4.x系列 快速使用云消息队列 RocketMQ 版4.x系列的Java SDK收发消息
快速入门概述
云消息队列 MQTT 版 支持使用多种...调用SDK收发消息 快速使用MQTT的Java SDK收发消息（终端和终端消息收发）快速使用MQTT的Java SDK收发消息（终端和云端消息收发）操作视频 该视频以终端和终端交互流程为例演示如何使用Java SDK收发消息。
如何快速使用微消息队列MQTT版的Java SDK收发消息？
本文提供使用 微消息队列MQTT版 的Java SDK收发消息的快速入门视频。
如何快速使用消息队列RabbitMQ版的Java SDK收发消息
本文提供使用 云消息队列 RabbitMQ 版 的Java SDK收发消息的快速入门视频。
- 产品推荐
- 这些文档可能帮助您