消费者分类
云消息队列 RocketMQ 版 支持PushConsumer和SimpleConsumer这两种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息 云消息队列 RocketMQ 版 面向不同的业务场景提供了不同...
Control Center设置告警
Out of sync replica count 集群中与Leader同步的Topic Partition副本总数。即分区的总和（Topic分区*Topic复制因子）。Production request count 每秒对集群中topic的生产请求量。Under replicated topic partitions 复制不足的Topic分区...
生产者（Producer）
消费者按照指定的订阅关系从 云消息队列 RocketMQ 版 服务端中获取消息并消费。内部属性 客户端ID 定义：生产者客户端的标识，用于区分不同的生产者。集群内全局唯一。取值：客户端ID由 云消息队列 RocketMQ 版 的SDK自动生成，主要用于...
NTP服务
物联网平台提供NTP服务，为资源受限的嵌入式设备，解决无法实时地获取服务端时间的问题。原理介绍 物联网平台的NTP服务，借鉴NTP协议原理，将物联网平台作为NTP服务器。高精准度的时间校正流程如下：设备端通过指定Topic向物联网平台发送...
Knative概述
生产者可以在消费者启动之前产生事件，消费者也可以在生产者启动之前监听事件。Function:Knative Functions为您提供了一个简单的方式来创建、构建和部署Knative服务。您无需深入了解底层技术栈（如Kubernetes、容器和Knative），通过使用...
Control Center设置告警
不同步副本计数 集群中与leader同步的topic partition副本总数；即，分区的总和（topic分区*topic复制因子）。生产请求数 每秒对集群中topic的生产请求量。复制不足的topic分区 复制不足的topic分区的数量。该指标的一个用例是想知道Kafka ...
采集-IoT/嵌入式日志
C Producer方案与其他嵌入式采集方案对比如下：类别 C Producer 其他方案 编程 平台 移动端+嵌入式 移动端为主 上下文 支持 不支持 多日志 支持 不支持（一种日志）自定义格式 支持 不支持（提供若干个有限字段）优先级 支持 不支持 环境...
OnsConsumerAccumulate-查询消息消费堆积情况
10000 LastTimestamp long 该 Group ID 下消费者实例群组中最近消费的某条消息的生产时间。单位：毫秒级的 Unix 时间戳。1566231000000 TotalDiff long 该 Group ID 订阅的所有 Topic 的消费堆积数量。100 Online boolean 该 Group ID 下...
数据转发到消息队列RocketMQ
云消息队列RocketMQ版：RocketMQ SDK注册的消费者获取消息时会触发服务端的动态过滤计算，RocketMQ根据该消费者上报的过滤条件的表达式进行匹配，并将符合条件的消息投递给该消费者，实现消费者所属业务服务器接收设备上报至物联网平台的...
基于Make的编译说明
配置项 说明 FEATURE_MQTT_COMM_ENABLED MQTT上云功能开关，MQTT上云是指搭载了C Link SDK的嵌入式设备和阿里云服务器之间使用 MQTT 协议进行连接和交互。使能之后，SDK将提供MQTT相关的API。FEATURE_COAP_COMM_ENABLED CoAP上云功能开关，...
发送消息（多线程）
SOFAStack 消息队列的消费者和生产者客户端对象是线程安全的，可以在多个线程之间共享使用。您可以在服务器上（或者多台服务器）部署多个生产者和消费者实例，也可以在同一个生产者或消费者实例里采用多线程发送或接收消息，从而提高消息...
创建资源
创建Topic Topic是 云消息队列 RocketMQ 版 里对消息的一级归类，例如创建名称为Topic_Trade的Topic来识别交易类消息，消息生产者将消息发送到Topic_Trade，而消息消费者则通过订阅该Topic来获取和消费消息。Topic的使用说明如下：Topic不...
创建资源
创建Topic Topic是 云消息队列 RocketMQ 版 里对消息的一级归类，例如创建名称为Topic_Trade的Topic来识别交易类消息，消息生产者将消息发送到Topic_Trade，而消息消费者则通过订阅该Topic来获取和消费消息。Topic的使用说明如下：Topic不...
消息（Message）
消费者按照指定的订阅关系从 云消息队列 RocketMQ 版 服务端中获取消息并消费。消息内部属性 系统保留属性 主题名称 定义：当前消息所属的主题的名称。集群内全局唯一。更多信息，请参见 主题（Topic）。取值：从客户端SDK接口获取。消息...
定时/延时消息
消费中 消息被消费者获取，并按照消费者本地的业务逻辑进行处理的过程。此时服务端会等待消费者完成消费并提交消费结果，如果一定时间后没有收到消费者的响应，云消息队列 RocketMQ 版 会对消息进行重试处理。具体信息，请参见 消费重试。...
事务消息
提交待消费 第二阶段如果事务执行结果明确为提交，服务端会将半事务消息重新存储到普通存储系统中，此时消息对下游消费者可见，等待被消费者获取并消费。消费中 消息被消费者获取，并按照消费者本地的业务逻辑进行处理的过程。此时服务端会...
ISV产品说明
本文为您介绍ISV产品主要功能及功能逻辑。...号码迁移 通过Meta官方API提供的号码迁移功能，把使用其他BSP的号码迁移至 Chat App 消息服务。完全线上自主化的客户号码迁移。通道管理 查看WABA下所有号码的验证状态、连接状态、质量评分、发送...
仪表盘
具体的指标含义和计算公式如下：分类 指标 定义 计算公式 消息数量指标 处理中的消息（inflight messages）在消费者客户端正在处理，但客户端还未返回消费结果的消息。最晚一条拉取消息的位点－最晚一条提交消息的位点 已就绪的消息（ready...
批量消费
功能原理 批量消费主要分为以下两个阶段：消息从生产者发布至 云消息队列 RocketMQ 版 后，Push消费者中的拉消息线程通过长轮询将消息拉到后台缓存。Push消费者根据缓存情况是否满足任一批量条件，判断是否将消息提交给消费线程完成消费。...
迁移上云操作
步骤四：更换接入点 确认此次迁移范围内的所有生产者以及消费者，将源集群消息收发代码中的接入点修改为目标阿里云 云消息队列 RocketMQ 版 实例的接入点。步骤五：迁移消息业务 按照Topic粒度，分阶段执行切流操作。步骤一：迁移评估 执行...
常见问题
分布式事务 SDK 与事务云服务通信返回失败消息，说明 SDK 发送给事务云服务的消息违反某些约束条件，可以根据事务 ID 在 dtx-rpc.log 中查询事务云服务返回的具体失败信息。如何查看分布式事务的日志？分布式事务的事务日志存放路径为${...
MySQL协议开发说明
COM_STMT_FETCH 不支持 对Lindorm使用嵌入式SQL中的FETCH语句。COM_STMT_CLOSE 支持 关闭预处理语句。COM_STMT_SEND_LONG_DATA 不支持 用于发送大对象的命令，在 COM_STMT_EXECUTE 前执行。Replication Protocol 不支持 MySQL的Binlog复制...
仪表盘
uid instance_id topic message_type Counter rocketmq_throughput_out_total byte 服务端投递给消费者的消息吞吐量，其中消息数量包含消费者处理中、处理成功和处理失败的消息。uid instance_id topic consumer_group fifo_enable Counter...
阿里云日志服务Splunk Add-on
一个消费组由多个消费者构成，同一个消费组下面的消费者共同消费一个Logstore中的数据，消费者之间不会重复消费数据。一个Logstore下面会有多个Shard。每个Shard只会分配到一个消费者。一个消费者可以同时拥有多个Shard。所创建的消费者...
步骤三：调用SDK收发消息
云消息队列 RocketMQ 版 支持 SimpleConsumer 和 PushConsumer 两种消费者类型，您可以选择任意一种方式订阅消息，具体的消费者类型的差异如下：对比项 PushConsumer SimpleConsumer 接口方式 使用监听器回调接口返回消费结果，消费者仅...
自定义配置
RabbitMQ自定义消费者：通过设置自定义消费者的类名或者包含匿名内部消费者的类名，可以看到该消费者的调用链路。多个消费者以英文逗号（,）分隔。线程池监控：支持Tomcat/Dubbo/HSF等框架的线程池指标监控，需升级Agent探针至最新版本。该...
Spring 集成
背景信息 主要包括以下三部分内容：普通消息生产者和 Spring 集成 事务消息生产者和 Spring 集成 消息消费者和 Spring 集成 请确保同一个 Group ID 下所有 Consumer 实例的订阅关系保持一致。详情请参见 订阅关系一致。SpringBoot 框架下...
步骤三：创建资源
生产者需要将消息发送至指定Topic，消费者通过订阅Topic获取消息进行消费。消费者消费消息时，需要指定Group订阅对应的Topic。Group和Topic的关系是N∶N，即同一个Group可以订阅多个Topic，同一个Topic也可以被多个Group订阅。前提条件 您...
配置AMQP服务端订阅
工作原理 AMQP服务端订阅 会将同一产品所有设备的 指定类型消息，实时转发到一个或多个消费组中，每个消费组中包括多个消费者即AMQP客户端。每条消息转发到消费组时，消费组中随机一个消费者收到消息，不同消费组通过消费组ID区分。在上图...
Paho-MQTT C（非嵌入式版）接入示例
本文介绍如何使用Paho提供的C语言MQTT开源工程（非嵌入式版），将设备接入阿里云物联网平台，并进行消息收发。使用前必读 本文操作步骤以普通用户权限为例。如果您在操作过程中涉及到管理员权限才能执行的操作，可尝试使用 sudo 命令执行。...
SQL结果集导出
水印嵌入方式 是 您可选择如下嵌入方式：数据水印：是指将标识信息通过一定方式嵌入到数据中，数据使用者难以察觉该水印信息。文件水印：是指将标识信息通过一定方式嵌入到文件中，数据使用者可以直接看到该水印信息。文件水印信息 是 请...
HSF概述
HSF为用户屏蔽了分布式领域中的各种复杂技术细节，如远程通讯、序列化实现、性能损耗、同步与异步调用方式的实现等。HSF架构 HSF作为一个纯客户端架构的RPC框架，没有服务端集群，所有HSF服务调用均是通过服务消费方（Consumer）与服务提供...
错误编码：HSF-0001
名称不匹配，检查代码中对应发布者和消费者XML配置的 interface、version、group，3个数据要完全一致（注意大小写也要一样，同时要注意前后不能有空格）。检查服务提供者防火墙是否开启或网络不通，即telnet服务提供者IP HSF端口（默认...
什么是服务端订阅
即使消费者的客户端宕机，或因消费能力不足堆积了消息，消费端恢复后，设备生成的消息也可以和堆积消息并行发送，使设备优先恢复实时推送消息状态。使用AMQP服务端订阅，需先在控制台配置AMQP服务端订阅，请参见 配置AMQP服务端订阅。然后...
数据转发到AMQP服务端订阅消费组
工作原理 云产品流转 可将同一产品所有设备或指定设备的指定Topic消息，实时转发到一个或多个消费组中，每个消费组中包括多个消费者即AMQP客户端。每条消息转发到消费组时，消费组中随机一个消费者收到消息，不同消费组通过消费组ID区分。...
什么是生活物联网平台
选择接入天猫精灵IoT生态的产品，可以被天猫精灵全系生态终端控制，包括天猫精灵各型号音箱、天猫精灵App、天猫精灵车机等，可以实现语音、触屏等多模态交互，为消费者提供控制、查询、播报、场景与主动服务。目前天猫精灵IoT生态已接入...
HSF概述
HSF为用户屏蔽了分布式领域中的各种复杂技术细节，如远程通讯、序列化实现、性能损耗、同步与异步调用方式的实现等。HSF架构 HSF作为一个纯客户端架构的RPC框架，没有服务端集群，所有HSF服务调用均是通过服务消费方（Consumer）与服务提供...
仪表盘
tenant_userid instance_id instance_name authentication_type Counter kafka_server_brokertopicmetrics_failedfetchrequests_total 消费者失败请求量。tenant_userid instance_id instance_name authentication_type Counter kafka_...
2020年
2020-07-24 全部区域 UDF（嵌入式）支持SQL语言定义函数 MaxCompute支持通过SQL语言定义函数（SQL Function）在SQL脚本中使用SQL定义的UDF。2020-07-24 全部区域 UDF（SQL自定义函数）支持设置使用包年包月计算资源Project的作业优先级 您...
合作伙伴及开源生态
战略合作伙伴 蚂蚁集团除了与众多行内 ISV 进行合作外，还与众多的金融机构达成了战略合作协议，在场景、技术上进行深度合作，特别是在金融科技、分布式架构上与各金融机构进行联合创新，形成金融科技开放生态。目前，蚂蚁集团对外开放的...
- 产品推荐
- 这些文档可能帮助您