查看消费者状态

如果消息消费出现异常,您可以在 云消息队列 RocketMQ 版 控制台查看指定Group ID的消费状态,包括消费者在线状态、订阅关系一致性结果、消费堆积相关指标、消费者客户端信息等,帮助您快速定位异常原因。应用场景 消费者状态信息包括在线...

如何开启事件推送

关于消息队列产品定价说明,请参见 消息队列 MQ。打开RocketMQ控制台的实例列表页面,点击“创建实例”按钮,填写相关信息后,点击“确定“按钮,完成实例创建。注意:在使用消息队列MQ时,请注意以下网络访问限制:Topic和GroupID创建在同...

MSHA产品和开源产品对比

消息MQ 路由 发布打标(路由ID)✅ ❌ 消息MQ 路由 消费过滤(依据路由ID计算消费单元)✅ ❌ 消息MQ Failover 切流时重置位点,消息不丢 ✅ ❌ 数据层MySQL 路由 数据保护,防止多点写脏数据 ✅ ✅ 数据层MySQL Failover 路由ID...

配置消息日志

查看消息的消费者或消费次数。查看一个月前或者更久之前的消息操作日志。注意事项 如果您删除Project、Logstore,或者将授予 云消息队列 RabbitMQ 版 的权限取消,日志将无法正常推送。为方便查询消息日志,建议您在使用SDK收发消息时设置...

主题使用手册

本文介绍如何使用C#SDK中的sample代码,来完成创建主题、创建订阅、启动HTTP Endpoint、发布消息查看HTTP Endpoint接收消息和删除主题等操作。步骤一:准备工作 下载最新版C#SDK,解压后将工程导入到VisualStudio。找到工程里四个项目中...

授权信息

