获取主题消息-获取主题消息文档介绍内容-阿里云

步骤三：调用SDK收发消息

云消息队列 RocketMQ 版提供多种语言的SDK用于收发不同类型的消息，本文以Java SDK为例，说明如何调用SDK连接云消息队列 RocketMQ 版服务端，完成普通消息的收发流程。前提条件步骤二：创建资源安装IDEA 您可以使用IntelliJ IDEA或者...

QPS限制

100 删除互动消息应用 100 创建消息组 100 更新消息组 100 查询消息组成员 100 查询指定用户下消息组 100 获取消息组详情 100 加入消息组 200 禁言消息组全员 100 批量禁言消息组内成员 100 批量取消消息组内禁言成员 100 查询被禁言的消息...

什么是云消息队列 MQTT 版

核心概念 Topic：消息主题，一级消息类型，生产者向其发送消息。生产者：也称为消息发布者，负责生产并发送消息至Topic。消费者：也称为消息订阅者，负责从Topic接收并消费消息。消息：生产者向Topic发送并最终传送给消费者的数据。规则：...

批量消费

说明根据消息获取方式，云消息队列 RocketMQ 版提供Push和Pull两种类型的消费者，更多信息，请参见基本概念。功能原理批量消费主要分为以下两个阶段：消息从生产者发布至云消息队列 RocketMQ 版后，Push消费者中的拉消息线程通过长...

消息收发定价详情

说明云消息队列 RocketMQ 版有4种消息类型：普通消息、定时和延时消息、事务消息以及顺序消息，其中，定时和延时消息、事务消息以及顺序消息为高级特性消息。更多信息，请参见消息类型列表。计费单价阶梯单价说明按照阿里云主账号...

API概览

互动消息 API 描述 GetMessageToken 调用GetMessageToken获取长连接建连Token。CreateMessageApp 调用CreateMessageApp创建互动消息应用。UpdateMessageApp 调用UpdateMessageApp更新互动消息应用信息。ListMessageApp 调用ListMessageApp...

视频点播VOD的审计事件

GetMessageCallbackEventList 获取消息回调事件列表。GetMezzanineInfo 获取音视频的源文件信息。GetOSSStatis 获取OSS统计数据。GetPersonalStorageList 获取个人存储列表。GetPlayInfo 通过视频ID直接获取媒体文件（支持视频和音频）的...

视频直播的审计事件

GetMessageToken 获取消息鉴权Token。GetMultiRateConfig 获取多速率配置。GetMultiRateConfigList 获取多速率配置列表。InitializeAutoShowListTask 创建一个定时任务。ListLiveRealtimeLogDelivery 查询用户下所有实时日志投递。...

基本概念

消息堆积量=处理中消息量+已就绪消息量，具体的指标含义，可参考以下说明：上图表示指定主题的某一队列中各消息的状态，云消息队列 RocketMQ 版将处于不同处理阶段的消息数量和耗时进行统计，这些指标可直接反映队列中消息的处理速率和...

堡垒机的审计事件

GetNotificationConfig 获取消息通知策略。GetOMConfig 获取运维配置。GetOpenMemberStatus 获取用户会员开通状态。GetOperationDatabaseToken 获取数据库运维令牌。GetOperationToken 获取主机运维令牌。GetOssPolicyToken 获取OSS签名直...

消费者负载均衡

消费者从云消息队列 RocketMQ 版 获取消息消费时，通过消费者负载均衡策略，可将主题内的消息分配给指定消费者分组中的多个消费者共同分担，提高消费并发能力和消费者的水平扩展能力。本文介绍云消息队列 RocketMQ 版消费者的负载均衡...

Topic与Tag最佳实践

背景信息 Topic和Tag的定义如下：Topic 消息主题，通过Topic对不同的业务消息进行分类。Tag 消息标签，用来进一步区分某个Topic下的消息分类，消息从生产者发出即带上的属性。Topic和Tag的关系如下图所示。适用场景您可能会有这样的疑问：...

调用TCP协议的SDK收发普通消息

} 调用TCP协议的SDK发送普通消息获取相应语言的客户端SDK后，您即可运行以下示例代码发送普通消息。Java import com.aliyun.openservices.ons.api.Message;import com.aliyun.openservices.ons.api.OnExceptionContext;import ...

