消息过滤
消息服务MNS 的消息过滤功能是指将一个主题的消息通过不同的标签推送到不同的订阅渠道。本文介绍消息过滤的功能以及如何设置消息过滤标签。背景信息 通常情况下，在主题中创建订阅可以将消息推送至已订阅的推送目标。即消息没有设置消息...
设备报警事件
IoT云端订阅设备alarmEvent事件和上下线的MQ消息，将其转换为DOP数据模型，由上层应用订阅获取设备消息。模型ID：DeviceAlarmEventBasic 模型版本：1.0 属性名称 属性标识符 数据类型 数据描述 租户id tenantId String 租户id 事件时间 ...
MQ配置
开通权限 云价签需要获取用户发送MQ消息的权限，需在 RAM控制台 创建一个新角色，角色名为：CloudEslNotificationRole，并在选择信任的阿里云账号一栏，填入授权的目标账号ID。具体的账号ID请向对口技术同学二次确认。创建成功后，在RAM...
什么是全局事务服务GTS
可以与RDS、MySQL、PostgreSQL等数据源，Spring Cloud、Dubbo、HSF及其他RPC框架，MQ消息队列等中间件产品配合使用，轻松实现分布式数据库事务、多库事务、消息事务、服务链路级事务及各种组合。为什么需要全局事务服务 一个完整的业务往往...
主题模型基本概念
消息过滤标签（FilterTag）订阅中消息过滤的标签，标签一致的消息才会被推送。推送地址（Endpoint）消息接收端，订阅者用于接收主题消息的地址。TopicURL 消息服务MNS 的主题访问域名地址，格式如下：http://$AccountId.mns.$Region....
产品概述
平台组件：是指产品对平台提供的服务目录的依赖项，例如：一个办公软件，依赖MQ消息中间件，如果用户希望由ADP平台提供该中间件，则他应该在产品依赖中，声明对该MQ组件的依赖。用户组件：是指用户自身代码构建的业务应用，打包上传至ADP...
Topic与Tag最佳实践
您可通过本文了解如何搭配使用Topic和Tag来实现消息过滤。背景信息 Topic和Tag的定义如下：Topic 消息主题，通过Topic对不同的业务消息进行分类。Tag 消息标签，用来进一步区分某个Topic下的消息分类，消息从生产者发出即带上的属性。Topic...
消息过滤
消息过滤原理 消息过滤主要通过以下几个关键流程实现：生产者：生产者在初始化消息时预先为消息设置一些属性和标签，用于后续消费时指定过滤目标。消费者：消费者在初始化及后续消费流程中通过调用订阅关系注册接口，向服务端上报需要订阅...
使用限制
消息服务MNS 对某些具体指标进行了...单个主题访问QPS 500 无 消息过滤标签 1个 用于消息过滤，不超过16个字符。说明 上表中限制项“单个队列QPS”和“单个主题访问QPS”均表示API接口调用的QPS，如有特殊需求可 提交工单 提高此QPS上限值。
订阅关系（Subscription）
通过配置订阅关系，可控制如下传输行为：消息过滤规则：用于控制消费者在消费消息时，选择主题内的哪些消息进行消费，设置消费过滤规则可以高效地过滤消费者需要的消息集合，灵活根据不同的业务场景设置不同的消息接收范围。具体信息，请...
消费托管MQ接口
确认消息 消费托管MQ消息成功后，进行确认，方法名称：ackMQMessage。函数原型 AckMQMessageResponse ackMQMessage(final AckMQMessageRequest request)请求参数 参数 必选 说明 streamId 是 队列ID，即数据导出服务中的任务ID。...
服务关联角色
应用场景 物联网无线连接服务的MQ消息推送功能，需要访问消息队列RocketMQ版云服务的资源，通过服务关联角色功能获取访问权限。关联角色介绍 角色名称：AliyunServiceRoleForLinkcard 权限说明：{"Version":"1","Statement":[{"Effect":...
消息服务MNS的订阅成功后收不到消息
该参数描述了订阅中消息过滤的标签，标签一致的消息才会被推送。解决方案 请参考如下步骤进行排查。检查消息服务MNS的日志，确认查找不到相关记录。关于如何查看消息服务MNS的日志，请参见 日志管理。检查订阅时是否设置了 FilterTag 参数...
MSHA产品和开源产品对比
✅ 消息层MQ 路由 发布打标（路由ID）✅ ❌ 消息层MQ 路由 消费过滤（依据路由ID计算消费单元）✅ ❌ 消息层MQ Failover 切流时重置位点，消息不丢 ✅ ❌ 数据层MySQL 路由 数据保护，防止多点写脏数据 ✅ ✅ 数据层MySQL Failover 路由ID...
API 概览
本节给出BaaS REST的所需的SDK列表，具体接口信息请参阅相关文档。...针对两种模式，有对应的配套的API，分别介绍如下。...消费托管MQ接口 接口 描述 consumeMQMessage 获取托管MQ中的消息 ackMQMessage 消费托管MQ消息成功后，进行确认
Subscribe
FilterTag String 否 important 该订阅中消息过滤的标签（标签一致的消息才会被推送）。取值范围：不超过16个字符的字符串。默认不进行消息过滤。NotifyStrategy Boolean 否 BACKOFF_RETRY 向Endpoint推送消息出现错误时的重试策略。取值...
基础术语
消息过滤 Message filtering Consumer 可以根据消息标签（Tag）对消息进行过滤，确保 Consumer 最终只接收被过滤后的消息类型。消息过滤在消息队列的服务端完成。详情请参见 消息过滤。消息轨迹 Message trace 在一条消息从 Producer 发出...
全球消息路由
全球消息路由功能可用于跨地域间的消息同步，通过路由规则将消息从源实例的Topic中同步到目标实例的Topic，并支持过滤规则，按照指定的Tag将消息过滤后再进行同步。在容灾备份或异地多活场景下，您可以创建全球消息路由任务，确保跨地域间...
云消息队列 Kafka 版
topic Tag（可选）配置源实例中用于过滤消息的Tag。test Group ID 选择源实例中的消费组名称。请使用独立的消费组来创建事件源，不要和已有的业务混用消费组，以免影响已有的消息收发。GID_http_1 并发配额（消费者数）选择源实例的消费者...
推送到HTTP
可选：消息过滤标签：输入标签用于过滤消息。重试策略：选择重试策略。消息推送格式：选择消息推送格式。步骤三：发布消息 登录 消息服务MNS控制台。在左侧导航栏，单击 主题列表。在顶部菜单栏，选择地域。在 主题列表 页面，找到目标主题...
基本概念
消息过滤 消费者可以通过订阅指定消息标签（Tag）对消息进行过滤，确保最终只接收被过滤后的消息合集。过滤规则的计算和匹配在 云消息队列 RocketMQ 版 的服务端完成。更多信息，请参见 消息过滤。重置消费位点 以时间轴为坐标，在消息持久...
主题模型快速入门
可选：消息过滤标签：通过设置的标签对消息进行过滤。重试策略：向接收端推送消息出现错误时的重试策略。重试策略支持选择以下任一类型：退避重试 指数衰减重试 消息推送格式：设置推送消息到接收端的消息格式。消息推送格式可以选择以下任...
旧版样例简介
sample-mq-consumer：该工程主要为上述案例中的 MQ 消息提供者（provider）提供一个消费者（consumer）案例，该工程不依赖 GTS，仅为方便用户理解 MQ 案例。sample-txc-edas：在 EDAS 上使用 GTS 的案例，该案例综合了 GTS、EDAS 及 MQ 的...
实例规格
SQL属性过滤，请参见 消息过滤。不支持 数据传输加密 支持SSL/TLS数据传输加密，但需要配合SDK版本为Java ons-client-2.x.x的客户端使用。SDK参考，请参见 Java SDK版本说明。支持SSL/TLS数据加密。您需要 提交工单 申请，并配合SDK版本为...
Subscribe
FilterTag 否 描述了该订阅中消息过滤的标签（标签一致的消息才会被推送）。不超过16个字符的字符串，默认不进行消息过滤。NotifyStrategy 否 描述了向Endpoint推送消息出现错误时的重试策略。BACKOFF_RETRY或者 EXPONENTIAL_DECAY_RETRY，...
推送到移动设备
可选：消息过滤标签：输入标签用于过滤消息。重试策略：选择重试策略。消息推送格式：选择消息推送格式。步骤三：发布消息 登录 消息服务MNS控制台。在左侧导航栏，单击 主题列表。在顶部菜单栏，选择地域。在 主题列表 页面，找到目标主题...
什么是消息服务MNS
在创建订阅时指定消息过滤标签，然后PublishMessage时指定消息标签，消息服务MNS 在推送消息时会根据标签进行过滤，仅推送消息标签与订阅中指定的过滤标签匹配的消息到指定队列上。更多信息，请参见 主题接口规范。消息投递 消息服务MNS ...
ALIYUN:MNS:Subscription
FilterTag String 否 否 此次订阅中消息过滤的标签。不超过16个字符，默认不进行消息过滤。说明 标签一致的消息才会被推送。NotifyStrategy String 否 是 向Endpoint推送消息出现错误时的重试策略。取值：BACKOFF_RETRY（默认值）...
基本概念
当前时间－最早一条未提交消息的就绪时间 消息过滤 Consumer可以根据消息标签（Tag）对消息进行过滤，确保Consumer最终只接收被过滤后的消息类型。消息过滤在 云消息队列 RocketMQ 版 的服务端完成。更多信息，请参见 消息过滤。消息轨迹 ...
推送到邮箱
可选：消息过滤标签：输入标签用于过滤消息。重试策略：选择重试策略。消息推送格式：选择 SIMPLIFIED。步骤三：发布消息 登录 消息服务MNS控制台。在左侧导航栏，单击 主题列表。在顶部菜单栏，选择地域。在 主题列表 页面，找到目标主题...
推送到阿里短信
可选：消息过滤标签：输入标签用于过滤消息。重试策略：选择重试策略。消息推送格式：选择 SIMPLIFIED。步骤三：发布消息 登录 消息服务MNS控制台。在左侧导航栏，单击 主题列表。在顶部菜单栏，选择地域。在 主题列表 页面，找到目标主题...
普通消息
使用示例 普通消息支持设置消息索引键、消息过滤标签等信息，用于消息过滤和搜索查找。以Java语言为例，收发普通消息的示例代码如下：完整的消息收发示例代码请参见 RocketMQ 5.x系列SDK（推荐）。普通消息发送。MessageBuilder ...
主题控制台操作帮助
可选：消息过滤标签：通过设置的标签对消息进行过滤。重试策略：向接收端推送消息出现错误时的重试策略。重试策略支持选择以下任一类型：退避重试 指数衰减重试 消息推送格式：设置推送消息到接收端的消息格式。消息推送格式可以选择以下任...
主题控制台操作帮助
可选：消息过滤标签：通过设置的标签对消息进行过滤。重试策略：向接收端推送消息出现错误时的重试策略。重试策略支持选择以下任一类型：退避重试 指数衰减重试 消息推送格式：设置推送消息到接收端的消息格式。消息推送格式可以选择以下任...
sample-txc-edas 样例
该样例综合了 GTS、EDAS 及 MQ 的使用，...在 sample-mq-consumer 目录下执行 build.sh 编译该工程，编译完成后在 sample-mq-consumer/client/bin 目录下执行 run.sh 可以消费掉刚刚 sample-txc-edas/txc-client-mq 工程生产出来的 MQ 消息。
Python SDK版本说明
Version 1.1.2 更新日期 2016-05-23 SDK 下载 更新内容 Topic推送支持消息过滤。增加 sample 目录，包含更详细的示例代码。Version 1.1.1 更新日期 2016-03-28 SDK 下载 更新内容 支持HTTPS。支持Logging。Version 1.1.0 更新日期 2016-01-...
领域模型概述
订阅关系以消费组粒度进行管理，消费组通过定义订阅关系控制指定消费组下的消费者如何实现消息过滤、消费重试及消费进度恢复等。云消息队列 RocketMQ 版 的订阅关系除过滤表达式之外都是持久化的，即服务端重启或请求断开，订阅关系依然...
自建Apache RocketMQ触发器
SQL：通过SQL语句进行消息过滤，可匹配消息的属性标识以及属性值。Tag Filter 选择 FilterType 后，需要配置对应的过滤类型下的过滤语句。TagA 认证模式 选择认证模式，支持 ACL 模式。ACL 用户名 当 认证模式 选择 ACL 后，需要配置Apache...
内容分割
数据处理 消息过滤：选择 无需过滤。消息转换：选择 自定义配置。消息体（body）选择 数据清洗，并选中 新建函数模版。函数模版 选择 内容分割 transform_split，然后根据业务情况修改函数代码。创建完成后，您可以登录 函数计算控制台 ...
推送到队列
（可选）消息过滤标签：输入标签用于过滤消息。重试策略：选择重试策略。消息推送格式：选择消息推送格式。步骤四：发布消息 登录 消息服务MNS控制台。在左侧导航栏，单击 主题列表。在顶部菜单栏，选择地域。在 主题列表 页面，找到目标...
- 产品推荐
- 这些文档可能帮助您