消息队列 MQ(Ons)的RAM代码(RamCode)为 mq,支持的授权粒度为 RESOURCE。权限策略通用结构 权限策略支持JSON格式,其通用结构如下:{"Version":"1","Statement":[{"Effect":"<Effect>","Action":"<Action>","Resource":"<Resource>",...

快速使用MQTT.fx模拟SDK收发消息

查看消息轨迹 进入 云消息队列 MQTT 版 控制台,在 消息轨迹查询 页面输入 Group ID 和 Device ID 然后单击 查询。返回3条消息轨迹。从下至上依次为:第1条:MQTT 云消息队列 MQTT 版 控制台发送到MQTT.fx的消息。第2条:MQTT.fx客户端发送...

查看消费明细

本文主要为您介绍如何查看消息队列 RocketMQ 版 4.x系列标准版实例的费用明细,帮助您解决如下问题:如何查看每个Topic每天的费用明细和使用量?如何查看每个Topic计费项的资源包抵扣明细?如何查看每个Topic每小时的用量明细?为什么...

主题+HTTP Endpoint使用手册

本文介绍如何使用Python SDK中的sample代码,完成创建主题、创建订阅、启动HTTP Endpoint、发布消息查看HTTP Endpoint接收消息和删除主题操作。步骤一:准备工作 下载最新版Python SDK,解压后进入 mns_python_sdk 子目录。打开 sample....

报警管理

如果您选择的 Group ID 在消费对应的 Topic 时产生了消息堆积,并且堆积超过了报警阈值,消息队列 MQ 就会给报警接收人发送短信通知。消费延迟阈值:消费延迟的值是指该 Group ID 最近一次消费该 Topic 消息的时间和该 Topic 最近一次投递...

Queue管理

本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息的存储资源Queue、查看Dashboard大盘、被Exchange绑定、向指定Queue发送消息查看Consumer Tag、清空Queue和删除Queue。背景信息 Consumer Tag是Consumer客户端的标识符。您可以在 ...

消息队列

当区块链服务监听到链上事件时,会自动生成MQ消息并发布到MQ的主题上,您可以订阅MQ中的这些事件消息做进一步处理。集成消息队列 RocketMQ 说明 注意:集成阿里云消息队列Rocket MQ服务,需要您先参考安装云服务集成章节完成云服务集成的...

MQ消息回执通知

本文以异步查询OSS数据为例,介绍如何在DLA中使用MQ做消息回执通知。前提条件 开通OSS服务 说明 在DLA中异步执行SQL时,...MQ成功接收DLA消息后,您就可以通过MQ实时了解DLA异步执行SQL的任务详情。关于MQ,请参见 什么是消息队列RocketMQ版?

使用Spring Cloud框架收发消息

在 kafka.input.topic.name 配置的Topic发送消息查看Demo程序日志中是否会打印消息。具体操作,请参见 发送消息。VPC环境(消息传输不鉴权不加密)VPC环境,消息可以采用PLAINTEXT协议不鉴权不加密传输。客户端通过默认接入点访问 云消息...

授权信息

本文为您介绍 消息队列 MQ(RocketMQ)为RAM权限策略定义的操作(Action)、资源(Resource)和条件(Condition)。消息队列 MQ(RocketMQ)的RAM代码(RamCode)为 rocketmq,支持的授权粒度为 RESOURCE。权限策略通用结构 权限策略支持...

公共参数

x-mq-version 是 调用 云消息队列 RocketMQ 版 的版本号,当前版本为2015-06-06。Content-MD5 否 HTTP消息体的MD5值。具体格式,请参见 Content-MD5 Header Field。公共返回头 参数 说明 Content-Length HTTP响应Body的长度。Connection ...

事件推送

关于消息队列产品定价说明,请参见 消息队列 MQ。新建消息队列实例,完成以下操作。在概览页面,单击新建实例。在创建实例弹窗,输入您的自定义信息后,单击确认。假设,您已创建一个名为test的消息队列标准版实例。您可以在实例详情页面,...

查询消息轨迹

MQ Server 消息类型 普通消息 定时消息 顺序消息 事务消息 说明 发送的消息为定时消息或延时消息时,消息类型 都显示为 定时消息。到达Server 消息到达 云消息队列 RocketMQ 版 服务端的时间。预设DeliverAt 定时消息的预计投递时间。实际...

权限策略

mq:QueryMqttMsgTransTrend 根据Topic查询消息的收发报表 mq:SendMqttMessageByConsole 控制台发消息测试 mq:CreateMqttTopic 创建Topic mq:DeleteMqttTopic 删除Topic mq:ListMqttTopic 查询Topic mq:UpdateMqttTopic 更新Topic备注信息 ...

MQ 事务消息纳入全局事务管理样例

本样例介绍如何把 MQ 事务消息的发送纳入 GTS 管理的全局事务。前提条件 在把 MQ 事务消息的发送纳入 GTS 管理的全局事务,请先完成以下工作:准备一个可用的 MySQL 环境(可以是阿里云的 RDS)。准备一个可用的 Maven 环境。样例说明 样例...

搭建与管理网络

凭证入网 网关配置完成,并分配入网凭证给自己后,您就可以用这个凭证来使用网络,并且可以将消息队列(MQ)作为数据出口。登录 物联网络管理平台控制台。在左侧导航栏,选择 节点管理>节点分组。在 节点分组 页面,单击 创建分组。在 创建...

sample-txc-edas 样例

DJM.LOG.RETAIN.COUNT=7-DJM.LOG.FILE.SIZE=300MB"在 sample-txc-edas/txc-client-mq/client/bin 目录下执行 run.sh,查看 MQ 的 Provider 执行结果。将 sample-mq-consumer 工程上传到 ECS。在 sample-mq-consumer/src/main/java/...

QueryMqttTraceMessagePublish-查询消息发送轨迹

mqtt.trace.action.msg.pub.mq消息动作取值为 pub_mq时返回该参数值。mqtt.trace.action.msg.pub.mqtt ActionInfo string 消息动作的说明信息。取值说明如下:Pub From Mqtt Client:消息动作取值为 pub_mqtt时返回该参数值。Pub From MQ...

开通服务并授权

说明 此权限暂不支持通过控制台查看MQTT实例列表,如需查看,需授予mq:MqttInstanceAccess权限以查询指定实例的基本信息。更多信息,请参见 控制台实例操作权限。AliyunMQPubOnlyAccess 云消息队列 MQTT 版 的发布权限,被授予该权限的RAM...

收发普通消息

普通消息是指 云消息队列 RocketMQ 版 中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Python SDK收发普通消息的示例代码。前提条件 您已完成以下操作:安装Python SDK。更多信息,请参见 ...

收发顺序消息

顺序消息(FIFO消息)是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的Python SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类:全局顺序:对于指定的一个Topic,所有消息按照...

收发定时消息和延时消息

背景信息 延时消息:Producer将消息发送到 云消息队列 RocketMQ 版 服务端,但并不期望立马投递这条消息,而是延迟一定时间后才投递到Consumer进行消费,该消息即延时消息。定时消息:Producer将消息发送到 云消息队列 RocketMQ 版 服务端...

收发事务消息

def_init_(self):threading.Thread._init_(self)self.count=0#重新New一个Client self.mq_client=MQClient(#设置HTTP接入域名,进入消息队列RocketMQ版控制台实例详情页面的HTTP接入点区域查看。{HTTP_ENDPOINT}",#AccessKey ID阿里云...

MQ监控

MQ监控可展示消息队列RocketMQ版的Topic发布和订阅消息的情况。应用限制 EDAS标准版不支持MQ监控,专业版和铂金版支持MQ监控。功能入口 登录 EDAS控制台。在左侧导航栏,单击 应用管理>应用列表,在顶部菜单栏选择地域并在页面上方选择微...

收发普通消息

消息内容。MessageTag:"",/消息标签。Properties:map[string]string{},/消息属性。}/设置消息的Key。msg.MessageKey="MessageKey"/设置消息自定义属性。msg.Properties["a"]=strconv.Itoa(i)ret,err:=mqProducer.PublishMessage(msg)if ...

收发定时消息和延时消息

消息内容。MessageTag:"",/消息标签。Properties:map[string]string{},/消息属性。}/设置消息的Key。msg.MessageKey="MessageKey"/设置消息自定义属性。msg.Properties["a"]=strconv.Itoa(i)/延时消息,发送时间为10s后。该参数格式为...

收发顺序消息

消息内容。MessageTag:"",/消息标签。Properties:map[string]string{},/消息属性。}/设置消息的Key。msg.MessageKey="MessageKey"/设置消息的自定义属性。msg.Properties["a"]=strconv.Itoa(i)/设置分区顺序消息的Sharding Key,用于...

