MQ配置

MQ配置,提供了一套通过阿里云RocketMQ产品订阅云价签产品消息的机制。配置准备使用MQ订阅云价签产品消息,用户首先需要开通RocketMQ产品并创建实例开通权限云价签需要获取用户发送MQ消息的权限,需在RAM控制台创建一个新角色,角色名为:...

配置MQ

多活容灾MSHA的异地双活功能依赖阿里云消息队列RocketMQ版,在异地双活容灾场景下,完成消息层配置后,保障在单地域MQ组件故障场景中消息不丢失。本文介绍如何配置MQ。前提条件 两个地域的应用已接入最新版本的ONS-Client进行消息消费。更...

配置MQ

多活容灾MSHA的异地应用双活功能依赖阿里云消息队列RocketMQ版,在异地应用双活容灾场景下,完成消息层配置后,保障在单地域MQ组件故障场景中消息不丢失。本文介绍如何配置MQ。前提条件 两个地域已拥有MQ铂金版实例和MQ多活商品组。具体...

MQ监控

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

MQ监控

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

MQ推送

MQ推送用于监控物联网卡的状态变化以及流量使用情况,并可以直接将消息推送到用户自己的系统中,帮助用户实时接收物联网卡的状态变化、套餐用量等信息。使用说明MQ推送与自动化规则都是用于监控物联网卡的状态变化以及流量使用情况,主要...

MQ订阅消息

通过MQ订阅系统消息格式说明。消息定义消息体字段类型说明EventCatgoryString事件分类,取值范围:"DEVICE":设备事件"BIZ": 业务事件EventString事件说明:"DEVICE_OFFLINE": 设备下线"DEVICE_PROPERTY":设备属性变更"BIZ_REFRESH_DELAY...

MQ消息回执通知

本文以异步查询OSS数据为例,介绍如何在DLA中使用MQ做消息回执通知。前提条件 开通OSS服务 说明 在DLA中异步执行SQL时,必须开通OSS服务,存储SQL执行结果。创建目录 OSS数据源 创建MQ实例、Topic、Group 操作步骤 新建RAM角色。使用DLA...

消费托管MQ接口

消费托管MQ接口主要用于获取托管MQ中的消息以及消息成功后进行确认的功能。获取消息获取托管MQ中的消息,方法名称:consumeMQMessage。函数原型ConsumeMQMessageResponse consumeMQMessage(final ConsumeMQMessageRequest request) 请求...

sample-txc-mq 样例

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

数据出口至消息队列MQ

物联网络管理平台支持数据出口至阿里云中间件消息队列MQ,本文介绍如何在物联网络管理平台上配置数据流转至消息队列MQ。配置出口数据 登录物联网络管理平台控制台。在左侧导航栏选择节点管理>节点分组,单击一条节点分组对应操作栏下的数据...

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

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

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

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

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

问题原因 单个JVM进程中出现下列情况时,会导致客户端启动失败,提示Group ID重复: 启动了一个以上的Producer实例,并且这些实例使用相同的Group ID。启动了一个以上的Consumer实例,并且这些实例使用相同的Group ID。...

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

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

GetMqSofamqMessageById

MQ_INST_111111111111_DOxxxxxx 407 42.120.*.*:64646 914112295 test-mq_topic SGVsbG8gTVEg5raT7oWf5p6D5ai05ayt55iv 1 1E0578FE110F18B4AAC235C0C8460BA2 11.220.*.*:10911 1570761026708 OK OK JSON格式 HTTP/1.1 200 OK Content-Type...

GetMqSofamqConsumerStatus

test-mq_topic CLUSTERING 0 1566883844954 MQ_INST_111111111111_DOxxxxxx true true 197 100857 true 30.5.121.*JAVA 42.120.74.*V4_3_6_SNAPSHOT 30.5.121.*@25560#-1999745829#-1737591554#458773089270275 CLUSTERING 20 PUSH JAVA ...

ListMqSofamqWarn

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

消息队列RabbitMQ版

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

RocketMQ数据源

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

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 时设置 返回数据 名称 类型 示例值 描述 ResultMessage String OK 结果描述 ResultCode String OK ...

QueryMqSofamqMessageByKey

