本文针对使用 云消息队列 RocketMQ 版 SDK与 云消息队列 MQTT 版 交互的场景,提供交互中所涉及的消息结构和属性字段的映射关系,方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版 是一款面向移动端的网关产品,可通过数据互通...
消息过期清理机制 开源的Apache RocketMQ中,消息保存时长并不能完整控制消息的实际保存时间,因为消息存储仍然使用本地磁盘,本地磁盘空间不足时,为保证服务稳定性消息仍然会被强制清理,导致消息的实际保存时长小于设置的保存时长。...
使用示例 Headers Exchange根据消息Headers属性和Binding Headers属性的匹配规则路由消息的示例如下:Message 消息Headers属性 Binding Headers属性 Queue Message A type=read resource=group type=read resource=group x-match=all type=...
本文汇总了使用 云消息队列 Kafka 版 实例时的常见问题。计费问题 为什么购买了按量付费实例后不使用也要收费?为什么按流量峰值收费?按流量峰值收费的依据是什么?为什么额外增加分区要收费?我使用的Connector组件如何计费?客户端报错 ...
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息,本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下,异构系统间需要维持强一致的状态同步,...
创建Topic Topic是 云消息队列 RocketMQ 版 里对消息的一级归类,例如创建名称为Topic_Trade的Topic来识别交易类消息,消息生产者将消息发送到Topic_Trade,而消息消费者则通过订阅该Topic来获取和消费消息。Topic的使用说明如下:Topic不...
创建Topic Topic是 云消息队列 RocketMQ 版 里对消息的一级归类,例如创建名称为Topic_Trade的Topic来识别交易类消息,消息生产者将消息发送到Topic_Trade,而消息消费者则通过订阅该Topic来获取和消费消息。Topic的使用说明如下:Topic不...
如果您是首次使用 云消息队列 RocketMQ 版,您可以参考快速入门文档,了解如何购买实例并接入 云消息队列 RocketMQ 版 服务端完成基本的消息收发流程。使用流程 快速使用 云消息队列 RocketMQ 版 收发消息的流程如下图所示。详细操作,请...
本文介绍使用开源的客户端SDK接入 云消息队列 RabbitMQ 版 服务端时的注意事项。要点 说明 com.rabbitmq.client.ConnectionFactory 接口 设置 com.rabbitmq.client.ConnectionFactory 接口时,必须开启连接自动恢复功能,保证服务端升级时...
本文从稳定性、内核能力、治理能力以及使用习惯等方面,对比阿里云 云消息队列 Kafka 版 与开源Apache Kafka。稳定性 项目 云消息队列 Kafka 版 Apache Kafka 磁盘水位 磁盘写满删除旧数据。磁盘写满直接宕机。线程池隔离 读冷数据仍可以...
本文介绍使用C++ SDK v2.x.x及以上版本接入 云消息队列 RocketMQ 版 所需完成的准备工作、使用说明以及注意事项,以便后续使用C++ SDK收发消息。使用前,请注意以下几点:本文仅针对C++ SDK v2.x.x及以上版本进行说明,若您需从当前使用的v...
使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。basicReject方法的参数说明如下:deliveryTag:Channel的消息投递的唯一标识符。requeue:被否定应答的消息...
如果消息消费出现异常,您可以在 云消息队列 RocketMQ 版 控制台查看指定Group ID的消费状态,包括消费者在线状态、订阅关系一致性结果、消费堆积相关指标、消费者客户端信息等,帮助您快速定位异常原因。应用场景 消费者状态信息包括在线...
在使用开源RabbitMQ集群时,当您希望能够解决各种稳定性痛点(例如消息堆积、脑裂等问题)、实现高并发、分布式、灵活扩缩容时,您可以将开源RabbitMQ集群迁移至 云消息队列 RabbitMQ 版,本文介绍迁移上云的前提条件、操作步骤、注意事项...
使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。basicReject方法的参数说明如下:deliveryTag:Channel的消息投递的唯一标识符。requeue:被否定应答的消息...
收发消息参数设计 由于CSG控制台是利用MQTT模拟的RPC调用,控制台下发的消息,没有返回值就直接用 noreply 表示,无需重复接受之前的消息。控制台会在接到错误码后,提示用户再次下发指令。需在MQTT客户端做以下配置:cleanSession 参数...
云消息队列 MQTT 版 的Serverless实例购买成功后,默认为您预留固定规格的资源,若实际使用量超过预留规格,则按照实际使用量弹性计费,可以帮助您提高资源利用率并降低业务成本。重要 Serverless版实例购买后,无论是否使用实例都会开始按...
在阿里云官方网站开通消息队列服务后方可开始使用 云消息队列 MQTT 版。如果您的账号为RAM用户,必须先为RAM用户进行授权,才能通过控制台或API访问相应的 云消息队列 MQTT 版 资源,并使用SDK收发消息。前提条件 您已注册阿里云账号并完成...
对于电子价签系统中,改价任务的交互消息建议使用 云消息队列 MQTT 版 提供的P2P消息,P2P消息不需要订阅,发送方直接指定对端接收即可,详细信息,请参见 P2P消息收发模式(MQTT)。收发消息参数设计 由于电子价签场景改价任务一般要求...
消息服务MNS 可以为队列和主题开启日志管理功能,支持将队列或主题的消息操作日志推送到 日志服务 SLS(Simple Log Service)。在成功将MNS日志推送到 SLS 后,MNS支持通过日志查询特定信息。例如在消息发送、消费、确认等环节出现异常时,...
如需使用压缩消息,您需要在 云消息队列 Kafka 版 的客户端进行设置。在 云消息队列 Kafka 版 客户端进行消息压缩的说明如下:压缩格式:支持Snappy、LZ4、GZIP等压缩格式。其中,GZIP对CPU的消耗较高,因此不建议您选择GZIP,建议您选择...
典型错误使用死信消息场景 处理死信消息时,如果将死信消息多层流转,转储回原Topic,会引起死信消息再次被循环重试,可能会引起雪崩效应。死信策略 什么时候消息会转为死信状态 消息重试达到最大重试次数后还没有被成功消费,消息将不再被...
取值如下:normal:普通消息 fifo:顺序消息 delay:定时/延时消息 transaction:事务消息 messaging.rocketmq.message.tag string 消息的过滤标签。消费者可通过Tag对消息进行过滤,仅接收指定标签的消息。messaging.rocketmq.message....
本文以Windows系统为例,介绍如何使用MQTT.fx模拟SDK接入 云消息队列 MQTT 版 并进行消息收发。前提条件 下载并安装 MQTT.fx。背景信息 云消息队列 MQTT 版 最简单的使用场景即MQTT客户端消息的自发自收。如下图所示,您可以使用MQTT.fx...
使用限制 使用 云消息队列 RabbitMQ 版 消息轨迹功能时,限制如下:仅当实例支持消息轨迹时,才可以查询该实例中消息收发的轨迹。说明 实例是否支持消息轨迹和可以查询的消息轨迹时间范围,由您在创建实例时选择配置。如果实例未配置消息...
云消息队列 RocketMQ 版 的消费者和生产者客户端对象是线程安全的,可以在多个线程之间共享使用。您可以在服务器上(或者多台服务器)部署多个生产者和消费者实例,也可以在同一个生产者或消费者实例里采用多线程发送或接收消息,从而提高...
本文以 TCP 协议下的 Java 为例,提供操作示例帮助您从零开始搭建消息队列测试工程,提供 Spring 和纯 Java 两种使用方式。Demo 工程包含普通消息、顺序消息、事务消息和定时、延时消息的配置以及测试代码。前提条件 安装 IDE。您可以使用 ...
SOFABoot 目前对外开放的有...支持 中间件(消息)MsgBroker 不支持 支持 中间件(数据)DTX 支持 说明 支持 TCC、FMT 模式。支持异库事务日志存储。支持 说明 支持 TCC、FMT 模式。支持异库事务日志存储。支持同城双活。支持共享版中间件。
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息,本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和延时消息本质相同,都是服务端根据消息设置的定时时间在某一固定时刻...
消息存储实例目前只支持 云消息队列 RocketMQ 版 类型的后端存储实例。目前您在同一个地域(Region)可以创建有限数量的 云消息队列 MQTT 版 实例,且一个 云消息队列 MQTT 版 实例仅可绑定一个相应的 云消息队列 RocketMQ 版 实例。同一...
本文介绍使用 云消息队列 MQTT 版 进行消息收发时的常见问题。为什么会出现一条消息同一时间重试多次?为什么消息会一直重试?消息发送时提示GroupID没有权限。使用RocketMQ数据流入MQTT功能时,为什么子级Topic后会多了一个“/”?消息发送...
云消息队列 Kafka 版 快速入门操作流程 操作步骤 具体操作步骤如下:步骤一:获取访问授权 步骤二:购买和部署实例 VPC接入 公网和VPC接入 步骤三:创建资源 步骤四:使用SDK收发消息 默认接入点收发消息 SSL接入点PLAIN机制收发消息 视频...
本文为您介绍如何使用发送消息。前提条件 已开通 ChatApp 消息服务。已完成 注册阿里云账号 和 企业实名认证。创建的模板已审核通过。具体操作,请参见 创建模板。WABA账号绑定的手机号码已完成验证。具体操作,请参见 通道管理。操作步骤 ...
当需要对不同的用户或用户组授予不同级别的访问权限时,您可以使用 云消息队列 Kafka 版 专业版 或V3系列Serverless 实例的访问控制列表(ACL)功能,为SASL用户赋予对Topic、Group等资源的操作权限,实现细粒度的权限管理。背景信息 企业A...
功能描述 功能类型 相关文档 支持通过开源插件rabbitmq_delayed_message_exchange的使用方式投递延时消息 您可使用兼容开源插件的方式,通过声明x-delayed-message Exchange,免去插件的安装,实现消息的延时投递。新增 x-delayed-message ...
已授权消息服务使用AliyunMNSLoggingRole角色导出日志。单击 云资源访问授权,根据提示完成授权。警告 请勿取消授权或删除RAM角色,否则将导致MNS日志无法正常推送到日志服务。背景信息 如下图所示,如果您创建了事件通知规则,当您在请求...
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。不同消息类型所属的Topic不能混用,例如收发普通消息的Topic不能用来收发其他类型的消息。本文提供使用TCP协议下的C/C++ SDK收发...
全球消息路由功能可用于跨地域间的消息同步,通过路由规则将消息从源实例的Topic中同步到目标实例的Topic,并支持过滤规则,按照指定的Tag将消息过滤后再进行同步。在容灾备份或异地多活场景下,您可以创建全球消息路由任务,确保跨地域间...
当您使用 ChatApp 消息服务 API接口发送消息后,可以通过MNS消息队列消费模式或HTTP批量推送模式来接收消息发送状态的结果和用户回复的消息内容。背景信息 如果出现网络异常、响应超时等情况,可能会导致回执消息推送重复、回执消息获取...
若您使用 云消息队列 MQTT 版 的数据流入、数据流出规则和 云消息队列 RocketMQ 版 进行通信,云消息队列 RocketMQ 版 会根据调用的 云消息队列 RocketMQ 版 的消息收发API或Topic资源等进行计费。客户端上线下事件流出到消息队列RocketMQ...