sample-txc-mq 样例
本样例介绍如何把 MQ 事务消息的发送纳入 GTS 管理的全局事务。前提条件 在使用 sample-txc-mq 样例前，请先完成以下工作：开通 GTS（创建事务分组）。开通 MQ。...可以消费掉刚刚 sample-txc-mq 工程生产出来的 MQ 消息。
GetMqSofamqDLQMessageById
BornHost String 42.120.*.*:64646 生成该消息的客户端实例 BornTimestamp Long 1570761026630 生成时间戳 InstanceId String MQ_INST_111111111111_DOxxxxxx 实例 ID MsgId String 1E0578FE110F18B4AAC235C0C8460BA2 消息 ID，即 Message ...
MQ订阅消息
通过MQ订阅系统消息格式说明。消息定义 消息体 字段 类型 说明 EventCatgory String 事件分类，取值范围："DEVICE"：设备事件"BIZ":业务事件 Event String 事件说明："DEVICE_OFFLINE":设备下线"DEVICE_PROPERTY"：设备属性变更"BIZ_...
消息 Mesh
消息 Mesh 经过蚂蚁消息中间件团队大半年的打磨和沉淀，已经迈出了坚实的一大步：在开源社区迟迟未在消息 Mesh 上取得实质性进展时，蚂蚁团队已经为蚂蚁内部主流消息中间件打通了数据平面。同时，依赖消息的精细化流量调度，预期可以发掘出...
QueryMqSofamqDLQMessageByGroupId
Value String TagA 值 ReconsumeTimes Long 1 消息重试消费的次数 StoreHost String 11.220.*.*:10911 存储该消息的服务器实例 StoreSize Long 407 消息大小 StoreTimestamp Long 1570761026708 被服务端存储的时间戳 Topic String test-mq_...
概述
分布式事务可以与服务框架（SOFABoot、Spring Cloud、Dubbo 等）、数据源（数据访问代理、RDS、MySQL、OceanBase 等）、消息队列等蚂蚁集团中间件产品配合使用，轻松实现服务链路级事务、跨库事务、消息事务及各种组合。分布式事务主要涉及...
查询调用链路
选择 MQ：新增 消息类型、topic 这两个查询项。选择 NoSQL：新增 NoSQL 类型、调用方法 这两个查询项。自定义业务 Tag 输入自定义的业务 Tag。仅支持 JSON 格式。单击 查询。在查询结果列表中，查看链路的 Trace ID、调用时间、响应时长、...
概述
SOFAStack 消息队列（SOFAStack MQ，简称 SOFAMQ）是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成，为分布式应用系统提供异步解耦和削峰填谷的能力，支持事务消息、顺序消息、定时消息等多种消息...
MQ监控
MQ监控可展示消息队列RocketMQ版的Topic发布和订阅消息的情况。应用限制 EDAS标准版不支持MQ监控，专业版和铂金版支持MQ监控。功能入口 登录 EDAS控制台。在左侧导航栏，单击 应用管理>应用列表，在顶部菜单栏选择地域并在页面上方选择微...
MQ监控
ARMS应用监控的MQ监控可展示消息队列Apache RocketMQ版的Topic发布和订阅消息的情况。功能入口 登录 ARMS控制台，在左侧导航栏选择 应用监控>应用列表。在 应用列表 页面顶部选择目标地域，然后单击目标应用名称。说明 语言 列显示 图标的...
消息类型
普通消息 定时和延时消息 顺序消息 事务消息 普通消息 普通消息是指消息队列中无特性的消息，区别于有特性的定时/延时消息、顺序消息和事务消息。TCP Java SDK 收发普通消息的示例代码 发送普通消息（三种方式）发送消息（多线程）订阅消息...
操作链路概述
创建工作空间 要使用消息队列，您需要确保 SOFAStack 控制台已创建至少一个工作空间。如 SOFAStack 未创建工作空间或您需要创建一个新的工作空间，可参见 添加工作空间。创建好工作空间后，将为您自动创建一个消息队列实例。创建 Topic ...
查询消息轨迹
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...
TCC 模式接入注意事项
1:AT 2:MT 3:AT&MT-><constructor-arg value="3"/></bean>在 GTS 中使用 MQ 时，MTRelationShipManager 一定要先于 TxcTransactionScaner 进行声明 说明 非 XML 配置方式的应用，可以忽略该注意事项。先实例化MTRelationShipManager->...
版本说明
1.0.3.2 发布时间 发布内容 下载 2021-12-24 功能优化 去除Log4j依赖，改为使用SLF4J。mq-http-java-sdk-1.0.3.2.zip 1.0.3.1 发布时间 发布内容 下载 2021-12-13 功能优化 Log4j版本升级至2.15.0。mq-http-java-sdk-1.0.3.1.zip 1.0.3 ...
版本说明
支持使用Message ID查询消息轨迹。支持消息属性。mq-http-csharp-sdk-1.0.1.zip 1.0.0 发布时间 发布内容 下载 2019-01-23 新特性 首次发布。暂不支持高级特性消息，包括顺序消息、事务消息、定时和延时消息。已支持集群消费模式，暂不支持...
版本说明
1.0.3 发布时间 发布内容 下载 2021-01-05 新特性 支持顺序消息。mq-http-cpp-sdk-1.0.3.zip 1.0.1 发布时间 发布内容 下载 2019-06-10 新特性 支持高级特性消息，包括定时和延时消息、事务消息，暂不支持顺序消息。支持使用Message ID查询...
版本说明
1.0.3 发布时间 发布内容 下载 2021-01-05 新特性 支持顺序消息。mq-http-nodejs-sdk-1.0.3.zip 1.0.1 发布时间 发布内容 下载 2019-06-10 新特性 支持高级特性消息，包括定时和延时消息、事务消息，暂不支持顺序消息。支持使用Message ID...
解决方案与客户案例
如果使用了阿里云的中间件如CSB、MQ等，或者使用RPC可以连接到多活数据库，可以实现在服务层的流量路由和纠错。针对RPC服务，在多活场景中分为：单元化服务、中心化服务、普通服务三类：单元化服务：每个单元内完全自治的服务，是多活场景...
版本说明
支持使用Message ID查询消息轨迹。支持消息属性。mq-http-php-sdk-1.0.1.zip 1.0.0 发布时间 发布内容 下载 2019-01-23 新特性 首次发布。暂不支持高级特性消息，包括顺序消息、事务消息、定时和延时消息。已支持集群消费模式，暂不支持...
版本说明
支持使用Message ID查询消息轨迹。支持消息属性。mq-http-go-sdk-1.0.1.zip 1.0.0 发布时间 发布内容 下载 2019-06-10 新特性 首次发布。暂不支持高级特性消息，包括顺序消息、事务消息、定时和延时消息。已支持集群消费模式，暂不支持广播...
通知
消息服务MNS 不再提供Android SDK，如果您的客户端是Android操作系统，推荐您使用微消息队列MQTT。阿里云消息队列（MQ）推出 微消息队列MQTT，适用于移动互联网以及物联网应用，连接端（浏览器、Android、iOS、智能设备、互动直播、车联网...
通知
消息服务MNS 不再提供Objective-C iOS SDK，如果您的客户端是iOS操作系统，推荐您使用微消息队列MQTT。阿里云消息队列（MQ）推出 微消息队列MQTT，适用于移动互联网以及物联网应用，连接端（浏览器、Android、iOS、智能设备、互动直播、车...
消息队列
如果您希望区块链上的各种事件能自动发布到消息中间件，您可以将区块链事件和MQ做映射配置。当区块链服务监听到链上事件时，会自动生成MQ消息并发布到MQ的主题上，您可以订阅MQ中的这些事件消息做进一步处理。集成消息队列 RocketMQ 说明 ...
使用限制
在使用多活容灾MSHA时，您需要提前了解使用限制，例如支持的框架版本要求等，以免程序出现异常。如果您使用的框架版本不在下列支持范围内，请升级到支持的版本，或加入多活容灾MSHA钉钉群（群号：31623894）联系MSHA技术团队进行兼容性评估...
Advisor服务关联角色
{"Action":["drds:DescribeDrdsInstances"],"Resource":"*","Effect":"Allow"} mq的访问权限 {"Action":["mq:OnsInstanceInServiceList","mq:OnsRegionList","mq:OnsTopicList"],"Resource":"*","Effect":"Allow"} mse的访问权限 {"Action...
MetaQ数据源
DataWorks数据集成支持使用MetaQ Reader读取消息队列Message Queue（简称MQ）的数据，本文为您介绍DataWorks的MetaQ数据读取能力。支持的版本 MetaQ Reader通过消息队列服务的Java SDK订阅MetaQ中的实时消息数据，使用的Java SDK版本如下所...
旧版样例简介
sample-mq-consumer：该工程主要为上述案例中的 MQ 消息提供者（provider）提供一个消费者（consumer）案例，该工程不依赖 GTS，仅为方便用户理解 MQ 案例。sample-txc-edas：在 EDAS 上使用 GTS 的案例，该案例综合了 GTS、EDAS 及 MQ 的...
配置MQ
多活容灾MSHA的异地应用双活功能依赖阿里云消息队列RocketMQ版，在异地应用双活容灾场景下，完成消息层配置后，保障在单地域MQ组件故障场景中消息不丢失。本文介绍如何配置MQ。前提条件 两个地域已拥有MQ铂金版实例和MQ多活商品组。具体...
配置MQ
多活容灾MSHA的异地双活功能依赖阿里云消息队列RocketMQ版，在异地双活容灾场景下，完成消息层配置后，保障在单地域MQ组件故障场景中消息不丢失。本文介绍如何配置MQ。前提条件 两个地域的应用已接入最新版本的ONS-Client进行消息消费。更...
创建和管理 Topic
Topic 是 SOFAStack 消息队列里对消息的一级归类，消息生产者将消息发送到 Topic，而消息消费者则通过订阅该 Topic 来获取和消费消息。创建 Topic 登录 SOFAStack 控制台。在左侧导航栏，选择 中间件>消息队列>Topic 管理。单击 创建 Topic...
版本说明
1.0.3 发布时间 发布内容 下载 2021-01-05 新特性 支持顺序消息。mq-http-python-sdk-1.0.3.zip 1.0.1 发布时间 发布内容 下载 2019-06-10 新特性 支持高级特性消息，包括定时和延时消息、事务消息，暂不支持顺序消息。支持使用Message ID...
采集公网数据
方案1：前端服务器+Kafka 由于Kafka不提供RESTful协议，更多是在集群内使用，因此一般需要Nginx服务器做公网代理，再使用Logstash或API通过Nginx将公网数据写入到Kafka等消息中间件。需要的设施如下：设施 数目 配置 作用 价格 ECS服务器 2...
授权信息
操作（Action）下表是 消息队列 MQ（Ons）定义的操作，这些操作可以在RAM权限策略语句的 Action 元素中使用，用来授予执行该操作的权限。下面对表中的具体项提供说明：操作：是指具体的权限点。API：是指操作对应的API接口。访问级别：是指...
使用Canal将MySQL的数据同步至云消息队列 Kafka 版
本教程介绍如何使用Canal将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Canal的主要用途是基于MySQL数据库增量日志解析，提供增量数据订阅和消费。Canal伪装自己为MySQL Slave，向MySQL Master发送dump请求。MySQL Master收到dump...
集成概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 Connector生态集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据...
业务流量隔离功能实践
方案2：隔离环境和线上普通环境使用独立中间件 该方案需要具备无下游应用时兜底调用（RPC、MQ、调度任务等）到线上普通环境的能力，否则需要上下游应用全量部署，且需要运维保障第二套线上环境的稳定性。而要实现兜底调用，则需要具备...
使用异常
本节将介绍消息队列常见的使用异常问题及相应的解决方案。无法连接 Broker 客户端启动失败，出现“Can not find name server with endpoint”报错 启动 Producer、Consumer 失败，Group ID 重复 主动订阅消息，获取队列列表失败 消息显示 ...
ALIYUN:CMS:MonitorGroupInstances
mq_topic：消息服务的Topic。ocs：云数据库Memcache版。opensearch：开放搜索。oss：对象存储服务。polardb：云数据库PolarDB。petadata：HybridDB for MySQL。scdn：安全加速。sharebandwidthpackages：共享带宽包。sls：日志服务。vpn：...
RocketMQ
名称 类型 描述 示例值 object RocketMQ 消息通知参数。...如果需使用 RocketMQ 做消息通知，该参数必填。topic1 InstanceId string RocketMQ 实例 Id。如果需使用 RocketMQ 做消息通知，该参数必填。MQ_INST_11111111111_BYcNy2Nc
- 产品推荐
- 这些文档可能帮助您