MQ监控

ARMS应用监控的MQ监控可展示消息队列Apache RocketMQ版的Topic发布和订阅消息的情况。功能入口 登录ARMS控制台。在左侧导航栏选择应用监控>应用列表,并在顶部菜单栏选择目标地域。在应用列表页面单击目标应用名称。在左侧导航栏中单击MQ...

MQ数据源

创建Topic 背景信息 关于利用MQ数据源进行监控的案例,请参见车联网实时监控方案。同步MQ数据源 登录ARMS控制台。在左侧导航栏,选择自定义监控数据源管理>MQ数据源。可选:如果此前未授权ARMS读取MQ数据,则按照ARMS的提示信息完成授权。...

MQ

Queue,简称MQ)是阿里云商用的专业消息中间件、企业级互联网架构的核心产品,基于高可用分布式集群技术,搭建了包括发布订阅、消息轨迹、资源统计、定时(延时)、监控报警等一套完整的消息云服务。MQ的更多信息请参见创建消息队列MQ源表...

阿里云试用中心,为您提供0门槛上云实践机会!

100+款试用云产品,最长免费试用12个月!拨打95187-1,咨询专业上云建议!
广告

MQ

消息队列(Message Queue)简称MQ,是阿里云商用的专业消息中间件,是企业级互联网架构的核心产品。消息列队是基于高可用分布式集群技术,搭建了包括发布订阅、消息轨迹、资源统计、定时(延时)和监控报警等一套完整的消息云服务。实时...

创建消息队列MQ源表

本文为您介绍实时计算如何创建消息队列MQ源表以及创建过程涉及到的CSV类格式、WITH参数和类型映射。说明 如果您需要使用带独立命名空间的MQ,请使用Blink 3.x作业版本。什么是消息队列MQ 消息队列MQ是阿里云专业消息中间件,是企业级互联网...

创建消息队列MQ结果表

本文为您介绍如何创建实时计算Flink版消息队列MQ结果表,以及创建过程涉及到的WITH参数。注意 本文仅适用于Blink 1.4.5及以上版本。如果您需要使用带独立命名空间的MQ,请使用Blink 3.x作业版本。什么是消息列队MQ 消息队列MQ(Message ...

消息队列RocketMQ版结果表

由于阿里云网络安全策略动态变化,实时计算连接公网服务MQ时可能会出现网络连接问题,推荐您使用内网服务MQ,如果在使用公网服务MQ时出现异常,请您提交工单进行咨询。accessId AccessKey ID。是 无。accessKey AccessKey Secret。是 无。...

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

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

消息队列RocketMQ版源表

由于阿里云网络安全策略动态变化,实时计算连接公网服务MQ时可能会出现网络连接问题,推荐您使用内网服务MQ,如果在使用公网服务MQ时出现异常,请您提交工单进行咨询。accessId AccessKey ID。是 无。accessKey AccessKey Secret。是 无。...

微消息队列MQTT版推送事件到函数计算

本代码提供签名鉴权模式下MQ4IOT客户端发送消息到MQ4IOT客户端的示例,其中初始化参数请根据实际情况修改。签名模式即使用阿里云账号系统提供的AccessKey和SecretKey对每个客户端计算出一个独立的签名供客户端识别使用。对于实际业务场景...

什么是消息队列RabbitMQ版?

消息队列RabbitMQ版是阿里云消息队列(MQ)团队基于AMQP 0-9-1(AMQP 0.91)标准协议研发的分布式、高吞吐、低延迟、高可扩展的云消息队列服务。消息队列RabbitMQ版完全兼容开源RabbitMQ社区、开箱即用、无需部署、免运维,帮助您快速上云...

获取MQTT客户端在线状态

数据格式如下:MQ Tag:connect/disconnect/tcpclean 其中: connect事件代表客户端上线动作。disconnect事件代表客户端主动断开连接。按照MQTT协议,客户端主动断开TCP连接之前应该发送disconnect 报文,MQTT服务器在收到disconnect 报文...

新建RocketMQ数据源

参数 描述 数据源类型 选择ROCKET_MQ。数据源名称 填写数据源名称。数据源名称由汉字、数字、字母、下划线(_)或短划线(-)组合组成。说明 数据源名称不能超过64个字符。数据源描述 填写对数据源简单的描述。数据源配置 配置数据源:如果...

MQTT客户端上下线事件数据流出

数据格式如下:MQ Tag:connect/disconnect/tcpclean 其中: connect事件代表客户端上线动作。disconnect事件代表客户端主动断开连接。按照MQTT协议,客户端主动断开TCP连接之前应该发送disconnect 报文,MQTT服务器在收到disconnect 报文...

AHAS为消息队列Apache RocketMQ版消费端削峰填谷

AHAS应用防护功能与消息队列RocketMQ组合,可以让MQ消费端负载保持在消息处理水位之下,同时尽可能处理更多消息,达到削峰填谷的效果。本文以AHAS应用防护的匀速处理请求的能力为例,说明如何对RocketMQ消费端进行限流。背景信息 在消息...

使用AMQProxy解决PHP等客户端Connection复用问题

amqps:/188XXX420.mq-amqp.cn-hangzhou-a.aliyuncs.com 返回示例如下:Proxy upstream: 188XXX420.mq-amqp.cn-hangzhou-a.aliyuncs.com:5671 TLS Proxy listening on 127.0.0.1:5673 0 clients 0 upstreams 参数 描述 clients 客户端和...

设备消息通过RocketMQ流转到服务器

本示例中,产品名称为MQ_test,所属品类为自定义品类,节点类型为直连设备,其他参数使用默认值。单击查看产品详情,在产品详情页面,单击Topic类列表> 自定义Topic,然后单击自定义Topic类,定义一个用于设备上报数据的Topic。本示例中,...

设备消息通过RocketMQ流转到服务器

本示例中,产品名称为MQ_test,所属品类为自定义品类,节点类型为直连设备,其他参数使用默认值。单击查看产品详情,在产品详情页面,单击Topic类列表> 自定义Topic,然后单击自定义Topic类,定义一个用于设备上报数据的Topic。本示例中,...

查询分析RocketMQ客户端日志

MQ_INST_*_BcrpdQUI%testes,从报错信息可以判断出现ERROR日志的原因是该实例(MQ_INST_*_BcrpdQUI)中topic(testes)的路由信息丢失,可能原因是topic配置错误、topic被误删等。报错的时间点为June 16th 2020,17:24:00.168。将单个报错...

MQ监控

MQ监控可展示消息队列RocketMQ版的Topic发布和订阅消息的情况。应用限制 EDAS标准版不支持MQ监控,专业版和铂金版支持MQ监控。功能入口 登录EDAS控制台。按需执行以下任一操作来进入应用的详情页面:在左侧导航栏选择资源管理>容器服务K8s...

消息队列RocketMQ版推送事件到函数计算

MQ".getBytes());设置代表消息的业务关键属性,请尽可能全局唯一。以方便您在无法正常收到消息情况下,可通过控制台查询消息并补发。注意:不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");异步发送消息,发送结果通过callback...

