消息过滤
应用场景 云消息队列 RocketMQ 版 作为发布订阅模型的消息中间件广泛应用于上下游业务集成场景。在实际业务场景中，同一个主题下的消息往往会被多个不同的下游业务方处理，各下游的处理逻辑不同，只关注自身逻辑需要的消息子集。使用 云...
领域模型概述
消息传输模型介绍 主流的消息中间件的传输模型主要为点对点模型和发布订阅模型。点对点模型 点对点模型也叫队列模型，具有如下特点：消费匿名：消息上下游沟通的唯一的身份就是队列，下游消费者从队列获取消息无法声明独立身份。一对一通信...
概述
分布式事务可以与服务框架（SOFABoot、Spring Cloud、Dubbo 等）、数据源（数据访问代理、RDS、MySQL、OceanBase 等）、消息队列等蚂蚁集团中间件产品配合使用，轻松实现服务链路级事务、跨库事务、消息事务及各种组合。分布式事务主要涉及...
步骤一：架构规划
使用的中间件 中间件 配置信息 备注 消息队列 TopicGroupID 创建 topic、groupid 和路由规则。数据访问代理 1 个实例，3 个库，每个库 10 库 10 表 创建实例，添加数据节点，创建数据库、数据表，并连接数据访问代理。分布式事务 无 无 微...
消息 Mesh
消息 Mesh 经过蚂蚁消息中间件团队大半年的打磨和沉淀，已经迈出了坚实的一大步：在开源社区迟迟未在消息 Mesh 上取得实质性进展时，蚂蚁团队已经为蚂蚁内部主流消息中间件打通了数据平面。同时，依赖消息的精细化流量调度，预期可以发掘出...
通知
消息服务MNS 不再提供Android SDK，如果您的客户端是Android操作系统，推荐您使用微消息队列MQTT。阿里云消息队列（MQ）推出 微消息队列MQTT，适用于移动互联网以及物联网应用，连接端（浏览器、Android、iOS、智能设备、互动直播、车联网...
通知
消息服务MNS 不再提供Objective-C iOS SDK，如果您的客户端是iOS操作系统，推荐您使用微消息队列MQTT。阿里云消息队列（MQ）推出 微消息队列MQTT，适用于移动互联网以及物联网应用，连接端（浏览器、Android、iOS、智能设备、互动直播、车...
概述
SOFAStack 消息队列（SOFAStack MQ，简称 SOFAMQ）是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成，为分布式应用系统提供异步解耦和削峰填谷的能力，支持事务消息、顺序消息、定时消息等多种消息...
QueryMqSofamqMessageByKey
Key String 是 messageKey1 需查询的消息的 Message Key Topic String 是 test-mq_topic 需查询的消息的 Topic 返回数据 名称 类型 示例值 描述 Data Array 查询结果 Body String SGVsbG8gTVEg5raT7oWf5p6D5ai05ayt55iv 消息体 BodyCrc ...
GetMqSofamqMessageById
10911 存储该消息的服务器实例 BornTimestamp Long 1570761026630 生成时间戳 InstanceId String MQ_INST_111111111111_DOxxxxxx 实例 ID Body String SGVsbG8gTVEg5raT7oWf5p6D5ai05ayt55iv 消息体 MsgId String 1E0578FE110F18B4AAC235C0...
授权信息
操作（Action）下表是 消息队列 MQ（RocketMQ）定义的操作，这些操作可以在RAM权限策略语句的 Action 元素中使用，用来授予执行该操作的权限。下面对表中的具体项提供说明：操作：是指具体的权限点。API：是指操作对应的API接口。访问级别...
MQ订阅消息
通过MQ订阅系统消息格式说明。消息定义 消息体 字段 类型 说明 EventCatgory String 事件分类，取值范围："DEVICE"：设备事件"BIZ":业务事件 Event String 事件说明："DEVICE_OFFLINE":设备下线"DEVICE_PROPERTY"：设备属性变更"BIZ_...
QueryMqSofamqMessageByTopic
Topic String 是 test-mq_topic 需查询的消息的 Topic 名称 返回数据 名称 类型 示例值 描述 Data Struct 分页查询Message Content Array 消息的详细信息 Body String SGVsbG8gTVEg5raT7oWf5p6D5ai05ayt55iv 消息体 BodyCrc Long 914112295...
背景信息
OLAP场景中，为避免复杂SQL运行时间过长，程序一直阻塞等待而影响业务运行...DLA支持将消息写入阿里云 消息队列（Message Queue，简称MQ）、消息服务（Message Service，简称MNS，原MQS）或者 钉钉机器人，帮助您快速、异步感知任务执行状态。
GetMqSofamqDLQMessageById
BornHost String 42.120.*.*:64646 生成该消息的客户端实例 BornTimestamp Long 1570761026630 生成时间戳 InstanceId String MQ_INST_111111111111_DOxxxxxx 实例 ID MsgId String 1E0578FE110F18B4AAC235C0C8460BA2 消息 ID，即 Message ...
QueryMqSofamqDLQMessageByGroupId
Value String TagA 值 ReconsumeTimes Long 1 消息重试消费的次数 StoreHost String 11.220.*.*:10911 存储该消息的服务器实例 StoreSize Long 407 消息大小 StoreTimestamp Long 1570761026708 被服务端存储的时间戳 Topic String test-mq_...
操作链路概述
创建工作空间 要使用消息队列，您需要确保 SOFAStack 控制台已创建至少一个工作空间。如 SOFAStack 未创建工作空间或您需要创建一个新的工作空间，可参见 添加工作空间。创建好工作空间后，将为您自动创建一个消息队列实例。创建 Topic ...
消息类型
本文介绍 SOFAStack 消息队列各个消息类型的概念、适用场景以及使用过程中的注意事项等。普通消息 定时和延时消息 顺序消息 事务消息 普通消息 普通消息是指消息队列中无特性的消息，区别于有特性的定时/延时消息、顺序消息和事务消息。TCP...
查询调用链路
选择 MQ：新增 消息类型、topic 这两个查询项。选择 NoSQL：新增 NoSQL 类型、调用方法 这两个查询项。自定义业务 Tag 输入自定义的业务 Tag。仅支持 JSON 格式。单击 查询。在查询结果列表中，查看链路的 Trace ID、调用时间、响应时长、...
解决方案与客户案例
如果使用了阿里云的中间件如CSB、MQ等，或者使用RPC可以连接到多活数据库，可以实现在服务层的流量路由和纠错。针对RPC服务，在多活场景中分为：单元化服务、中心化服务、普通服务三类：单元化服务：每个单元内完全自治的服务，是多活场景...
查询消息轨迹
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...
MQ监控
MQ监控可展示消息队列RocketMQ版的Topic发布和订阅消息的情况。应用限制 EDAS标准版不支持MQ监控，专业版和铂金版支持MQ监控。功能入口 登录 EDAS控制台。在左侧导航栏，单击 应用管理>应用列表，在顶部菜单栏选择地域并在页面上方选择微...
MQ监控
ARMS应用监控的MQ监控可展示消息队列Apache RocketMQ版的Topic发布和订阅消息的情况。功能入口 登录 ARMS控制台，在左侧导航栏选择 应用监控>应用列表。在 应用列表 页面顶部选择目标地域，然后单击目标应用名称。说明 语言 列显示 图标的...
MetaQ数据源
DataWorks数据集成支持使用MetaQ Reader读取消息队列Message Queue（简称MQ）的数据，本文为您介绍DataWorks的MetaQ数据读取能力。支持的版本 MetaQ Reader通过消息队列服务的Java SDK订阅MetaQ中的实时消息数据，使用的Java SDK版本如下所...
Advisor服务关联角色
{"Action":["drds:DescribeDrdsInstances"],"Resource":"*","Effect":"Allow"} mq的访问权限 {"Action":["mq:OnsInstanceInServiceList","mq:OnsRegionList","mq:OnsTopicList"],"Resource":"*","Effect":"Allow"} mse的访问权限 {"Action...
消息队列
如果您希望区块链上的各种事件能自动发布到消息中间件，您可以将区块链事件和MQ做映射配置。当区块链服务监听到链上事件时，会自动生成MQ消息并发布到MQ的主题上，您可以订阅MQ中的这些事件消息做进一步处理。集成消息队列 RocketMQ 说明 ...
数据出口至消息队列MQ
物联网络管理平台支持数据出口至阿里云中间件消息队列MQ，本文介绍如何在物联网络管理平台上配置数据流转至消息队列MQ。配置出口数据 登录 物联网络管理平台控制台。在左侧导航栏选择 节点管理>节点分组，单击一条节点分组对应 操作 栏下的...
三方标准中间件对接
中间件通讯方式 操作系统 中间件类型 中间件名称 访问节点方式 Linux 阿里云中间件 IotEdge 固定的服务名称 iotedge LinkVisual 固定的服务名称 linkvisual 三方中间件 RedisHA 使用服务名称 SQL Server 使用服务名称 Redis 使用服务名称 ...
中间件
name是指服务名称 三方中间件 Kafka 使用服务名称 ZooKeeper 使用服务名称 InfluxDB 使用服务名称 MongoDB 使用服务名称 MySQL 使用服务名称 PostgreSQL 使用服务名称 RabbitMQ 使用服务名称 SQL Server 使用服务名称 MySQL-HA 使用服务...
合作伙伴及开源生态
同时，SOFAStack 也积极参与了多个重要开源社区，如 SOFAStack 消息队列（SOFAStack MQ，简称 SOFAMQ）加入了 OpenMessaging 社区贡献能力。活动与社群 SOFALab 源码共建 SOFALab 为 SOFAStack 社区发起源码解析系列文章的共建活动，该系列...
TCC 模式接入注意事项
所以，使用 AT 模式的同时，又需要把 MQ 事务消息纳入全局事务管理时，就需要同时开启 AT 和 TCC 模式的配置。constructor-arg value="gtstest.123213123.HZ"/>!1:AT 2:MT 3...
创建和管理 Topic
在左侧导航栏，选择 中间件>消息队列>Topic 管理。单击 创建 Topic，然后在 创建 Topic 对话框配置 Topic 信息：Topic：Topic 名称。Topic 只能包含英文、数字、短横线（-）和下划线（_），其中英文和数字必须要有一种，短横线（-）和...
业务流量隔离功能实践
方案2：隔离环境和线上普通环境使用独立中间件 该方案需要具备无下游应用时兜底调用（RPC、MQ、调度任务等）到线上普通环境的能力，否则需要上下游应用全量部署，且需要运维保障第二套线上环境的稳定性。而要实现兜底调用，则需要具备...
采集公网数据
方案1：前端服务器+Kafka 由于Kafka不提供RESTful协议，更多是在集群内使用，因此一般需要Nginx服务器做公网代理，再使用Logstash或API通过Nginx将公网数据写入到Kafka等消息中间件。需要的设施如下：设施 数目 配置 作用 价格 ECS服务器 2...
使用异常
本节将介绍消息队列常见的使用异常问题及相应的解决方案。无法连接 Broker 客户端启动失败，出现“Can not find name server with endpoint”报错 启动 Producer、Consumer 失败，Group ID 重复 主动订阅消息，获取队列列表失败 消息显示 ...
微消息队列MQTT版推送事件到函数计算
MQ4IOT 消息的一级Topic，需要在控制台申请才能使用。如果使用了没有申请或者没有被授权的Topic会导致鉴权失败，服务端会断开客户端连接。final String parentTopic="XXXXX;MQ4IOT支持子级Topic，用来做自定义的过滤，此处为示意，可以填写...
专有云通用架构
集群规模大于50台物理机时可采用Apsara Stack Enterprise专有云，集群规模大于50台物理机，适合银行、证券等大型金融机构自建专有云，建议使用下图所示的架构，部署包括：虚拟化VM、数据库、存储、中间件、大数据等金融云产品。Apsara ...
配置MQ
多活容灾MSHA的异地双活功能依赖阿里云消息队列RocketMQ版，在异地双活容灾场景下，完成消息层配置后，保障在单地域MQ组件故障场景中消息不丢失。本文介绍如何配置MQ。前提条件 两个地域的应用已接入最新版本的ONS-Client进行消息消费。更...
配置MQ
多活容灾MSHA的异地应用双活功能依赖阿里云消息队列RocketMQ版，在异地应用双活容灾场景下，完成消息层配置后，保障在单地域MQ组件故障场景中消息不丢失。本文介绍如何配置MQ。前提条件 两个地域已拥有MQ铂金版实例和MQ多活商品组。具体...
调用HTTP协议的SDK收发普通消息
前提条件 创建资源 说明 本文以普通消息为例进行说明，因此您创建的普通消息的Topic不能用来收发其他类型的消息，包括定时、延时、顺序和事务消息。换言之，切勿混用不同消息类型的Topic。创建AccessKey 下载并安装HTTP协议的SDK 云消息...
- 产品推荐
- 这些文档可能帮助您