配置MQ
多活容灾MSHA的异地应用双活功能依赖阿里云消息队列RocketMQ版，在异地应用双活容灾场景下，完成消息层配置后，保障在单地域MQ组件故障场景中消息不丢失。本文介绍如何配置MQ。前提条件 两个地域已拥有MQ铂金版实例和MQ多活商品组。具体...
sample-txc-mq 样例
本样例介绍如何把 MQ 事务消息的发送纳入 GTS 管理的全局事务。前提条件 在使用 sample-txc-mq 样例前，请先完成以下工作：开通 GTS（创建事务分组）。开通 MQ。具体操作，请参见 快速入门概述。准备两个 RDS 实例，用户创建数据库。准备...
配置MQ
多活容灾MSHA的异地双活功能依赖阿里云消息队列RocketMQ版，在异地双活容灾场景下，完成消息层配置后，保障在单地域MQ组件故障场景中消息不丢失。本文介绍如何配置MQ。前提条件 两个地域的应用已接入最新版本的ONS-Client进行消息消费。更...
消费托管MQ接口
消费托管MQ接口主要用于获取托管MQ中的消息以及消息成功后进行确认的功能。获取消息 获取托管MQ中的消息，方法名称：consumeMQMessage。函数原型 ConsumeMQMessageResponse consumeMQMessage(final ConsumeMQMessageRequest request)请求...
MQ监控
ARMS应用监控的MQ监控可展示消息队列Apache RocketMQ版的Topic发布和订阅消息的情况。功能入口 登录 ARMS控制台，在左侧导航栏选择 应用监控>应用列表。在 应用列表 页面顶部选择目标地域，然后单击目标应用名称。说明 语言 列显示 图标的...
MQ 事务消息纳入全局事务管理样例
本样例介绍如何把 MQ 事务消息的发送纳入 GTS 管理的全局事务。前提条件 在把 MQ 事务消息的发送纳入 GTS 管理的全局事务，请先完成以下工作：准备一个可用的 MySQL 环境（可以是阿里云的 RDS）。准备一个可用的 Maven 环境。样例说明 样例...
SDK 使用说明
消费托管MQ的使用说明 在Java项目中使用BaaS REST进行消费托管MQ之前，请参见本文上方的 SDK 通用说明 获取REST身份、下载 REST SDK、添加依赖及修改配置项。说明 在修改配置项时，无需进行链账户相关的额外配置。SDK 版本需升级至2.15.3及...
sample-txc-edas 样例
使用 txc-client-mq 子工程的 console 方式验证综合了 MQ 业务的服务部署结果。将 sample-txc-edas 整个工程拷贝到 ECS 服务器上，按步骤（4）修改参数配置，然后在 sample-txc-edas 目录下执行 build.sh 完成工程编译。设置运行时环境变量...
收发事务消息
instance_id="${INSTANCE_ID}"consumer=mq_client.get_consumer(instance_id,topic_name,group_id)#长轮询表示如果Topic没有消息，则客户端请求会在服务端挂起3秒，3秒内如果有消息可以消费则立即返回响应。长轮询时间3秒（最多可设置为30...
收发事务消息
长轮询表示如果Topic没有消息,则请求会在服务端挂起3s，3s内如果有消息可以消费则立即返回客户端。messages=consumer.consumeMessage(3,/一次最多消费3条消息（最多可设置为16条）。3/长轮询时间3秒（最多可设置为30秒）。} catch...
查询分析RocketMQ客户端日志
具体的报错信息是 No route info of this topic,MQ_INST_*_BcrpdQUI%testes，从报错信息可以判断出现ERROR日志的原因是该实例（MQ_INST_*_BcrpdQUI）中topic（testes）的路由信息丢失，可能原因是topic配置错误、topic被误删等。...
触发器Event格式
c2691505-38da-4d1b-998a-f1d4bb8c*cursorTime 最后一条日志到达日志服务端的Unix时间戳，单位：秒。1529486425 CDN触发器 event是 函数计算 的入口参数，具体格式如下。其中，对于不同的CDN事件类型，eventParameter 中包含的键值对不同。...
背景信息
OLAP场景中，为避免复杂SQL运行时间过长，程序一直阻塞等待而影响业务运行...DLA支持将消息写入阿里云 消息队列（Message Queue，简称MQ）、消息服务（Message Service，简称MNS，原MQS）或者 钉钉机器人，帮助您快速、异步感知任务执行状态。
业务流量隔离功能实践
具体需求内容包括：采用跟生产环境不同的中间件（微服务注册中心、MQ实例等），搭建一套常态化运行的安全生产环境，并建立统一的灰度发布流程，经过安全生产环境的灰度发布和观测验证后，才允许发布到生产环境。固定从生产环境引流1%的HTTP...
部署开源的RabbitMQ
RabbitMQ登录密码 rabbitmq_gui_port：RabbitMQ Web服务器端口 rabbitmq_mq_port：RabbitMQ远程连接端口 rabbitmq_er_port：RabbitMQ服务器用于Erlang进程间通信的内部端口 rabbitmq_mqtt_port：RabbitMQ服务器对外提供MQTT协议服务的监听...
全局事务服务（文档停止维护）
全局事务服务（Global ...GTS 支持 DRDS、RDS、MySQL 等多种数据源，可以配合 EDAS 和 Dubbo 等微服务框架使用，兼容 MQ 实现事务消息。通过各种组合，可以轻松实现分布式数据库事务、多库事务、消息事务、服务链路级事务等多种业务需求。
什么是全局事务服务GTS
可以与RDS、MySQL、PostgreSQL等数据源，Spring Cloud、Dubbo、HSF及其他RPC框架，MQ消息队列等中间件产品配合使用，轻松实现分布式数据库事务、多库事务、消息事务、服务链路级事务及各种组合。为什么需要全局事务服务 一个完整的业务往往...
异地多活的审计事件
异地多活已与操作审计服务集成，您可以在操作审计中查询用户操作异地多活产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中，满足实时审计、问题回溯分析等需求。操作审计记录了用户通过Open...
通过RocketMQ客户端消费设备消息
在物联网应用场景中，如果需要将设备上报至物联网平台的数据转发至您业务服务器的应用中进行消费（例如过滤、分析、存储等），可以使用物联网平台提供的云产品流转服务，例如通过云消息队列RocketMQ版（以下简称RocketMQ）实现设备数据流转...
通过RocketMQ客户端消费设备消息
在物联网应用场景中，如果需要将设备上报至物联网平台的数据转发至您业务服务器的应用中进行消费（例如过滤、分析、存储等），可以使用物联网平台提供的云产品流转服务，例如通过云消息队列RocketMQ版（以下简称RocketMQ）实现设备数据流转...
返回结果
587 MQ_FAILED 中间件出错。请通过 在线服务 联系我们。588 EXCEED_QUOTA 请求频率超出配额。默认配额：图片检测50张/秒，视频检测20路/秒，语音检测20路/秒，文本检测100条/秒，图片OCR 10张/秒。如果需要调整配额，请通过 在线服务 联系...
订阅数据示例
服务IP/*MQ4IOT clientId，由业务系统分配，需要保证每个 tcp 连接都不一样，保证全局唯一，如果不同的客户端对象（tcp 连接）使用了相同的 clientId 会导致连接异常断开。clientId 由两部分组成，格式为 GroupID@DeviceId，其中 groupId ...
金融云产品列表
MQ 部署 部署 部署 部署 消息服务 MNS 部署 部署 部署 无 数据传输 部署 部署 部署 部署 资源编排ROS 部署 部署 部署 部署 弹性伸缩 部署 部署 部署 部署 日志服务 SLS 部署 部署 部署 部署 API网关 部署 部署 部署 无 云数据库 OceanBase ...
使用场景
其中，相应的客户端和服务端，如 RPC，MQ，DB 都植入了路由路径。当容灾演练或者真实灾难发生时，管理员只需要动态地推送规则，相应的规则会影响到所有架构组件。示意图如下。ACM 为异地多活场景中的应用带来以下好处：基础架构和容灾逻辑...
支持STS的云服务
RAM代码 控制台 API 企业级分布式应用服务-edas√消息队列MQ 消息队列Rocket MQ版 mq√消息队列MQ 微消息队列MQTT版 mq√消息队列MQ 消息队列RabbitMQ版 amqp√云服务总线CSB-csb√性能测试-pts√消息服务-mns√应用配置管理-acms√消息...
物联网无线连接服务的审计事件
物联网无线连接服务已与操作审计服务集成，您可以在操作审计中查询用户操作物联网无线连接服务产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中，满足实时审计、问题回溯分析等需求。操作审计...
消息队列MQ的审计事件
消息队列MQ（AMQP）已与操作审计服务集成，您可以在操作审计中查询用户操作消息队列MQ产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中，满足实时审计、问题回溯分析等需求。操作审计记录了...
事务模式简介
适用的场景包括跨数据库事务、MQ 的消息事务、EDAS 的服务事务及多场景混合型事务方案。AT 模式下，DRDS 中接入分布式事务 与 DRDS版本集成使用时无需@TxcTransaction 注解，且无需引入 GTS 的 SDK，仅需要在用户的 SQL 语句中使用 select ...
AT 模式接入
AT 模式接入适用的场景包括跨数据库事务、MQ 的消息事务、EDAS 的服务事务及多场景混合型事务方案。本文介绍如何基于@TxcTransaction 注解使用 GTS 服务。前提条件 在使用 AT 模式接入 GTS 前，请先完成以下工作：开通 GTS（创建事务分组）...
Spring集成
P6z2pkIKAZ*n61JZ5e1lofFG9 nameSrvAddr 云消息队列 RocketMQ 版 实例的TCP协议接入点，用户访问 云消息队列 RocketMQ 版 服务端。http://MQ_INST_XXXXXX.cn-hangzhou.mq.aliyuncs.com:80 topic您在控制台创建的Topic，用于发送消息。noamal...
产品功能发布记录
当区块链服务监听到链上事件时，会自动生成MQ消息并发布到MQ的主题上，您可以订阅MQ中的这些事件消息做进一步处理。2020.02.27 相关文档 Hyperledger Fabric【云服务集成】数据库 如果您希望区块链上的数据能导出到关系型数据库，您可以将...
OnsInstanceBaseInfo-查询实例基本信息和收发消息的接...
取值说明如下：0：铂金版实例部署中 2：标准版实例已欠费 5：标准版实例或铂金版实例服务中 7：铂金版实例升级中且服务可用 5 InstanceId string 实例 ID。MQ_INST_138015630679*_BAAy1Hac InstanceType integer 实例类型。取值说明如下：1...
支持配额中心的云产品
expressconnect 云企业网 cbn 负载均衡 slb 共享带宽 cbwp 网络智能服务 netana 运维管理 云监控 cms 配额中心 quotas 运维编排 oos 应用服务 API网关 apigateway 资源管理 entconsole 微服务引擎 mse 互联网中间件 云消息队列MQ ons 移动...
MQ消息回执通知
前提条件 开通OSS服务 说明 在DLA中异步执行SQL时，必须开通OSS服务，存储SQL执行结果。创建目录 OSS数据源 创建MQ实例、Topic、Group 操作步骤 新建RAM角色。使用DLA所属账号登录 RAM控制台。单击 身份管理>角色。单击 创建角色，并进行...
什么是智能洞察？
目前服务支持按照HTTP、Dubbo、HSF和MQ进行分类查询，并给出具体根因结果。应用服务整体错误率突增 基于服务历史3小时数据，判断最近5分钟应用错误率是否有异常突增点。目前服务支持按照HTTP、Dubbo、HSF和MQ进行分类查询，并给出具体根因...
配置网卡多队列的网络中断亲和性
由于irqbalance服务会动态调整IRQ Affinity，配置 ecs_mq 脚本会和irqblanace产生冲突，建议关闭irqbalance服务。systemctl stop irqbalance.service 执行以下命令，下载最新版本的网卡多队列的自动配置脚本 ecs_mq。wget ...
QueryMqSofamqMessageByKey
Name String TAGS Key 名 Value String TagA 值 ReconsumeTimes Long 1 消息重试消费的次数 StoreHost String 11.220.*.*:10911 存储该消息的服务器实例 StoreSize Long 407 消息大小 StoreTimestamp Long 1570761026708 被服务端存储的...
GetMqSofamqMessageById
B214-6CB5E44B7F04 请求ID Data Object 查询结果 StoreSize Long 407 消息大小，单位：KB ReconsumeTimes Long 1 消息重试消费的次数 StoreTimestamp Long 1570761026708 被服务端存储的时间戳 Topic String test-mq_topic 消息的 Topic ...
- 产品推荐
- 这些文档可能帮助您