SSL接入点PLAIN机制收发消息
本文以Java SDK为例介绍如何在公网环境下使用SDK接入 云消息队列 Kafka 版 的SSL接入点并使用PLAIN机制收发消息。前提条件 步骤三：创建资源 安装1.8或以上版本JDK 安装2.5或以上版本Maven 安装Java依赖库 在 pom.xml 中添加以下依赖。...
消息存储和清理机制
消息在队列中的存储情况如下：消息存储管理粒度说明 云消息队列 RocketMQ 版 按照服务端节点粒度管理存储时长而非队列或主题，原因如下：消息存储优势权衡：云消息队列 RocketMQ 版 基于统一的物理日志队列和轻量化逻辑队列的二级组织方式...
消息发送重试和流控机制
消息流控机制 消息流控基本概念 消息流控指的是系统容量或水位过高，云消息队列 RocketMQ 版 服务端会通过快速失败返回流控错误来避免底层资源承受过高压力。触发条件 云消息队列 RocketMQ 版 的消息流控触发条件如下：存储压力大：参考 ...
消息超时和重试机制
本文介绍 云消息队列 RabbitMQ 版 服务端默认的消息重试机制，帮助您理解消费失败后的消息处理逻辑，并选择合适的消息处理策略。重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试...
消息重试
消费逻辑的最终兜底机制，消息重试失败且超过最大重试次数，若保存死信消息功能开启，该失败消息会被投递至死信Topic。您可以通过消费死信Topic的消息进行业务恢复。具体信息，请参见 死信队列。举例：某条消息的消费重试流程如上图所示，...
消费重试
消费逻辑的最终兜底机制，消息重试失败且超过最大重试次数，若保存死信消息功能开启，该失败消息会被投递至死信Topic。您可以通过消费死信Topic的消息进行业务恢复。具体信息，请参见 死信消息。Discard：丢弃。消息重试失败且超过最大重试...
设置消息通知
说明 目前工作流触发执行的任务，可忽略管道上绑定的消息机制，以创建工作流时 输入 节点绑定的消息机制为准。参数 描述 输入Bucket 选择输入路径后自动显示。输入路径 待处理文件的输入路径。转码管道 选择在上一步中已经绑定的转码管道。...
生产者（Producer）
事务检查器 定义：云消息队列 RocketMQ 版 的事务消息机制中，为保证异常场景下事务的最终一致性，生产者需要主动实现事务检查器的接口。具体信息，请参见 事务消息。发送事务消息时，事务检查器必须设置，且需要和预绑定主题列表一起配合...
开源对比
消息重试机制 消息消费超过一定时间未响应会重新投递。超时时间和重试次数的详细解释，请参见 消息超时和重试机制。无消息重试机制。无法跳过有问题消息的消费处理，无法处理新生产的消息，从而会导致消息大量堆积引起内存问题，导致消息...
消息重试
本文介绍 SOFAStack 消息队列的消息重试机制和配置方式。顺序消息的重试 对于顺序消息，当消费者消费消息失败后，消息队列会自动不断地进行消息重试（每次间隔时间为 1 秒），这时，应用会出现消息消费被阻塞的情况。因此，建议您使用顺序...
背景信息
OLAP场景中，为避免复杂SQL运行时间过长，程序一直阻塞等待而影响业务运行...DLA支持将消息写入阿里云 消息队列（Message Queue，简称MQ）、消息服务（Message Service，简称MNS，原MQS）或者 钉钉机器人，帮助您快速、异步感知任务执行状态。
欠费说明
消息通知机制，请参见 消息通知机制。如何设置预警提醒，请参见 设置实例到期欠费预警提醒通知。表 1.消息通知机制 付费方式 实例到期欠费停机提醒时间 停机 停机后释放实例提醒时间 释放 包年包月 实例到期前24小时 到期后立即停机 实例...
消费失败是否支持重试？
重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试机制和关闭消息重试机制。云消息队列 RabbitMQ 版 服务端默认的消息重试机制如下：如果您没有开启Consumer客户端消费消息，则不会...
获取离线MQTT消息
为了简化离线消息获取机制，云消息队列 MQTT 版 系统在客户端成功建立连接并通过权限校验后，会自动加载离线消息并下发到客户端。注意事项 客户端建立连接后，需要通过权限校验才能自动加载离线消息。例如，若您使用的是Token验证的方式，...
获取离线MQTT消息
为了简化离线消息获取机制，云消息队列 MQTT 版 系统在客户端成功建立连接并通过权限校验后，会自动加载离线消息并下发到客户端。注意事项 客户端建立连接后，需要通过权限校验才能自动加载离线消息。例如，若您使用的是Token验证的方式，...
SDK概述
SASL接入点：在VPC环境下通过SASL接入点接入 云消息队列 Kafka 版 并使用PLAIN机制或者SCRAM机制收发消息。SASL支持两种机制验证身份：PLAIN机制：一种简单的用户名密码校验机制。云消息队列 Kafka 版 的PLAIN机制，支持不重启实例的情况下...
普通消息
消息删除 云消息队列 RocketMQ 版 按照消息保存机制滚动清理最早的消息数据，将消息从物理文件中删除。更多信息，请参见 消息存储和清理机制。使用限制 普通消息仅支持使用 MessageType 为 Normal 主题，即普通消息只能发送至类型为普通...
事务消息
事务超时机制 云消息队列 RocketMQ 版 事务消息的生命周期存在超时机制，即半事务消息被生产者发送服务端后，如果在指定时间内服务端无法确认提交或者回滚状态，则消息默认会被回滚。事务超时时间，请参见 参数限制。不支持多个sendReceipt...
消费者负载均衡
消息消费的顺序性机制：通过消费者负载均衡策略，您可以进一步了解消息消费时，如何保证同一消息组内消息的先后顺序。消息分配的水平拆分策略：了解消费者负载均衡策略，您可以明确消息消费压力如何被分配到不同节点，有针对性地进行流量...
定时/延时消息
消息删除 云消息队列 RocketMQ 版 按照消息保存机制滚动清理最早的消息数据，将消息从物理文件中删除。更多信息，请参见 消息存储和清理机制。使用限制 消息类型一致性 定时消息仅支持在 MessageType 为 Delay 的主题内使用，即定时消息...
顺序消息
如需保证消息生产的顺序性，则必须满足以下条件：同一消息组（MessageGroup）消息生产顺序性的范围为消息组，生产者发送消息时可以为每条消息设置消息组，只有同一消息组内的消息可以保证顺序性，不同消息组或未设置消息组的消息之间不保证...
消息收发计算规格费用
消息收发TPS计算规则 消息收发TPS即为每秒钟消息发送和订阅消息次数的最大总和。实例默认的收发能力比例为1:1，对于写少读多的场景，您可以在 云消息队列 RocketMQ 版 控制台修改收发比例。消息大小以4 KB为最小计量单位，不足4 KB按照4 KB...
概述
云消息队列 Kafka 版 快速入门操作流程 操作步骤 具体操作步骤如下：步骤一：获取访问授权 步骤二：购买和部署实例 VPC接入 公网和VPC接入 步骤三：创建资源 步骤四：使用SDK收发消息 默认接入点收发消息 SSL接入点PLAIN机制收发消息 视频...
消费者分类
适用场景 PushConsumer严格限制了消息同步处理及每条消息的处理超时时间，适用于以下场景：消息处理时间可预估：如果不确定消息处理耗时，经常有预期之外的长时间耗时的消息，PushConsumer的可靠性保证会频繁触发消息重试机制造成大量重复...
使用ACL功能进行访问控制
相关操作 完成授权后，用户A可以通过SASL接入点接入 云消息队列 Kafka 版 并使用PLAIN机制消费消息。如何使用SDK接入，请参见 SDK概述。如果您希望通过API方式为SASL用户授权，请参见 CreateSaslUser-创建SASL用户 和 CreateAcl-创建ACL。...
死信Exchange
消息过期，即消息在Queue中存在的时间超过了设置的消息存活时间。具体信息，请参见 消息存活时间。死信Queue 死信Exchange绑定的Queue，用于存储死信消息。路由流程 死信Exchange路由死信消息的流程如下：生产者将消息发送到Exchange。...
CreateSaslUser-创建SASL用户
消息队列 Kafka 版优化了 PLAIN 机制，支持不重启实例的情况下动态增加 SASL 用户。scram：一种用户名密码校验机制，安全性比 PLAIN 更高。消息队列 Kafka 版使用 SCRAM-SHA-256。默认值为 plain。plain Mechanism string 否 加密方式。...
DescribeSaslUsers-查询SASL用户
消息队列 Kafka 版优化了 PLAIN 机制，支持不重启实例的情况下动态增加 SASL 用户。scram：一种用户名密码校验机制，安全性比 PLAIN 更高。消息队列 Kafka 版使用 SCRAM-SHA-256。默认值为 plain。scram Password string 密码。Username ...
DeleteSaslUser-删除SASL用户
消息队列 Kafka 版优化了 PLAIN 机制，支持不重启实例的情况下动态增加 SASL 用户。scram：一种用户名密码校验机制，安全性比 PLAIN 更高。消息队列 Kafka 版使用 SCRAM-SHA-256。默认值为 plain。scram Mechanism string 否 加密方式。...
请求签名机制
本文介绍API请求的签名机制的构成、计算方法和示例。签名构成 消息服务MNS 服务会对每个访问的请求进行验证，每个请求向 消息服务MNS 提交时，都需要在该请求的Header中包含签名（Authorization）。消息服务MNS 通过使用AccessKeyId和...
签名机制
本文介绍签名的生成机制。背景信息 AccessKey ID和AccessKey Secret由阿里云官方颁发给访问者（可以通过阿里云管理控制台申请和管理），其中：AccessKey ID用于标识访问者的身份。AccessKey Secret用于加密签名字符串和服务器端验证签名...
产品优势
功能齐全 支持多种消息类型：普通消息、定时消息、分区顺序消息、事务消息 支持多种消费模式：Pub/Sub 模式、Tag 过滤 支持 TCP Java SDK 运维体系...千万级高并发处理能力 服务可靠 99.9%服务高可用 99.99999%数据高可靠 支持消息重投机制
接入点对比
公网/VPC实例接入点对比 网络类型 端口 接入点 协议 适用场景 公网 9093 SSL接入点 SASL_SSL 消息传输过程需加密，消息收发需鉴权，支持以下两种机制验证身份：PLAIN SCRAM-SHA-256 专有网络VPC 9092 默认接入点 PLAINTEXT 消息传输过程...
生产者负载均衡
消息发送的顺序性机制：通过生产者负载均衡策略，您可以进一步了解顺序消息发送时，如何保证相同消息组内消息的先后顺序。消息服务能力的均衡性策略：了解生产者负载均衡策略，您可以知晓消息在不同节点间分配的规律，您可以按照负载策略...
队列（MessageQueue）
模型关系 在整个 云消息队列 RocketMQ 版 的领域模型中，队列所处的流程和位置如下：云消息队列 RocketMQ 版 默认提供消息可靠存储机制，所有发送成功的消息都被持久化存储到队列中，配合生产者和消费者客户端的调用可实现至少投递一次的...
订阅消息API
说明 HTTP协议下 云消息队列 RocketMQ 版 的消息重试机制为：无序消息每隔5分钟重试一次，顺序消息每隔1分钟重试一次，最多重试288次。ConsumedTimes String 消息被消费的次数。MessageTag String 消息Tag。Properties String 消息属性。...
消息过滤
使用建议 合理划分主题和Tag标签 从消息的过滤机制和主题的原理机制可以看出，业务消息的拆分可以基于主题进行筛选，也可以基于主题内消息的Tag标签及属性进行筛选。关于拆分方式的选择，应遵循以下原则：消息类型是否一致：不同类型的消息...
主题（Topic）
主题管理尽量避免自动化机制 在 云消息队列 RocketMQ 版 架构中，主题属于顶层资源和容器，拥有独立的权限管理、可观测性指标采集和监控等能力，创建和管理主题会占用一定的系统资源。因此，生产环境需要严格管理主题资源，请勿随意进行增...
Go SDK收发消息
sasl.mechanism 消息收发的机制。各类型接入点对应取值如下：默认接入点：不涉及，无需配置。SSL接入点：PLAIN。SASL接入点：PLAIN机制需配置为PLAIN；SCRAM机制需配置为SCRAM-SHA-256。sasl.username SASL用户名。如果是SSL接入点或SASL接...
- 产品推荐
- 这些文档可能帮助您