消息过滤
消息过滤原理 消息过滤主要通过以下几个关键流程实现： 生产者：生产者在初始化消息时预先为消息设置一些属性和标签，用于后续消费时指定过滤目标。消费者：消费者在初始化及后续消费流程中通过调用订阅关系注册接口，向服务端上报需要订阅...
定时和延时消息
本文主要介绍 云消息队列 RocketMQ 版 的定时消息和延时消息的概念、适用场景以及使用过程中的注意事项。概念介绍 定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是推迟到在当前时间点...
事务消息
云消息队列 RocketMQ 版 提供的分布式事务消息适用于所有对数据最终一致性有强需求的场景。本文介绍 云消息队列 RocketMQ ...Node.js SDK 收发事务消息 PHP SDK 收发事务消息 Java SDK 收发事务消息 C++ SDK 收发事务消息 C#SDK 收发事务消息
PHP SDK收发消息
如果是默认接入点，无SASL相关代码，即删除如下代码中包含 sasl.和 ssl.相关的代码即可。set('sasl.mechanisms','PLAIN');conf->set('api.version.request','true');conf->set('sasl.username',$setting['sasl_plain_username']);conf->set...
什么是消息演练
目前市面上有RocketMQ、Kafka、RabbitMQ等流行的消息中间件服务，消息演练功能将这些常见的中间件进行了统一抽离，为消息服务安排分配了精选后的演练最佳实践。您不需要自己去研究分析每种消息服务需要什么演练场景，仅需选择演练方案即可...
消息 Mesh
中集成各种流量控制策略，例如可根据消息类型、消息数量、消息大小等多种参数来控制消息的发送和消费速率。流量调度：通过打通 Sidecar 节点之间的通信链路，可以利用 Sidecar 的流量转发来实现任意精度的消息流量调度，帮助基于事件驱动的...
如何处理消息堆积
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警，登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象：在 Group 详情 页面，看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹，单击 创建查询任务，...
消息队列RocketMQ版是否能保证消息不重复？
绝大多数情况下，消息是不重复的。作为一款分布式消息中间件，在网络抖动、应用处理超时等异常情况下，无法保证消息不重复，但是能保证消息不丢失。
消息队列
如果您希望区块链上的各种事件能自动发布到消息中间件，您可以将区块链事件和MQ做映射配置。当区块链服务监听到链上事件时，会自动生成MQ消息并发布到MQ的主题上，您可以订阅MQ中的这些事件消息做进一步处理。集成消息队列 RocketMQ 说明 ...
事务消息
事务消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行，同时需要调用多个下游业务...
设备消息收发解决方案
本文介绍物联网平台设备消息收发原理、实现方案及相关消息Topic说明。
消息队列RocketMQ
4.x标准版当前最高可达每秒5千条消息的限速机制，使用该版RocketMQ作为实时计算Flink版对接的消息中间件，可能会导致Flink作业运行不稳定。因此，在选择消息中间件时，如果您正在或计划通过标准版RocketMQ与Flink对接，请您谨慎评估。如果...
消息收发功能
云消息队列 MQTT 版 支持多语言的消息收发。本文提供单独使用 云消息队列 MQTT 版 收发消息以及与 云消息队列 RocketMQ 版 结合使用时需使用的代码示例的链接。单独使用 云消息队列 MQTT 版 收发消息 语言 链接 Java ...Python ...
消息堆积和延迟问题
本文主要介绍 云消息队列 RocketMQ 版 TCP协议的Java客户端使用过程中，经常会出现的消息堆积和消息延迟的问题。通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的主要原因，帮助您可以在业务部署前更好的规划资源和配置，或...
消息查询
在左侧导航栏，选择 中间件>消息队列>消息查询 在 消息查询 页面，您可单击以下任一页签，然后按页面提示输入相应信息。按 Message ID 查询：Message ID 是由服务端生成的 32 位字符串，用于标识一条消息。按 Message ID 查询，即根据 ...
顺序消息
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，...
什么是云消息队列 MQTT 版
云消息队列 MQTT 版 是阿里云推出的一款面向移动互联网以及物联网领域的轻量级消息中间件。如果说传统的消息队列中间件一般应用于微服务之间，那么适用于物联网的 云消息队列 MQTT 版 则实现了端与云之间的消息传递和真正意义上的万物互联...
消息收发功能
消息收发为 云消息队列 MQTT 版 最基本的功能，云消息队列 MQTT 版 支持终端和云端服务接入 云消息队列 MQTT 版 服务器，实现终端和终端、终端和云端的消息通信。本文介绍消息收发功能的基本场景和示例代码。背景信息 云消息队列 MQTT 版 ...
查询消息轨迹
消息轨迹是指一条消息从生产者发送到消息队列服务端，再到消费者消费处理，整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。本文介绍如何快速查询消息轨迹。前提条件 您的消息已从生产者发送。操作步骤 登录 SOFAStack...
普通消息
中最基础的消息，区别于有特性的顺序消息、定时/延时消息和事务消息。本文为您介绍普通消息的应用场景、功能原理、使用方法和使用建议。应用场景 普通消息一般应用于微服务解耦、事件驱动、数据集成等场景，这些场景大多数要求数据传输通道...
使用Spring Cloud框架收发消息
本文介绍如何使用Spring Cloud框架接入 云消息队列 Kafka 版 并收发消息。背景信息 Spring Cloud是用于构建消息驱动的微服务应用程序的框架。详细信息，请参见 Spring Cloud Stream。前提条件 安装1.8或以上版本JDK。安装2.5或以上版本...
什么是云消息队列 RocketMQ 版？
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台，面向互联网分布式应用场景提供微服务异步解耦、流式数据处理、事件驱动处理等核心能力。为什么选择云...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的PHP SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的PHP SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装PHP SDK。更多信息，请参见 准备环境...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的PHP SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。更...
数据出口至消息队列MQ
物联网络管理平台支持数据出口至阿里云中间件消息队列MQ，本文介绍如何在物联网络管理平台上配置数据流转至消息队列MQ。配置出口数据 登录 物联网络管理平台控制台。在左侧导航栏选择 节点管理>节点分组，单击一条节点分组对应 操作 栏下的...
收发定时消息和延时消息
背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时消息。定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端...
消息存储和清理机制
本文为您介绍 云消息队列 RocketMQ 版 中消息的存储机制，包括消息的存储粒度、判断依据及后续处理策略等。背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限...
定时/延时消息
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻...
普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。说明 您在调用SDK收发消息时需注意， 云消息队列 RocketMQ 版 提供的四种消息类型所对应的Topic不能混用，例如，您创建的普通...
消息路由
本文将引导您快速创建并管理消息路由任务，实现单元化部署环境下跨单元消息路由和同步。说明 该功能仅适用于支持 LDC 单元化架构的环境。创建路由任务 您可以登录消息队列控制台，根据业务需求创建跨地域的消息同步任务。操作步骤如下：...
事务消息
本文介绍如何使用 消息服务MNS 的延时消息功能，实现本地操作和消息发送的事务一致性。前提条件 您已创建以下队列，具体操作，请参见 创建队列。事务消息队列 消息存活时间小于消息延时时间。当消息发送成功、事务操作成功时，生产者修改...
消息推送简介
消息推送服务（Message Push Service，简称 MPS）是移动开发平台 mPaaS 提供的专业的移动消息推送方案，针对不同的场景推出多种推送类型，满足您的个性化推送需求。为了提升推送的到达率，mPaaS 在 MPS 中集成了华为、小米等厂商的推送功能...
什么是消息解析
物联网平台定义设备消息的标准数据格式为Alink JSON。对于低配置且资源受限或者对网络流量有要求的设备，不适合直接构造JSON数据与物联网平台通信，可将原数据透传到物联网平台。物联网平台提供消息解析功能，可以根据您提交的脚本，将消息...
消息（Message）
本文介绍 云消息队列 RocketMQ 版 中消息（Message）的定义、模型关系、内部属性、行为约束及使用建议。定义 消息是 云消息队列 RocketMQ 版 中的最小数据传输单元。生产者将业务数据的负载和拓展属性包装成消息发送到 云消息队列 RocketMQ...
MNS消息队列消费模式
本文为您介绍MNS消息队列消费模式接收回执消息的示例代码。相关下载 语言 说明 Java 下载 Java MNS SDK 安装包拉取MNS消息。Node.js 下载 Node.js MNS SDK 安装包拉取MNS消息。NET/C# 依赖.NET语言的阿里云SDK核心库及dybaseapi，其中...
顺序消息
云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的注意事项。什么是顺序消息 顺序消息是 云消息队列 RocketMQ 版 提供的一种对消息发送和消费顺序有严格要求的消息。对于一个指定的Topic，消息严格按照先进先出...
服务端订阅设备消息
为消息消费端配置消费组身份，用于企业服务器通过消费组获取转发的消息。在左侧导航栏，选择，单击 消费组列表 页签。单击 创建消费组。在 创建消费组 对话框中，设置消费组名称为 路灯消费组，单击 确认。为路灯设备所属产品配置服务端...
步骤三：调用SDK收发消息
事务消息Topic必须提前配置，以免事务消息回查接口失败，具体原理请参见事务消息。Producer producer= provider.newProducerBuilder().setTopics(topic) setClientConfiguration(configuration).build();普通消息发送。Message message= ...
物联网平台通过消息组转发消息为什么存在延迟？
物联网平台推送到消费端（AMQP客户端）的消息不保序，即AMQP客户端接收到消息的时间顺序不一定是消息实际产生的时间顺序。您可根据以下方法，对消费端接收消息进行排序。设备上下线消息：收到消息的顺序不是实际设备上下线时间排序。设备...
- 产品推荐
- 这些文档可能帮助您