API使用说明
消息服务MNS 提供了以下API接口：队列接口 队列接口适用于点对点的消息收发，当接收消息时，需要应用端自行轮询获取消息（拉模式）。主题接口 主题接口适用于一对多的消息收发，应用端只需要在某个地址上启动监听，服务端就会主动将消息推...
消费者分类
使用方式 SimpleConsumer的使用涉及多个接口调用，由业务逻辑按需调用接口获取消息，然后分发给业务线程处理消息，最后按照处理的结果调用提交接口，返回服务端当前消息的处理结果。示例如下：/消费示例：使用SimpleConsumer消费普通消息，...
使用流程
创建格式转换任务后，您可以通过调用 GetOfficeConversionTask 接口获取任务状态或者使用消息队列获取转换结果的通知（Notification）。智能媒体管理提供文档预览V1和文档预览V2两个版本的文档预览，请根据实际场景选择。重要 如果预览服务...
直播互动消息简介
消息收发 支持发送消息、获取消息、消息存储、消息审核等功能。消息组管理 支持创建消息组、人数获取、消息组禁言等管理功能。产品优势 支持跨多终端消息收发。支持消息默认存储及服务端消息获取。支持消息安全审核及按需发送。适用场景 ...
Account
消费者 从MNS的消息队列获取消息的角色。主题模型 主题所有者 开通MNS服务的Account通过 CreateTopic 接口创建出一个主题，这个Account就是该主题的所有者，主题所有者拥有该主题的所有操作权限。发布者 向MNS的主题发布消息的角色。订阅者...
子设备禁用、启用、删除
子设备通过网关订阅该Topic获取消息。Alink请求数据格式 {"id":"123","version":"1.0","params":{},"method":"thing.disable"} Alink响应数据格式 {"id":"123","code":200,"data":{} } 参数说明 参数 取值 说明 id String 消息ID号。String...
API概览
GetTopicStatus 获取消息收发状态 获取Topic的消息收发状态。GetQuotaTip 获取Topic和分区的使用配额 获取Topic和分区的使用配额。QueryMessage 查询 Topic 消息 查询 Topic 中存储的消息，可通过消息创建时间或者位点来进行查询。消费组 ...
如何处理消息堆积
请参见 查看消费者状态 获取消息堆积的消费者实例所对应的宿主机IP地址，并登录该宿主机。执行以下任意命令，查看并记录Java进程的PID。ps-ef|grep javajps-lm 执行以下命令，查看堆栈信息。jstack-l pid>/tmp/pid.jstack 执行以下命令，...
API概览
您需要再调用OnsTraceGetResult接口，传入返回的查询任务ID，获取消息轨迹的详细结果。OnsTraceQueryByMsgKey 根据Message Key创建轨迹查询任务 通过传入Topic名称和Message Key创建轨迹查询任务，得到该查询任务的ID。您需要再调用...
消息（Message）
消费者按照指定的订阅关系从 云消息队列 RocketMQ 版 服务端中获取消息并消费。消息内部属性 系统保留属性 主题名称 定义：当前消息所属的主题的名称。集群内全局唯一。更多信息，请参见 主题（Topic）。取值：从客户端SDK接口获取。消息...
消费者负载均衡
消费者从 云消息队列 RocketMQ 版 获取消息消费时，通过消费者负载均衡策略，可将主题内的消息分配给指定消费者分组中的多个消费者共同分担，提高消费并发能力和消费者的水平扩展能力。本文介绍 云消息队列 RocketMQ 版 消费者的负载均衡...
延时消息
因为 云消息队列 RabbitMQ 版 的消息是分布式存储的，如果您使用pull模式的 basic.get 方法获取消息，并不能保证正好从存储的节点获取消息。开源延时消息插件方案 为了减少与开源RabbitMQ的差别，云消息队列 RabbitMQ 版 也基于原生的延时...
消息重试
获取消息重试次数 消费者收到消息后，可按照以下方式获取消息的重试次数：public class MessageListenerImpl implements MessageListener {@Override public Action consume(Message message,ConsumeContext context){/获取消息的重试次数 ...
订阅关系（Subscription）
定义 订阅关系是 云消息队列 RocketMQ 版 系统中消费者获取消息、处理消息的规则和状态配置。订阅关系由消费者分组动态注册到服务端系统，并在后续的消息传输中按照订阅关系定义的过滤规则进行消息匹配和消费进度维护。通过配置订阅关系，...
顺序消息
消费示例二：使用SimpleConsumer消费顺序消息，主动获取消息进行消费处理并提交消费结果。需要注意的是，同一个MessageGroup的消息，如果前序消息没有消费完成，再次调用Receive是获取不到后续消息的。List<MessageView>messageViewList=...
步骤三：创建资源
生产者需要将消息发送至指定Topic，消费者通过订阅Topic获取消息进行消费。消费者消费消息时，需要指定Group订阅对应的Topic。Group和Topic的关系是N∶N，即同一个Group可以订阅多个Topic，同一个Topic也可以被多个Group订阅。前提条件 您...
消费者（Consumer）
消费者通常被集成在业务系统中，从 云消息队列 RocketMQ 版 服务端获取消息，并将消息转化成业务可理解的信息，供业务逻辑处理。在消息消费端，可以定义如下传输行为：消费者身份：消费者必须关联一个指定的消费者分组，以获取分组内统一...
输入弹窗
获取消息 TextView*/public TextView getMsg();获取底部按钮的 LinearLayout*/public LinearLayout getBottomLayout();获取弹窗最外层的 RelativeLayout*/public RelativeLayout getDialogBg();设置确认按钮监听*/public void ...
消息重试
获取消息重试次数 Consumer收到消息后，可按照以下方式获取消息的重试次数，消息重试间隔时间一般不需要获取。public class MessageListenerImpl implements MessageListener {@Override public Action consume(Message message,...
企业铂金版计费说明
使用HTTP协议消费消息时，消费者客户端通过主动调用消费方法获取消息，调用方法的频率由消费者应用控制。如果服务端成功返回消息，则投递消息次数按照以上规则计算，即消息条数乘以对应的高级特性倍率和消息体大小倍率。如果服务端未返回...
消费托管MQ接口
获取消息 获取托管MQ中的消息，方法名称：consumeMQMessage。函数原型 ConsumeMQMessageResponse consumeMQMessage(final ConsumeMQMessageRequest request)请求参数 参数 必选 说明 numOfMessages 是 一次最多消费消息的条数，取值范围：1...
获取离线MQTT消息
为了简化离线消息获取机制，云消息队列 MQTT 版 系统在客户端成功建立连接并通过权限校验后，会自动加载离线消息并下发到客户端。注意事项 客户端建立连接后，需要通过权限校验才能自动加载离线消息。例如，若您使用的是Token验证的方式，...
消息堆积
解决方法 面对消息堆积，且有明显性能下降的情况，可采取以下措施处理：在消息队列控制台，通过 查看消费者状态 获取消息堆积的消费者实例所对应的宿主机 IP 地址，并登录该宿主机或容器。执行以下任一命令查看进程 pid。ps-ef|grep java ...
消息查询
按 Message ID 查询，即根据 Topic 和 Message ID，精确定位任意一条消息，获取消息的属性。建议在发送消息成功后将 Message ID 信息打印到日志中，方便问题排查。获取 Message ID 的方法如下：SendResult sendResult=producer.send(msg);...
获取离线MQTT消息
为了简化离线消息获取机制，云消息队列 MQTT 版 系统在客户端成功建立连接并通过权限校验后，会自动加载离线消息并下发到客户端。注意事项 客户端建立连接后，需要通过权限校验才能自动加载离线消息。例如，若您使用的是Token验证的方式，...
使用指南
合约消息推送开发流程 用户智能合约使用合约消息推送服务API接口，开发流程如下：在 BaaS 平台上获取消息合约名称。获取合约消息推送 API 接口定义。在用户合约中引入合约消息推送 API 接口。用户合约实现接收消息接口，供跨链消息收发合约...
消息查询
查询方式 查询条件 查询类别 说明 按Message ID查询 Topic+Message ID 精确查询 根据Topic和Message ID可以精确定位任意一条消息，获取消息的属性。按Message Key查询 Topic+Message Key 模糊查询 根据Topic和Message Key可以匹配到包含...
获取消息组详情
调用GetMessageGroup获取消息组详情。使用说明 本接口的单用户QPS限制为100次/秒。超过限制，API调用会被限流，这可能会影响您的业务，请合理调用。更多信息，请参见 QPS限制。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算...
ListQueue
Name Value API ListQueue RAM授权操作 mns:ListQueue 资源 acs:mns:$region:$accountid:/queues 使用说明 调用该接口返回结果中只包含QueueURL属性，如需进一步获取消息队列的属性可以通过 GetQueueAttributes 接口获取。如果仅需要获取...
消费进度管理
云消息队列 RocketMQ 版 定义消费位点的初始值为消费者首次获取消息时，该时刻队列中的最大消息位点。相当于消费者将从队列中最新的消息开始消费。重置消费位点 若消费者分组的初始消费位点或当前消费位点不符合您的业务预期，您可以通过...
消息存储和清理机制
了解消息存储和过期清理机制，可以从以下方面帮助您更好的进行运维管理：提供消息存储时间SLA，为业务提供安全冗余空间：消息存储时间的承诺本质上代表业务侧可以自由获取消息的时间范围。对于消费时间长、消息堆积、故障恢复等场景非常...
什么是RRPC
设备可通过发送 SUB 指令订阅指定Topic，实现从物联网平台获取消息。开发方法，请参见 Link SDK 中订阅Topic的代码示例。在设备端开发处理RRPC消息数据的方法，请参见 RRPC功能开发示例。用户服务器调用物联网平台的 RRpc 接口。物联网平台...
消息弹窗
获取消息 TextView*/public TextView getMsg();设置确认按钮点击监听*@param listener*/public void setPositiveListener(OnClickPositiveListener listener);设置取消按钮点击监听*@param listener*/public void setNegativeListener...
跨链服务
业务合约开发参考：账本访问 API 使用流程 账本访问开发使用示例 合约消息推送开发流程 用户智能合约使用合约消息推送服务API接口，开发流程如下：在BaaS平台上获取消息合约名称。获取合约消息推送 API 接口定义。在用户合约中引入合约消息...
什么是消息服务MNS
更多信息，请参见：Endpoint签名认证 主题使用手册 对于因为网络或者其他原因不方便提供回调地址的情况，消息服务MNS 依然支持将消息推送到队列中，您仍然可以直接到队列中获取消息。原先使用队列模型的消费者，可以无缝消费主题中的消息。...
接口和参数说明
云消息队列 RocketMQ 版 提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从 云消息队列 RocketMQ 版 获取消息。本文介绍消息发送和订阅的接口和参数说明。背景信息 云消息队列 RocketMQ 版 支持以下两种消息获取方式：Push...
消息过滤
服务端：消费者获取消息时会触发服务端的动态过滤计算，云消息队列 RocketMQ 版 服务端根据消费者上报的过滤条件的表达式进行匹配，并将符合条件的消息投递给消费者。消息过滤分类 云消息队列 RocketMQ 版 支持Tag标签过滤和SQL属性过滤，...
定时和延时消息
本文主要介绍 云消息队列 RocketMQ 版 的定时消息和...Go：收发定时消息和延时消息 Python：收发定时消息和延时消息 Node.js：收发定时消息和延时消息 PHP：收发定时消息和延时消息 C#：收发定时消息和延时消息 C++：收发定时消息和延时消息
生产者（Producer）
消费者按照指定的订阅关系从 云消息队列 RocketMQ 版 服务端中获取消息并消费。内部属性 客户端ID 定义：生产者客户端的标识，用于区分不同的生产者。集群内全局唯一。取值：客户端ID由 云消息队列 RocketMQ 版 的SDK自动生成，主要用于...
回执消息简介与配置流程
您可使用此消息队列名称（QueueName）和消息类型（MessageType），通过调用SDK从后台来获取队列中的短信状态报告。HTTP批量推送模式 HTTP批量推送模式表示通过HTTP POST方式发送消息到指定的Web URL。在 ChatApp消息服务控制台 设置HTTP回...
- 产品推荐
- 这些文档可能帮助您