云消息队列 Kafka 版 提供默认接入点、SSL接入点和SASL接入点以适用不同的连接及安全需求。默认接入点适用于在保密性较高的VPC环境收发消息;SASL接入点适用于无需对传输链路加密但需对消息收发鉴权;需要链路加密和消息鉴权,建议使用SSL...
简介 引擎用于描述消息在集成流中各个节点之间传递的数据结构。坐标:com.alibaba.bwif.script.core.StepMessage。结构说明 属性 类型 说明 id String 消息的唯一标识,每个节点的输入消息和输出消息ID都不同。attribute Map 用途:保存在...
本文主要对 云消息队列 RocketMQ 版 涉及的专有名词及术语进行定义和解析,方便您更好地理解相关概念并使用 云消息队列 RocketMQ 版。Topic 消息主题,一级消息类型,通过Topic对消息进行分类。更多信息,请参见 Topic与Tag最佳实践。消息...
扩展查询:在扩展协议里,前端首先发送一个Parse消息,它包含一个文本查询字符串,如果成功创建了一个命名的预备语句对象,那么它将持续到当前会话结束,一旦一个预备语句存在,就可以很使用Bind消息使之进入执行状态,Bind消息会传递相关...
在使用云消息队列 Kafka 版时,客户端可能报错,您可以根据报错消息匹配对应的解决方案。详细信息 报错信息对应的详细信息如下。报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权(sasl.mechanisms)...
说明 如果需要全量传递源端的RocketMQ消息的属性,推荐使用示例中的配置。变量:{"userProperties":"$.data.userProperties","msgId":"$.data.systemProperties.UNIQ_KEY"} 模板:{"EB_SYS_EMBED_OBJECT":"${userProperties}","UNIQ_KEY":...
本文说明 云消息队列 Kafka 版 涉及的专有名词和术语,帮助您更好地理解相关概念并使用该产品。Apache Kafka 一款开源的分布式数据流处理平台,可以实时发布、订阅、存储和处理数据流。更多信息,请参见 Apache Kafka。云消息队列 Kafka 版...
什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合,可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制(RAM)产品提供了两种类型的权限策略:系统策略和自定义策略。系统策略统一由阿里云创建,策略的版本...
如果您希望消息被投递后延迟一段时间被消费者消费,您可以使用 云消息队列 RabbitMQ 版 的延时消息。云消息队列 RabbitMQ 版 原生支持延时消息,使用方式比开源RabbitMQ更简单。什么是延时消息 延时消息是指在指定时间段之后才被消费者消费...
本文主要对 SOFAStack 消息队列涉及的专有名词及术语进行定义和解析,方便您更好地理解相关概念并使用消息队列。中文 英文 释义 消息主题 Topic 消息主题,一级消息类型,通过 Topic 对消息进行分类。详情请参见 Topic 与 Tag。消息 ...
查询 Topic 中存储的消息,可通过消息创建时间或者位点来进行查询。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息...
每个节点每次运行时会包含三个环节:收到输入消息(input message)、运行本节点的逻辑(如请求某个应用的接口)、产生输出消息(output message)并向后传递。集成应用对消息结构(message)进行了统一的约定,类型为 StepMessage,主要...
云消息队列 MQTT 版 V2.x.x版本强依赖 云消息队列 RocketMQ 版 作为消息存储,因此 云消息队列 MQTT 版 消息和 云消息队列 RocketMQ 版 天然打通,创建了Topic后即可天然使用 云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的SDK相互通信...
本文介绍 云消息队列 RocketMQ 版 使用自定义权限策略的场景和策略示例。什么是自定义权限策略 在基于RAM的访问控制体系中,自定义权限策略是指在系统权限策略之外,您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您...
本文主要介绍 云消息队列 RocketMQ 版 TCP协议的Java客户端使用过程中,经常会出现的消息堆积和消息延迟的问题。通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的主要原因,帮助您可以在业务部署前更好的规划资源和配置,或...
专有网络VPC环境下使用SSL加密传输消息 不支持。支持。跨可用区 不支持。支持。下载消息 支持。支持。共享性 部分资源(如磁盘)共享。可能有抖动,主要为延迟升高。例如,可能存在偶然的突发流量,导致磁盘压力增大,从而导致请求延迟大,...
本文主要介绍 云消息队列 RocketMQ 版 的定时消息和延时消息的概念、适用场景以及使用过程中的注意事项。概念介绍 定时消息:Producer将消息发送到 云消息队列 RocketMQ 版 服务端,但并不期望立马投递这条消息,而是推迟到在当前时间点...
全球消息路由的功能和使用方式和开源Shovel插件保持一致,支持不同实例和Vhost间的Queue到Queue、Queue到Exchange的消息转发。在此基础上,除了可以本地域间消息转发,也可以支持跨地域消息转发,以便您按需同步消息,实现不同实例、不同...
本文介绍使用 云消息队列 MQTT 版 云端SDK时的常见问题。使用云端SDK发送消息成功,为什么无法消费?云端SDK发送消息,只能使用终端SDK消费消息;或终端SDK发送消息,云端SDK消费消息,不支持云端SDK发送消息,云端SDK消费消息。终端SDK...
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息,本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下,异构系统间需要维持强一致的状态同步,...
使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。basicReject方法的参数说明如下:deliveryTag:Channel的消息投递的唯一标识符。requeue:被否定应答的消息...
使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。basicReject方法的参数说明如下:deliveryTag:Channel的消息投递的唯一标识符。requeue:被否定应答的消息...
使用示例 Headers Exchange根据消息Headers属性和Binding Headers属性的匹配规则路由消息的示例如下:Message 消息Headers属性 Binding Headers属性 Queue Message A type=read resource=group type=read resource=group x-match=all type=...
已授权消息服务使用AliyunMNSLoggingRole角色导出日志。单击 云资源访问授权,根据提示完成授权。警告 请勿取消授权或删除RAM角色,否则将导致MNS日志无法正常推送到日志服务。背景信息 如下图所示,如果您创建了事件通知规则,当您在请求...
本文介绍使用C++ SDK v2.x.x及以上版本接入 云消息队列 RocketMQ 版 所需完成的准备工作、使用说明以及注意事项,以便后续使用C++ SDK收发消息。使用前,请注意以下几点:本文仅针对C++ SDK v2.x.x及以上版本进行说明,若您需从当前使用的v...
本文针对使用 云消息队列 RocketMQ 版 SDK与 云消息队列 MQTT 版 交互的场景,提供交互中所涉及的消息结构和属性字段的映射关系,方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版 是一款面向移动端的网关产品,可通过数据互通...
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数,例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等,并支持可视化查询。当消息收发结果不符合预期...
本文汇总了使用 云消息队列 Kafka 版 实例时的常见问题。计费问题 为什么购买了按量付费实例后不使用也要收费?为什么按流量峰值收费?按流量峰值收费的依据是什么?为什么额外增加分区要收费?我使用的Connector组件如何计费?客户端报错 ...
本文介绍使用开源的客户端SDK接入 云消息队列 RabbitMQ 版 服务端时的注意事项。要点 说明 com.rabbitmq.client.ConnectionFactory 接口 设置 com.rabbitmq.client.ConnectionFactory 接口时,必须开启连接自动恢复功能,保证服务端升级时...
本文介绍 云消息队列 MQTT 版 提供的云端SDK和管控SDK的使用场景。使用说明 使用 云消息队列 MQTT 版 的云端SDK收发消息时,需要和终端SDK搭配使用。例如,使用云端SDK发送消息,终端SDK接收消息;或使用终端SDK发送消息,云端SDK接收消息...
如果消息消费出现异常,您可以在 云消息队列 RocketMQ 版 控制台查看指定Group ID的消费状态,包括消费者在线状态、订阅关系一致性结果、消费堆积相关指标、消费者客户端信息等,帮助您快速定位异常原因。应用场景 消费者状态信息包括在线...
本文从稳定性、内核能力、治理能力以及使用习惯等方面,对比阿里云 云消息队列 Kafka 版 与开源Apache Kafka。稳定性 项目 云消息队列 Kafka 版 Apache Kafka 磁盘水位 磁盘写满删除旧数据。磁盘写满直接宕机。线程池隔离 读冷数据仍可以...
本文为您介绍如何快速使用 云消息队列 RocketMQ 版 实现消息收发。使用流程 快速使用 云消息队列 RocketMQ 版 收发消息的流程如下图所示。使用说明 权限说明 若您的账号为RAM用户,则必须先为该RAM用户进行授权,才能访问 云消息队列 ...
取值如下:normal:普通消息 fifo:顺序消息 delay:定时/延时消息 transaction:事务消息 messaging.rocketmq.message.tag string 消息的过滤标签。消费者可通过Tag对消息进行过滤,仅接收指定标签的消息。messaging.rocketmq.message....
消息服务MNS 可以为队列和主题开启日志管理功能,支持将队列或主题的消息操作日志推送到 日志服务 SLS(Simple Log Service)。在成功将MNS日志推送到 SLS 后,MNS支持通过日志查询特定信息。例如在消息发送、消费、确认等环节出现异常时,...
在使用开源RabbitMQ集群时,当您希望能够解决各种稳定性痛点(例如消息堆积、脑裂等问题)、实现高并发、分布式、灵活扩缩容时,您可以将开源RabbitMQ集群迁移至 云消息队列 RabbitMQ 版,本文介绍迁移上云的前提条件、操作步骤、注意事项...
如果您是首次使用 云消息队列 RocketMQ 版,您可以参考快速入门文档,了解如何购买实例并接入 云消息队列 RocketMQ 版 服务端完成基本的消息收发流程。使用流程 快速使用 云消息队列 RocketMQ 版 收发消息的流程如下图所示。详细操作,请...
消息服务MNS 支持一对多拉取消息消费模型,以满足一对多订阅、主动拉取的场景。本文介绍如何高效利用该模型实现多消费者并行拉取与处理消息。说明 本文以Java SDK为例介绍广播拉取消息流程,其他语言SDK请参见 新版SDK参考(推荐)。前提...
使用前,请注意以下几点:使用 云消息队列 RocketMQ 版 服务的应用程序需要部署在阿里云ECS上。代码里涉及到的Topic和Group ID,需要到控制台上创建。Message Tag可以完全由应用自定义。创建步骤,请参见快速入门中的 创建资源。Windows....
对于电子价签系统中,改价任务的交互消息建议使用 云消息队列 MQTT 版 提供的P2P消息,P2P消息不需要订阅,发送方直接指定对端接收即可,详细信息,请参见 P2P消息收发模式(MQTT)。收发消息参数设计 由于电子价签场景改价任务一般要求...