客户端无法通过TCP协议的内网接入点连接...Rocket MQ版实例

问题描述 使用消息队列Rocket MQ版时,客户端无法通过TCP协议的内网接入点连接到Broker。问题原因 客户端所在环境不同,对应的问题原因不同,详情如下: 客户端在阿里云环境中客户端在阿里云ECS实例、轻量应用服务器、函数计算等产品中时,...

MQ消息回执通知

本文以异步查询OSS数据为例,介绍如何在DLA中使用MQ做消息回执通知。前提条件开通OSS服务说明 在DLA中异步执行SQL时,必须开通OSS服务,存储SQL执行结果。创建目录OSS数据源创建MQ实例、创建Topic、创建Group。详情请参见MQ文档主账号快速...

消费者连接消息队列Rocket MQ版时提示Group ID不存在

问题描述 消费者(Consumer)连接消息队列Rocket MQ版时提示Group ID不存在。问题原因 使用的Group ID错误或者未创建该Group ID,导致连接Broker时,未通过服务器校验。解决方案 参考下列步骤进行排查:登录消息队列Rocket MQ版的控制台。...

消息队列Rocket MQ版客户端的状态出现异常

问题描述 使用消息队列Rocket MQ版时,客户端的状态出现异常。问题原因 客户端状态异常的部分原因如下: 创建消费者(Consumer)或生产者(Producer)之后,程序未调用start()方法启动客户端。创建Consumer或Producer之后,程序调用start()...

使用消息队列RocketMQ版实例时订阅关系不一致

ID,例如GID-MQ-FAQ,也订阅了相同的Topic,例如MQ-FAQ-TOPIC-1。但JVM1和JVM2中Consumer实例订阅的Tag不同。示例代码 JVM1中的示例代码 Properties properties=new Properties();properties.put(PropertyKeyConst.GROUP_ID,"GID-MQ-FAQ");...

消息队列RabbitMQ版

消息队列RabbitMQ版是阿里云消息队列(MQ)团队基于AMQP 0-9-1协议研发的分布式、高吞吐、低延迟、高可扩展的云消息队列服务。消息队列RabbitMQ版完全兼容开源RabbitMQ社区、开箱即用、无需部署、免运维,帮助您快速上云。

启动消息队列Rocket MQ版的客户端时提示Group ID重复

问题描述 启动消息队列Rocket MQ版的Producer(生产者)实例或Consumer(消费者)实例时,提示Group ID重复。问题原因 单个JVM进程中出现下列情况时,会导致客户端启动失败,提示Group ID重复:启动了一个以上的Producer实例,并且这些实例...

RocketMQ数据源

数据源添加 首先进入LTS操作页面,数据源管理->RocketMQ数据源 录入MQ的相关信息,点击创建,...获取NameSrvAddrNameSrvAddr表示MQ的接入点,对于自建客户,请自行查询MQ的配置。对于云上的客户可以在MQ控制台获取。获取 AccessId、AccessKey

GetMqSofamqConsumerStatus