{"RequestId":"861E6630-AEC0-4B2D-B214-6CB5E44B7F04","Data":[{"BornTimestamp":"1570761026630","InstanceId":"MQ_INST_111111111111_DOxxxxxx","StoreSize":"407","BornHost":"42.120.*.*:64646","BodyCrc":"914112295","Topic":"test-...

UpdateMqSofamqWarn

InstanceId String 是 MQ_INST_111111111111_DOxxxxxx 实例 ID Threshold Long 是 3000 阈值 WarnId Long 是 10000001 指定修改的报警规则 返回数据 名称 类型 示例值 描述 ResultMessage String OK 结果描述 ResultCode String OK 结果码 ...

GetMqSofamqDLQMessageById

MQ_INST_111111111111_DOxxxxxx 407 42.120.*.*:64646 914112295 test-mq_topic SGVsbG8gTVEg5raT7oWf5p6D5ai05ayt55iv 1 1E0578FE110F18B4AAC235C0C8460BA2 11.220.*.*:10911 1570761026708 OK OK JSON 格式 {"RequestId":"861E6630-AEC0-...

DeleteMqSofamqTrace

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

DisableMqSofamqWarn

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

QueryMqSofamqConsumerTimespan

{"RequestId":"861E6630-AEC0-4B2D-B214-6CB5E44B7F04","Data":{"MinTimestamp":"1570701231122","ConsumeTimestamp":"1570761026400","InstanceId":"MQ_INST_111111111111_DOxxxxxx","MaxTimestamp":"1570761026804","Topic":"test-mq_...

RocketMQ触发器

INSTANCE_ID":"MQ_INST_164901546557*_BXhFHryi"},"userProperties":{ }, body":"TEST"} } 事件流模型的event格式如下所示。[{ id":"94ebc15f-f0db-4bbe-acce-56fb72fb*", source":"RocketMQ-Function-rocketmq-trigger","specversion...

QueryMqSofamqMessageByTopic

InstanceId String 是 MQ_INST_111111111111_DOxxxxxx 需查询的消息所对应的实例 ID。针对有独立命名空间的实例,该参数为必填。PageNum Long 是 1 页码 PageSize Long 是 20 每页显示条数 TaskId String 是 0BC1310300002A9F000021E4D7A...

GetMqSofamqTraceResult

格式{"RequestId":"861E6630-AEC0-4B2D-B214-6CB5E44B7F04","Data":{"Status":"finish","InstanceId":"MQ_INST_111111111111_DOxxxxxx","UserId":"27296756265288*","CreateTime":"1570966857000","MsgKey":"keyA","QueryId":...

GetMqSofamqTraceByMsgId

InstanceId String 是 MQ_INST_111111111111_DOxxxxxx 需查询的消息的 Topic 所对应的实例 ID。针对有独立命名空间的实例,该参数为必填。MsgId String 是 1E05791C117818B4AAC23B1BB0CE*需查询的消息的 ID,即 Message ID Topic String 是...

ResetMqSofamqConsumerOffset

MQ_INST_111111111111_DOxxxxxx 需查询的 Group ID 所对应的实例 ID。针对有独立命名空间的实例,该参数为必填。ResetTimestamp Long 否 1568033253000 重置位点到指定的时间戳,仅在 Type 为 1 时生效。单位:毫秒。Topic String 是 test-...

QueryMqSofamqDLQMessageByGroupId

MQ_INST_111111111111_DOxxxxxx 需查询的消息所对应的实例 ID。针对有独立命名空间的实例,该参数为必填。PageNum Long 是 1 页码 PageSize Long 是 10 每页条数 TaskId String 是 0BC1310300002A9F000021E4D7A48346 查询任务的 ID。首次...

使用Canal和RocketMQ实现数据库变更订阅处理

批量传输设置 批量处理功能是在一定延迟范围内提升整体的吞吐量,相关参数如下:参数 说明 默认值 canal.mq.canalBatchSize 从Canal获取数据的批次大小。单位:KB。50 canal.mq.canalGetTimeout 从Canal获取数据的超时时间。单位:毫秒。...

QueryMqSofamqTraceByTopic

String 是 MQ_INST_111111111111_DOxxxxxx 实例 ID Topic String 是 TP_xxx 需查询的消息的 Topic 返回数据 名称 类型 示例值 描述 QueryId String 272967562652883649157096685* 该消息轨迹查询任务的 ID RequestId String 861E6630-AEC0-...

UpdateMqSofamqTopicRemark

String 是 MQ_INST_111111111111_DOxxxxxx 实例 ID Remark String 是 test Topic 描述信息 Topic String 是 test 需更新的 Topic 名称,一个用户下不可重复。返回数据 名称 类型 示例值 描述 RequestId String 861E6630-AEC0-4B2D-B214-6CB...

UpdateMqSofamqGroupRemark

test_group_id 需配置更新的 Group ID InstanceId String 是 MQ_INST_111111111111_DOxxxxxx 实例 ID Remark String 是 test 描述信息 返回数据 名称 类型 示例值 描述 RequestId String 861E6630-AEC0-4B2D-B214-6CB5E44B7F04 请求ID ...

QueryMqSofamqGroupSubDetail

订阅匹配字符串 Online Boolean true 是否在线 Topic String test-mq_topic Topic 名称 示例 请求示例 http(s):/[Endpoint]/?Action=QueryMqSofamqGroupSubDetail GroupId=GID_test_group_id&InstanceId=SOFAMQ_INSTANCE_000001&<公共请求...
共有26条 < 1 2 3 4 ... 26 >
跳转至: GO
新人特惠 爆款特惠 最新活动 免费试用