使用ACL功能进行访问控制

背景信息企业A购买了云消息队列 Kafka 版，企业A希望用户A只能从云消息队列 Kafka 版的所有Topic中消费消息，而不能向云消息队列 Kafka 版的任何Topic生产消息。注意事项 Kafka为公网/VPC类型实例提供默认SASL用户，默认SASL用户仅...

调用HTTP协议的SDK收发普通消息

} 调用HTTP协议的SDK发送普通消息获取相应语言的客户端SDK后，您即可运行以下示例代码发送普通消息。Java import com.aliyun.mq.http.MQClient;import com.aliyun.mq.http.MQProducer;import com.aliyun.mq.http.model.TopicMessage;...

实例管理

实例是用于云消息队列 RocketMQ 版服务的虚拟机资源，会存储消息主题（Topic）和客户端ID（Group ID）信息。使用云消息队列 RocketMQ 版进行消息收发，必须先创建云消息队列 RocketMQ 版实例。本文介绍如何在云消息队列 RocketMQ 版...

连接查询

如需了解云消息队列 MQTT 版客户端的连接情况，您可以指定Topic、Group ID以及Client ID查询客户端的当前在线数、在指定时间段内的在线...Topic：客户端订阅的消息主题。QoS：客户端与服务端消息传输的服务质量级别，详细信息，请参见 QoS。

API使用说明

消息服务MNS 提供了以下API接口：队列接口队列接口适用于点对点的消息收发，当接收消息时，需要应用端自行轮询获取消息（拉模式）。主题接口主题接口适用于一对多的消息收发，应用端只需要在某个地址上启动监听，服务端就会主动将消息推...

MNS提供哪些可用的操作？

本文介绍消息服务MNS 提供了哪些可用的操作。消息服务MNS 队列模型支持的操作指令如下：接口功能描述...Unsubscribe 删除订阅 ListSubscriptionByTopic 获取主题的订阅列表接口功能描述支持方式 PublishMessage 发布消息控制台、API调用

消息（Message）

消息中转时做好不可变设计云消息队列 RocketMQ 版服务端5.x版本中，消息本身不可编辑，消费端获取的消息都是只读消息视图。但在历史版本3.x和4.x版本中消息不可变性没有强约束，因此如果您需要在使用过程中对消息进行中转操作，务必将...

DataWorks OpenAPI概述

1级 GetMetaTableThemeLevel 调用GetMetaTableThemeLevel获取表的主题和层级关系。1级 UpdateMetaCollection 调用UpdateMetaCollection更新集合对象。2级 ListMetaCollections 调用ListMetaCollections查询集合信息。2级 ...

消息队列Kafka版的审计事件

