消息并发-消息并发文档介绍内容-阿里云

SDK参考概述

普通消息顺序消息定时和延时消息事务消息 PushConsumer PullConsumer 批量消费广播消费集群消费消息重试查询消息轨迹死信队列重置消费位点 SDK使用说明 HTTP协议和TCP协议的接入点不可混用。例如，您使用TCP协议的SDK收发消息，您...

示例代码

thread和anotherThread共享Producer对象，并发地发送消息至消息队列RocketMQ版。Thread thread=new Thread(new Runnable(){@Override public void run(){ try { Message msg=new Message(/设置为您在消息队列RocketMQ版控制台上创建的Topic...

监控指标

流控错误并发实例超上限（RegionThrottles）次在某一地域内调用函数时，由于函数并发实例超上限导致函数执行失败，且返回 429 状态码的总调用次数。按1分钟或1小时粒度统计求和。实例总数超上限（RegionResourceThrottles）次在某一地域...

API概览

消息灰度消息灰度 GetAppMessageQueueRoute 获取应用消息灰度信息获取应用消息灰度相关的信息。UpdateMessageQueueRoute 更新应用消息灰度的配置更新应用消息灰度的配置。云原生网关 API 标题 API概述插件市场插件市场 GetPlugins ...

顺序消息

如需保证消息生产的顺序性，则必须满足以下条件：同一消息组（MessageGroup）消息生产顺序性的范围为消息组，生产者发送消息时可以为每条消息设置消息组，只有同一消息组内的消息可以保证顺序性，不同消息组或未设置消息组的消息之间不保证...

触发器高级功能

并发消费您可以通过设置并发消费线程数提高吞吐，目前仅Kafka触发器支持设置并发配额，云消息队列 Kafka 版并发消费需配合Topic分区共同实现，包括以下几种场景。Topic分区数=并发消费数：一个线程消费一个Topic分区。Topic分区数>并发...

应用场景

消息同步库：按照接收者存储同步消息，需要支持高并发写入以及实时拉取（写扩散）。消息索引：对历史库数据进行数据检索，需要支持数据更新同步。IM场景中可使用表格存储互联网应用架构中的分布式结构化数据存储架构来实现。场景架构如下...

什么是消息服务MNS

海量并发访问支持多个生产者和消费者并发访问同一队列，并能确保某条消息在取出之后的特定时间内，无法被其他消费者获得。您可以根据业务需求自由伸缩并发访问数。消息投递保障在消息有效期内，确保消息至少能被成功消费一次。消息服务...

消费者分组（ConsumerGroup）

模型关系在云消息队列 RocketMQ 版的领域模型中，消费者分组的位置和流程如下：消息由生产者初始化并发送到云消息队列 RocketMQ 版服务端。消息按照到达云消息队列 RocketMQ 版服务端的顺序存储到主题的指定队列中。消费者按照指定...

如何处理消息堆积

一般情况下，客户端从Broker节点拉取消息的过程不会导致消息堆积，主要是客户端本地消费过程中，由于消费耗时过长或消费并发度较小等原因，导致客户端消费能力不足，出现消息堆积的问题。具体的消费原理和消息堆积原因请参见消息堆积和...

消费者（Consumer）

模型关系在云消息队列 RocketMQ 版的领域模型中，消费者的位置和流程如下：消息由生产者初始化并发送到云消息队列 RocketMQ 版服务端。消息按照到达云消息队列 RocketMQ 版服务端的顺序存储到主题的指定队列中。消费者按照指定的...

ReceiveMessage

目前消息服务MNS 服务端会根据长轮询数量、长轮询等待时间、访问IP数量等因素动态设置长轮询防攻击并发上限值。当队列无消息时，超过长轮询上限值的请求将无法进入到监听状态，并直接返回404 MessageNotExist（按请求量正常计费）。如果您...

消息（Message）

模型关系在整个云消息队列 RocketMQ 版的领域模型中，消息所处的流程和位置如下：消息由生产者初始化并发送到云消息队列 RocketMQ 版服务端。消息按照到达云消息队列 RocketMQ 版服务端的顺序存储到队列中。消费者按照指定的订阅...

Serverless实例计费说明

云消息队列 RocketMQ 版中消息投递可分为并发投递和顺序投递，您可以在创建Group时选择投递方式，不同投递方式费用单价不同。阶梯单价 Serverless实例的消息收发单价在不同地域有所差异，具体价格如下：公共云地域单价标准版实例消息收发...

生产者（Producer）

模型关系在云消息队列 RocketMQ 版的领域模型中，生产者的位置和流程如下：消息由生产者初始化并发送到云消息队列 RocketMQ 版服务端。消息按照到达云消息队列 RocketMQ 版服务端的顺序存储到主题的指定队列中。消费者按照指定的...

订阅关系（Subscription）

模型关系在云消息队列 RocketMQ 版的领域模型中，订阅关系的位置和流程如下：消息由生产者初始化并发送到云消息队列 RocketMQ 版服务端。消息按照到达云消息队列 RocketMQ 版服务端的顺序存储到主题的指定队列中。消费者按照指定的...

Kafka触发器

同步调用投递并发最大值 Kafka消息投递到函数计算的并发最大值，取值范围为1~300。该参数仅对同步调用生效。如果需要更高的并发，请进入 EventBridge配额中心申请配额名称为 EventStreaming FC Sink 同步投递最大并发数的配额。1 触发...

ComputeSplits

调用ComputeSplits接口获取当前ParallelScan单个请求的最大并发数，用于使用多元索引并发导出数据时的并发度规划。请求消息结构 message ComputeSplitsRequest { optional string table_name=1;optional SearchIndexSplitsOptions search_...

调用ParallelScan接口并发扫描数据。请求消息结构 message ParallelScanRequest { optional string table_name=1;optional string index_name=2;optional ColumnsToGet columns_to_get=3;optional bytes session_id=4;optional ScanQuery ...

并发测试示例代码

本文介绍基于Java SDK提供的队列消息发送以及消费的并发测试用例。在并发测试中，您可以：指定并发度、运行时间。通过发送总请求数除以运行时间计算得到QPS。步骤一：初始化在运行目录创建 perf_test_config.properties 文件，按照如下...

2023年功能发布记录

实例类型及使用模式 Kafka触发器增加投递并发最大值优化 Kafka消息投递到函数计算的并发最大值，取值范围为1~300。该参数仅对同步调用生效。如果需要更高的并发，请进入 EventBridge配额中心申请配额名称为 EventStreaming FC Sink ...

2023年功能发布记录

实例类型及使用模式 Kafka触发器增加投递并发最大值优化 Kafka消息投递到函数计算的并发最大值，取值范围为1~300。该参数仅对同步调用生效。如果需要更高的并发，请进入 EventBridge配额中心申请配额名称为 EventStreaming FC Sink ...

创建SLS Sink Connector

本文介绍如何创建使用SLS Sink Connector，您可通过SLS Sink Connector将数据从云消息队列 Kafka 版实例的数据源Topic导出至日志服务SLS。前提条件详细步骤，请参见创建前提。步骤一：创建目标服务资源创建日志项目（Project）。详细...

创建OSS Sink Connector（旧版）

本文介绍如何创建使用OSS Sink Connector，您可以通过OSS Sink Connector将数据从云消息队列 Kafka 版的数据源Topic导出至对象存储OSS的Object中。前提条件详细步骤，请参见创建前提。步骤一：创建目标服务资源在对象存储OSS控制台...

创建Elasticsearch Sink Connector

本文介绍如何创建Elasticsearch Sink Connector，您可以通过Elasticsearch Sink Connector将数据从云消息队列 Kafka 版实例的数据源Topic导出至阿里云Elasticsearch中。前提条件详细步骤，请参见创建前提。步骤一：创建目标服务资源在...

创建AnalyticDB Sink Connector

本文介绍如何创建使用AnalyticDB Sink Connector，您可通过AnalyticDB Sink Connector将数据从云消息队列 Kafka 版实例的数据源Topic导出至AnalyticDB的表中。前提条件详细步骤，请参见创建前提。步骤一：创建目标服务资源创建云原生...

创建MaxCompute Sink Connector

本文介绍如何创建使用MaxCompute Sink Connector，您可以通过MaxCompute Sink Connector将数据从云消息队列 Kafka 版实例的数据源Topic导出至MaxCompute的表中。前提条件详细步骤，请参见创建前提。注意事项如需使用MaxCompute分区...

消费者分类

如何实现并发消费：消费者如何使用并发的多线程机制处理消息，以此提高消息处理效率？如何实现同步、异步消息处理：对于不同的集成场景，消费者获取消息后可能会将消息异步分发到业务逻辑中处理，此时，消息异步化处理如何实现？如何实现...

配置自动调优

说明对于消息队列类产品（例如Kafka，MQ，SLS等），自动调优并发的调整会受到分区数的影响，无法超过该上限。即如果您设置的并发度最大值超过其分区数，系统将自动调整并发度为分区数。parallelism.scale.min：并发度向下调整时，最小并发...

产品优势

数万级Topic：支持数万级Topic高并发读写，始终保持云消息队列 Kafka 版集群的高吞吐能力。高SLA保障支持灰度升级、升级/拖冷数据等极端场景写优化保障。全自动巡检运维体系保障，服务可用性达99.9%，数据可靠性达99.999999%。数据安全 ...

事务消息

基于普通消息方案：一致性保障困难将上述基于XA事务的方案进行简化，将订单系统变更作为本地事务，剩下的系统变更作为普通消息的下游来执行，事务分支简化成普通消息+订单表事务，充分利用消息异步化的能力缩短链路，提高并发度。...

流式数据通道概述

流式存储服务（DataHub、Kafka）实时同步MaxCompute 消息服务实时同步MaxCompute解除并发数及 batch size 的限制。解决消息服务实时同步到MaxCompute的问题，支持高并发、大批量同步。使用限制 MaxCompute流式数据通道服务的使用限制如下：...

NLB助力EMQ构建高性能企业级MQTT物联网接入平台

EMQ基于NLB网络型负载均衡打造了大规模分布式物联网MQTT消息服务器EMQX，实现峰值并发达到一个亿，这意味着只需要购买一个NLB实例，EMQX可以一直扩展到满足亿级设备的并发管理，实现业务的平滑扩张。客户价值高性能：超高性能、自动弹性，...

CreateQueue

属性列表如下：参数名称类型是否必选示例值描述 DelaySeconds Integer 否 0 发送到该Queue的所有消息的延迟时间，发送到队列的消息经过此参数设定的延时时间后，才能被消费。取值范围：0~604800，单位为秒。默认值：0。...

同步 OceanBase 数据库的数据至 RocketMQ

背景信息消息队列 RocketMQ 是阿里云基于 Apache RocketMQ 构建的低延迟、高并发、高可靠的分布式消息中间件。数据传输的数据同步功能可以帮助您实现 OceanBase 数据库的物理表和 RocketMQ 数据源之间的数据实时同步，扩展消息处理能力。...

云消息队列 Kafka 版

本文介绍如何在云消息队列 RabbitMQ 版控制台创建消息流入任务，将云消息队列 Kafka 版中的数据快速导入云消息队列 RabbitMQ 版。前提条件您已购买云消息队列 RabbitMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源...

消息队列Kafka版

本文介绍如何在云消息队列 RocketMQ 版控制台创建流入源为云消息队列 Kafka 版的消息流入任务。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。您已购买并部署云消息队列 Kafka...

云消息队列 Kafka 版

本文介绍如何在云消息队列 RocketMQ 版控制台创建消息流入任务，实现将云消息队列 Kafka 版中的数据快速导入至云消息队列 RocketMQ 版。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见 ...

创建MNS Sink Connector

本文介绍如何在云消息队列 Kafka 版控制台创建消息流出任务，将云消息队列 Kafka 版的数据导出至消息服务。前提条件您已购买并部署云消息队列 Kafka 版实例，且实例处于服务中状态。具体步骤，请参见步骤二：购买和部署实例。您...

创建Kafka Sink Connector

本文介绍如何在云消息队列 Kafka 版控制台创建消息流出任务，将指定云消息队列 Kafka 版实例中的数据导出至其他的云消息队列 Kafka 版。前提条件您已购买并部署云消息队列 Kafka 版实例，且实例处于服务中状态。具体步骤，请参见...

消息并发

新品推荐