Action=GetMqSofamqConsumerStatus&Cell=RZ01A&Detail=true&GroupId=GID_test_group_id&InstanceId=MQ_INST_111111111111_DOxxxxxx&NeedJstack=false&<公共请求参数> 正常返回示例 XML 格式<RequestId>861E6630-AEC0-4B2D-B214-6CB5E44B7F...

GetMqSofamqMessageById

{"RequestId":"861E6630-AEC0-4B2D-B214-6CB5E44B7F04","Data":{"BornTimestamp":"1570761026630","PropertyList":[{"Value":"TagA","Name":"TAGS"}],"InstanceId":"MQ_INST_111111111111_DOxxxxxx","StoreSize":"407","BornHost":"42.120....

sample-txc-mq 样例

本样例介绍如何把 MQ 事务消息的发送纳入 GTS 管理的全局事务。前提条件 在使用 sample-txc-mq 样例前,请先完成以下工作:开通 GTS(创建事务分组)。开通 MQ,详情请参见主账号快速入门。准备两个 RDS 实例,用户创建数据库。准备一个 ...

EnableMqSofamqWarn

MQ_INST_111111111111_DOxxxxxx 实例 ID WarnId Long 是 10001 待开启的报警规则 ID 返回数据 名称 类型 示例值 描述 RequestId String 861E6630-AEC0-4B2D-B214-6CB5E44B7F04 请求ID ResultCode String OK 结果码 ResultMessage String OK...

DeleteMqSofamqWarn

MQ_INST_111111111111_DOxxxxxx 实例 ID WarnId Long 是 10000001 待删除的报警规则 ID 返回数据 名称 类型 示例值 描述 RequestId String 861E6630-AEC0-4B2D-B214-6CB5E44B7F04 请求ID ResultCode String OK 结果码 ResultMessage String...

CreateMqSofamqWarn

InstanceId String 是 MQ_INST_111111111111_DOxxxxxx 实例 ID Threshold Long 是 1000 堆积阈值 Topic String 是 test 查询指定 Topic 时设置 返回数据 名称 类型 示例值 描述 RequestId String 861E6630-AEC0-4B2D-B214-6CB5E44B7F04 ...

UpdateMqSofamqWarn

String 是 MQ_INST_111111111111_DOxxxxxx 实例 ID Threshold Long 是 3000 阈值 WarnId Long 是 10000001 指定修改的报警规则 返回数据 名称 类型 示例值 描述 RequestId String 861E6630-AEC0-4B2D-B214-6CB5E44B7F04 请求ID ResultCode ...

ListMqSofamqWarn

InstanceId String 是 MQ_INST_111111111111_DOxxxxxx 实例 ID PageNum Long 是 1 页码 PageSize Long 是 20 每页显示条数 Topic String 是 test 查询指定 Topic 的报警规则时设置 返回数据 名称 类型 示例值 描述 Data Struct 查询到的告...

DeleteMqSofamqTrace

MQ_INST_111111111111_DOxxxxxx 实例 ID QueryId String 是 272967562652883649157096685*待删除的消息轨迹查询任务 ID 返回数据 名称 类型 示例值 描述 RequestId String 861E6630-AEC0-4B2D-B214-6CB5E44B7F04 请求ID ResultCode String ...

QueryMqSofamqMessageByKey

Action=QueryMqSofamqMessageByKey&Cell=RZ01A&InstanceId=MQ_INST_111111111111_DOxxxxxx&Key=messageKey1&Topic=test-mq_topic&<公共请求参数> 正常返回示例 XML 格式<RequestId>861E6630-AEC0-4B2D-B214-6CB5E44B7F04</RequestId><Data>...

DisableMqSofamqWarn

MQ_INST_111111111111_DOxxxxxx 实例 ID WarnId Long 是 10000001 待关闭的报警规则 ID 返回数据 名称 类型 示例值 描述 RequestId String 861E6630-AEC0-4B2D-B214-6CB5E44B7F04 请求ID ResultCode String OK 结果码 ResultMessage String...
< 1 2 3 4 ... 23 >
共有23页 跳转至: GO
产品推荐
消息队列MQ 全局事务服务 云服务器 商标 物联网无线连接服务 SSL证书 块存储
这些文档可能帮助您
Demo工程 什么是消息队列Kafka版? 什么是消息队列RocketMQ版? 功能与特性概述 订阅关系一致 什么是容器服务Kubernetes版

新品推荐

新人福利专场 阿里云试用中心 企业支持计划 飞天会员助力企业低成本上云 智能财税30天免费试用 云解析DNS新用户首购低至36元/年起 ECS限时升级特惠6.5折

你可能感兴趣

视频直播 大数据计算服务 MaxCompute 国内短信套餐包 ECS云服务器安全配置相关的云产品 开发者问答 阿里云建站 新零售智能客服 万网 小程序开发制作 视频内容分析 视频集锦 代理记账服务 阿里云AIoT 阿里云科技驱动中小企业数字化

热门推荐

切换为移动版

新人福利专场 阿里云试用中心 企业支持计划 飞天会员助力企业低成本上云 智能财税30天免费试用 云解析DNS新用户首购低至36元/年起 ECS限时升级特惠6.5折