消息队列Kafka版已与操作审计服务集成，您可以在操作审计中查询用户操作消息队列Kafka版产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中，满足实时审计、问题回溯分析等需求。操作审计记录了...

} catch(ClientException$e){/获取错误消息 echo$e->getErrorMessage();} catch(ServerException$exception){/获取错误代码 print_r($exception->getErrorCode());获取 Request Id print_r($exception->getRequestId());获取错误消息 print...

主题模型基本概念

推送地址（Endpoint）消息接收端，订阅者用于接收主题消息的地址。TopicURL 消息服务MNS 的主题访问域名地址，格式如下：http://$AccountId.mns.$Region.aliyuncs.com/topics/$TopicName。AccountId：阿里云账号ID。Region：消息服务MNS ...

TopicMessage

主题消息的最长保留时间为1天，超过这个时间，不论消息是否成功推送给用户都将被垃圾回收器回收。消息属性 MessageId 消息的编号。一个主题中每个消息都有唯一的MessageId。Message 消息正文。MessageMD5 消息正文的MD5值。MessageTag 消息...

通过创建规则实现邮件推送事件通知

从接收端队列获取通知消息，请参见队列使用手册。从接收端队列中接收异步回调结果消息的示例代码请参见以下文档：Java SDK：队列使用手册 Python SDK：队列使用手册 PHP SDK：队列使用手册 C#SDK：队列使用手册 RESTful API：...

直播互动消息简介

消息收发支持发送消息、获取消息、消息存储、消息审核等功能。消息组管理支持创建消息组、人数获取、消息组禁言等管理功能。产品优势支持跨多终端消息收发。支持消息默认存储及服务端消息获取。支持消息安全审核及按需发送。适用场景 ...

API概览

GetMetadataAmount 调用GetMetadataAmount获取云消息队列 RabbitMQ 版实例的元数据。RenewInstance 调用RenewInstance对云消息队列 RabbitMQ 版实例进行续费。ModifyInstance 调用ModifyInstance对云消息队列 RabbitMQ 版实例资源...

通过创建规则实现日志服务事件通知

从对应的队列中获取通知消息的方式。更多信息，请参见队列使用手册。使用SDK从对应队列中接收异步回调结果消息的示例代码可参见以下文档：Java SDK：队列使用手册 C++ SDK：C++ SDK Python SDK：队列使用手册 PHP SDK：队列使用手册 C#...

实例使用变更

V3.x.x版本 V3.x.x版本中，您创建云消息队列 MQTT 版实例后，无需绑定云消息队列 RocketMQ 版，马上就可获取相应接入点进行消息收发。说明如果您需要将云消息队列 MQTT 版的数据与其他阿里云产品进行互通，则需要使用规则。详细信息...

消息过滤

使用SDK订阅主题消息时，可以通过设置消息的标签值来进行消息过滤。完整的示例代码，请参见步骤五：发布消息。向主题发送消息时设置消息的标签值的示例代码如下：TopicMessage message=new Base64TopicMessage();这里的标签值要和订阅规则...

GetHotlineMessageLog-获取热线消息记录

调用GetHotlineMessageLog接口获取热线消息记录。调试您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试授权信息当前API暂无授权信息透出。请求参数名称 ...

推送到HTTP

步骤一：创建主题登录消息服务MNS控制台。在左侧导航栏，单击主题列表。在顶部菜单栏，选择地域。在主题列表页面，单击创建主题。在创建主题面板，配置以下参数，然后单击确定。名称：主题名称。消息最大长度：发送到主题的消息体...

快速入门概述

消息服务MNS 支持使用队列模型和主题模型收发消息，实现一对一或者一对多的消费模式，本文以简单明了的方式让您快速上手消息服务MNS。背景信息消息服务MNS 提供队列模型和主题模型。队列模型：支持一对一的消费模式。队列模型队列模型...

API概览

地域 API 标题 API概述 OnsRegionList 获取地域信息列表调用OnsRegionList获取云消息队列 RocketMQ 版目前开放服务的地域（Region）信息列表。实例 API 标题 API概述 OnsInstanceCreate 创建实例调用OnsInstanceCreate接口创建实例。...

OnsRegionList-获取地域信息列表

调用OnsRegionList获取云消息队列 RocketMQ 版目前开放服务的地域（Region）信息列表。接口说明注意阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖...

异步任务处理机制

{"Notification":{"RocketMQ":{"Endpoint":"RocketMQ消息通知地址","TopicName":"RocketMQ消息通知主题","InstanceId":"RocketMQ消息通知实例Id"} } } 通过NotifyEndpoint和NotifyTopicName两个参数指定MNS接收地址和主题接收异步消息通知 ...

日志管理

本案例要查询主题消息的消息轨迹，即输入主题名称和MessageId，查询语句格式为$TopicName and$MessageId，例如 logtest and 8798453B65727FC6433E6AB4F746XXXX。查询结果如下图所示，记录了某条消息从发送到通知的过程。本案例要查询队列...

OnsMessagePush-向指定的消费者推送消息

通过传入的 MsgId 获取指定消息的消息体，再将消息体重新进行封装推送给消费者。此时重新发送的这条消息和原消息的消息内容相同，但并不是同一条消息且 MsgId 不同。调试您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰...

消息存活时间

什么是消息存活时间在云消息队列 RabbitMQ 版中，消息存活时间用于限制消息在Queue中可以存在的时间，如果消息在Queue中存在的时间超过了设置的消息存活时间，消息将会被进行如下处理：若您未给Queue设置死信Exchange，消息将被Queue...

获取主题消息

新品推荐