QueryMqttTraceMessageOfClient-查询消息轨迹
取值说明如下：pub_mqtt：微消息队列 MQTT 版客户端发送消息。sub：微消息队列 MQTT 版客户端订阅消息。push_offline：服务端推送离线消息到微消息队列 MQTT 版客户端。pub_mqtt ActionCode string 消息动作的返回码。取值说明如下 mqtt....
产品优势
访问安全性 表格存储 提供多种权限管理机制，并对每一次请求都进行身份认证和鉴权，以防止未授权的数据访问，确保数据访问的安全性。支持数据访问权限管理，包括登录权限、创建表权限、读写权限、白名单控制权限等。无缝扩展 表格存储 通过...
参数说明
云消息队列 RocketMQ 版 提供.NET SDK实现消息发送与订阅，您可通过本文了解消息发送和订阅相关接口的参数说明。参数名 参数说明 NAMESRV_ADDR 设置TCP协议接入点，从 云消息队列 RocketMQ 版 控制台的 实例详情 页面获取。AccessKey ...
参数说明
云消息队列 RocketMQ 版 提供C/C++ SDK实现消息发送与订阅，您可通过本文了解消息发送和订阅相关接口的参数说明。参数名 参数说明 NAMESRV_ADDR 设置TCP协议接入点，从 云消息队列 RocketMQ 版 控制台的 实例详情 页面获取。AccessKey ...
RocketMQ全链路追踪解决方案
process PushConsumer中 MessageListener 接口对消息的处理过程，span以消息进入 MessageListener 为开始，离开 MessageListener 时结束。以上几个span的关系如下：receive span未启用时：process span为send span的子级。receive span启用...
收发普通消息（三种方式）
} } 单向（Oneway）发送 原理 发送方只负责发送消息，不等待服务端返回响应且没有回调函数触发，即只发送请求不等待应答。此方式发送消息的过程耗时非常短，一般在微秒级别。应用场景 适用于某些耗时非常短，但对可靠性要求并不高的场景，...
如何快速测试云消息队列 Kafka 版服务端是否正常？
在创建并部署 云消息队列 Kafka 版 实例后，您可以使用 云消息队列 Kafka 版 控制台直接发送消息，快速测试服务端是否正常。前提条件 您已创建并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。操作流程 快速测试 云消息队列 ...
JMS概述
发送者向Queue发送消息时不需要接收者同时处于活跃状态，接收者从Queue接收消息时同样不需发送者处于活跃状态。JMS P2P（主账号与RAM账号场景）JMS P2P（RAM角色跨账号授权场景）Pub/Sub JMS Pub/Sub消息收发模式具有以下特点：一条消息...
QueryMqttTraceMessagePublish-查询消息发送轨迹
AC1EC0030EAB78308DB16A3EC773BD95 ClientId string 发送消息的客户端 ID。GID_test@producer 示例 正常返回示例 JSON 格式 {"RequestId":"69AD5550-BF22-438A-9202-A6E89185*","MessageTraceLists":[{"Time":"2021-05-21 15:08:19.210",...
收发顺序消息
如果发送方有多个生产者或者有多个线程并发发送消息，则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为消息顺序的依据，和业务侧的发送顺序未必一致。具体的示例代码，请以 云消息队列 RocketMQ 版 代码库 为准。全局顺序消息和...
仪表盘
场景二：线上某些订单状态有异常，需要排查对应的消息链路环节是否正常发送消息。场景三：需要分析消息流量变化趋势、流量分布特点或消息体量，进而进行业务趋势分析规划。场景四：需要查看和分析应用上下游依赖拓扑情况，进行架构升级优化...
收发顺序消息
如果发送方有多个生产者或者有多个线程并发发送消息，则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为消息顺序的依据，和业务侧的发送顺序未必一致。具体的示例代码，请以 云消息队列 RocketMQ 版 代码库 为准。发送顺序消息的...
Serverless实例计费说明
计费公式 消息收发费用＝消息收发次数累计值（次）×消息收发单价（元/次）消息收发次数计算规则 消息收发次数=接收消息次数+投递消息次数 接收消息次数：表示服务端收到生产者发送的消息条数，例如，某个Topic中收到5条消息，则计算为5次...
查询原始日志
单击 表格，日志以表格形式展示。单击 原始，日志以原始形式展示。下载日志 根据需要将所需日志信息下载到本地保存或者分享资源链接供其他人下载。在 原始日志 页签，将鼠标拖动到 图标上，选择 下载日志。在 日志下载 页面，配置日志数量...
Queue管理
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息的存储资源Queue、查看Dashboard大盘、被Exchange绑定、向指定Queue发送消息、查看Consumer Tag、清空Queue和删除Queue。背景信息 Consumer Tag是Consumer客户端的标识符。您可以在 ...
收发事务消息
发送事务消息 具体的示例代码，请以 云消息队列 RocketMQ 版 代码库 为准。package com.aliyun.openservices.tcp.example.producer;import com.aliyun.openservices.ons.api.Message;import com.aliyun.openservices.ons.api.ONSFactory;...
收发顺序消息
如果发送方有多个生产者或者有多个线程并发发送消息，则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为消息顺序的依据，和业务侧的发送顺序未必一致。发送顺序消息的示例代码如下。const { MQClient,MessageProperties }=require...
消息优先级为1，就一定优先吗？
消息服务MNS 发送消息时，可以指定消息的优先级权值（取值范围1~16，1为最高优先级，默认优先级为8）。优先级越高的消息，越容易更早被消费。如果顺序发送100条消息，第50条消息的优先级置为1（其余消息优先级默认为8）。CloudQueue queue=...
消费幂等
如果此时生产者意识到消息发送失败并尝试再次发送消息，消费者后续会收到两条内容相同但Message ID不同的消息。投递时消息重复 消息消费的场景下，消息已投递到消费者并完成业务处理，当客户端给服务端反馈应答的时候网络闪断。为了保证...
收发顺序消息
如果发送方有多个生产者或者有多个线程并发发送消息，则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为消息顺序的依据，和业务侧的发送顺序未必一致。发送顺序消息的示例代码如下。import com.aliyun.mq.http.MQClient;import ...
延时消息
如果您希望消息被投递后延迟一段时间被消费者消费，您可以使用 云消息队列 RabbitMQ 版 的延时消息。云消息队列 RabbitMQ 版 原生支持延时消息，使用方式比开源RabbitMQ更简单。什么是延时消息 延时消息是指在指定时间段之后才被消费者消费...
增量同步性能白皮书
说明 分区数会随着数据规模自动增长，如您需要预先创建分区，请联系表格存储技术支持。多台机器消费是自动进行的，每台机器用相同tunnelid启动Tunnel客户端即可，详情参见 数据消费框架原理。测试场景 我们将主要测试以下场景。单机同步单...
基本概念
本文介绍 云消息队列 RocketMQ 版 的基本概念，以便您更好地理解和使用 云消息队列 ...顺序消息 顺序消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型，支持消费者按照发送消息的先后顺序获取消息，从而实现业务场景中的顺序处理。
收发顺序消息
如果发送方有多个生产者或者有多个线程并发发送消息，则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为消息顺序的依据，和业务侧的发送顺序未必一致。将以下代码拷贝到 OrderProducerDemo.cpp 文件中，修改相应的参数后，使用g+...
事务消息
事务消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行，同时需要调用多个下游业务...
日志管理
消息服务MNS 可以为队列和主题开启日志管理功能，支持将队列或主题的消息操作日志推送到 日志服务 SLS（Simple Log Service）。在成功将MNS日志推送到 SLS 后，MNS支持通过日志查询特定信息。例如在消息发送、消费、确认等环节出现异常时，...
查询消息
云消息队列 RabbitMQ 版 支持按Queue查询和按Message ID查询两种方式，前者适用于只知道消息发送到的Queue，不知道发送消息时设置的Message ID的模糊查询场景。后者适用于知道发送消息时设置的Message ID的精确查询场景。使用限制 云消息...
消息过滤
例如发送消息时未定义某个属性，在订阅时过滤条件中直接使用该属性，则过滤条件的表达式计算结果为null。如果消息自定义属性为浮点型，但过滤条件中使用整数进行判断，则消息默认被过滤，不会被投递给消费端。示例代码 发送消息 同时设置...
收发事务消息
} } int main(int argc,char*argv[]){/创建Producer和发送消息所必需的信息。ONSFactoryProperty factoryInfo;您在消息队列RocketMQ版控制台创建的Group ID。factoryInfo.setFactoryProperty(ONSFactoryProperty:ProducerId,"XXX");设置TCP...
使用限制
云消息队列 RocketMQ 版 对某些具体指标进行了约束和规范，您在使用 云消息队列 RocketMQ 版 时注意不要超过相应的限制值，以免程序出现异常。限制项 限制值 说明 Topic...批量发送消息 不支持 云消息队列 RocketMQ 版 不支持批量发送消息。
EMQX数据接入
JSON示例如下：{"temp":"23.5","hum":"37.4"} 单击 图标，发送消息。步骤三：通过表格存储控制台验证数据 登录 表格存储控制台。在页面上方，选择地域。在 概览 页面，单击实例名称。在 实例详情 页签，单击 时序表列表。在 时序表列表 页...
Queue
如果发送消息请求指定了DelaySeconds，以请求指定的DelaySeconds为准。MaximumMessageSize 消息体最大长度，单位：Byte。取值范围：1024~65536 Byte（64 KB）。该属性用于限制发送到队列的消息体的最大长度，超过该长度发送消息失败。...
数据转发到表格存储（Tablestore）
工作原理 云产品流转将设备的Topic消息转发到表格存储实例中的数据表中存储，使用表格存储的宽表引擎服务。在上图中：数据源：支持的Topic类型消息，请参见 数据格式。SQL表达式：编写SQL表达式来解析和处理设备上报的JSON数据。SQL表达式...
版本说明
本文介绍RocketMQ ONS 1.x系列Java SDK的版本信息，包含下载链接、发布时间、更新点等，以便您按需获取适用的Java SDK收发消息。重要 JDK 1.8适用于所有Java ons-client版本，JDK 1.6仅支持ons-client v1.8.4.Final及之前的版本使用。为...
收发事务消息
在发送消息前，必须调用start方法来启动Producer，只需调用一次即可，启动之后可以多线程并发发送消息。pProducer.start();Message msg=new Message(/Message Topic factoryInfo.getPublishTopics(),/Message Tag"TagA",/Message Body ...
消息幂等
如果此时Producer意识到消息发送失败并尝试再次发送消息，Consumer后续会收到两条内容相同并且Message ID也相同的消息。投递时消息重复 消息消费的场景下，消息已投递到Consumer并完成业务处理，当客户端给服务端反馈应答的时候网络闪断。...
基本概念
Producer 消息生产者，也称为消息发布者，负责生产并发送消息。Producer实例 Producer的一个对象实例，不同的Producer实例可以运行在不同进程内或者不同机器上。Producer实例线程安全，可在同一进程内多线程之间共享。Consumer 消息消费者...
作为Output接入
本文说明如何在VPC环境下通过Logstash向 云消息队列 Kafka 版 发送消息。前提条件 购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 VPC接入。下载并安装Logstash。具体操作，请参见 Download Logstash。下载并安装JDK 8。具体操作...
死信Exchange
超过指定时间消息还未被成功消费则变为死信消息，该消息将会被发送到死信Exchange。更多信息，请参见 消息存活时间。API 您可以在通过API创建Queue时，为其配置死信Exchange。更多信息，请参见 CreateQueue。客户端 您可以在 云消息队列 ...
表格（Pro版本）
表格Pro版本支持更强大的可视化功能，例如合并多个查询分析结果在同一个表格中展示、针对字段进行个性化设置等。本文介绍表格Pro版本的基本配置。简介 表格作为最常见的数据展示类型，是组织整理数据最基本的手段，通过对数据的整理，达到...
- 产品推荐
- 这些文档可能帮助您