权限策略

您可在 云消息队列 MQTT 版 控制台的 实例详情 页面查看实例是否有命名空间。云消息队列 MQTT 版 的Resource和Action的可选值和对应规则可分为控制台、OpenAPI和 云消息队列 MQTT 版 客户端三大类。针对控制台资源的相关操作,按资源类型又...

通知

消息服务MNS 不再提供Android SDK,...阿里云消息队列(MQ)推出 微消息队列MQTT,适用于移动互联网以及物联网应用,连接端(浏览器、Android、iOS、智能设备、互动直播、车联网)与云,实现双向通信,万物互联。更多信息,请参见 Demo工程。

通知

消息服务MNS 不再提供Objective-C ...阿里云消息队列(MQ)推出 微消息队列MQTT,适用于移动互联网以及物联网应用,连接端(浏览器、Android、iOS、智能设备、互动直播、车联网)与云,实现双向通信,万物互联。更多信息,请参见 Demo工程。

OnsMessageTrace-查看消息消费结果

调用OnsMessageTrace根据Message ID来判断...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsMessageTrace 接口,您还可以通过云消息队列 RocketMQ 版控制台查看消息的消费状态。具体操作,请参见 查询消息轨迹。

什么是Account ID?

本文介绍Account ID的概念及查看方法。Account ID是阿里云注册用户的主账号ID,可在阿里云官网查看。在 消息服务MNS产品页 单击 我的阿里云。在 我的账号 区域查看 账号ID,即Account ID。

OnsDLQMessageGetById-根据Message ID查询死信消息

通过传入Message ID查询指定的死信消息。...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsDLQMessageGetById 接口,您还可以通过云消息队列 RocketMQ 版控制台查看死信消息。具体操作,请参见 死信队列。

收发普通消息

普通消息是指 云消息队列 RocketMQ 版 中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的C#SDK收发普通消息的示例代码。前提条件 您已完成以下操作:安装C#SDK。更多信息,请参见 准备环境。...

收发顺序消息

顺序消息(FIFO消息)是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的C#SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类:全局顺序:对于指定的一个Topic,所有消息按照严格的...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 Kafka 版 消息服务 云消息队列 RocketMQ 版 全局事务服务 (文档停止维护) 表格存储 弹性公网IP
新人特惠 爆款特惠 最新活动 免费试用