分布式队列双总线能干啥-分布式队列双总线能干啥文档介绍内容-阿里云

基本概念

事务消息事务消息是云消息队列 RocketMQ 版提供的一种高级消息类型，支持在分布式场景下保障消息生产和本地事务的最终一致性。定时/延时消息定时/延时消息是云消息队列 RocketMQ 版提供的一种高级消息类型，消息被发送至服务端后，在...

查看订阅关系

对于大多数分布式应用来说，一个Group ID下通常会挂载多个Consumer实例。云消息队列 RocketMQ 版的订阅关系主要由Topic+Tag共同组成，即一个Group ID下所有的Consumer实例订阅的Topic以及这些Topic中的过滤规则Tag。同一个Group ID下所有...

什么是 SOFATracer

SOFATracer 是蚂蚁金服基于 OpenTracing 规范开发的分布式链路跟踪系统，其核心理念就是通过一个全局的 TraceId 将分布在各个服务节点上的同一次请求串联起来。通过统一的 TraceId 将调用链路中的各种网络调用情况以日志的方式记录下来，...

开源MQTT迁移至云消息队列 MQTT 版

云端SDK可用于云端分布式应用部署，天然支持共享订阅，并提供消息收发、消息订阅、客户端上下线事件通知等能力，目前支持Java、Go语言的SDK。更多信息，请参见云端开发概述。云端SDK支持在云消息队列 MQTT 版服务端层面进行订阅发布，而...

JMS概述

JMS使分布式应用能够以松耦合、可靠、异步的方式进行通信。云消息队列 RabbitMQ 版 JMS库支持 JMS 1.1。云消息队列 RabbitMQ 版JMS库云消息队列 RabbitMQ 版 JMS库是云消息队列 RabbitMQ 版提供的JMS接口。JMS应用只需变更少量代码，...

存储引擎对比

在创建Topic时，您可以为云消息队列 Kafka 版选择云存储或Local存储引擎。云存储依托阿里云云盘算法、低延迟、低成本、弹性伸缩能力更好，适用于大多数场景；若有特殊需求，例如Compact、幂等、事务、分区顺序消息等，建议您选择Local...

应用场景

云消息队列 Kafka 版作为数据中转枢纽具备以下优势：高容量存储：能在商业硬件上存储高容量的数据，实现可横向扩展的分布式系统。一对多消费模型：发布/订阅模型，支持同份数据集能同时被消费多次。同时支持实时和批处理：支持本地数据...

步骤三：创建资源

当使用云消息队列 Kafka 版进行消息收发时，您需要在已成功部署的Kafka实例中创建Topic和Group资源。生产者需要将消息发送至指定Topic，消费者通过订阅Topic获取消息进行消费。消费者消费消息时，需要指定Group订阅对应的Topic。Group和...

事件驱动架构

什么是事件驱动架构事件驱动架构是一种松耦合、分布式的驱动架构，收集到某应用产生的事件后实时对事件采取必要的处理后路由至下游系统，无需等待系统响应。使用事件总线EventBridge 可以构建各种简单或复杂的事件驱动架构，以标准化的...

连接查询

说明统计值基于分布式数据采集组件收集，可能存在延迟和误差。按Client ID查询您可以指定Client ID查询客户端的连接信息和订阅关系。登录云消息队列 MQTT 版控制台，在顶部菜单栏选择要查询的地域，例如华东1（杭州）。在左侧导航栏，...

SOFAMQ 常见问题

作为一款分布式消息中间件，在网络抖动、应用处理超时等异常情况下，可以保证消息不丢失，但是无法保证消息不重复。控制台显示的消息堆积量是否包含了 Topic 下所有 Tag 的消息？是。消息生产者将所有类型的 Tag 都发送至同一个 Topic 中，...

产品优势

集群分布式部署，服务节点无状态、无单点。即使单节点不可用，请求将Failover至其他节点保障消息服务正常提供。功能增强延时消息支持延时消息，实现秒级精准，无先入先出限制。简单易用，在代码上只需要设置一个参数即可完成，解决开源...

作为Input接入

云消息队列 Kafka 版可以作为Input接入Filebeat。本文说明如何在VPC环境下通过Filebeat从云消息队列 Kafka 版消费消息。背景信息在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 VPC...

如何快速测试云消息队列 Kafka 版服务端是否正常？

在创建并部署云消息队列 Kafka 版实例后，您可以使用云消息队列 Kafka 版控制台直接发送消息，快速测试服务端是否正常。前提条件您已创建并部署云消息队列 Kafka 版实例，且实例处于服务中状态。操作流程快速测试云消息队列 ...

作为Input接入

云消息队列 Kafka 版可以作为Input接入Logstash。本文说明如何在VPC环境下通过Logstash从云消息队列 Kafka 版消费消息。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 VPC...

使用Spring Cloud框架收发消息

Spring Cloud是用于构建消息驱动的微服务应用程序的框架，提供服务发现、配置管理、消息传递、负载均衡等微服务相关的解决方案，可以更容易地构建分布式系统和进行服务间通信。本文介绍如何使用Spring Cloud框架接入云消息队列 Kafka 版 ...

作为Input接入

云消息队列 Kafka 版可以作为Input接入Filebeat。本文说明如何在公网环境下通过Filebeat从云消息队列 Kafka 版消费消息。背景信息在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 ...

作为Output接入

云消息队列 Kafka 版可以作为Output接入Logstash。本文说明如何在VPC环境下通过Logstash向云消息队列 Kafka 版发送消息。前提条件购买并部署云消息队列 Kafka 版实例。具体操作，请参见 VPC接入。下载并安装Logstash。具体操作，请...

作为Output接入

云消息队列 Kafka 版可以作为Output接入Filebeat。本文说明如何在VPC环境下通过Filebeat向云消息队列 Kafka 版发送消息。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。更多信息，请参见 VPC...

作为Output接入

云消息队列 Kafka 版可以作为Output接入Filebeat。本文说明如何在公网环境下通过Filebeat向云消息队列 Kafka 版发送消息。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 ...

作为Input接入

云消息队列 Kafka 版可以作为Input接入Logstash。本文说明如何在公网环境下通过Logstash从云消息队列 Kafka 版消费消息。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 ...

作为Output接入

云消息队列 Kafka 版可以作为Output接入Logstash。本文说明如何在公网环境下通过Logstash向云消息队列 Kafka 版发送消息。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 ...

集群消费和广播消费

集群消费和广播消费是云消息队列 RocketMQ 版的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息云消息队列 ...

发布者最佳实践

失败重试 分布式环境下，由于网络等原因偶尔发送失败是常见的。导致这种失败的原因可能是消息已经发送成功，但是ACK失败，也有可能是确实没发送成功。云消息队列 Kafka 版是VIP网络架构，长时间不进行通信连接会被主动断开，因此，不是...

RocketMQ全链路追踪解决方案

在分布式应用系统中，多个服务间的交互涉及复杂的网络通信和数据传输，往往一次请求需要多个内部服务间的相互调用才能完成，任何一个环节出现问题都可能导致外部服务任务执行失败或延时，且很难快速定位问题根源。链路追踪功能可在多个服务...

队列（MessageQueue）

常见队列增加场景需要增加队列实现物理节点负载均衡云消息队列 RocketMQ 版每个主题的多个队列可以分布在不同的服务节点上，在集群水平扩容增加节点后，为了保证集群流量的负载均衡，建议在新的服务节点上新增队列，或将旧的队列迁移到...

将云消息队列 Kafka 版的数据迁移至MaxCompute

MaxCompute和DataWorks一起向用户提供完善的数据处理和数仓管理能力，以及SQL、MR、Graph等多种经典的分布式计算模型，能够更快速地解决用户海量数据计算问题，有效降低企业成本，保障数据安全。本教程旨在帮助您使用DataWorks，将云消息...

消费者分类

说明由于服务端存储为分布式，可能会出现服务端实际有消息，但是返回为空的现象。一般可通过重新发起ReceiveMessage调用或提高ReceiveMessage的并发度解决。批量拉取消息数：SimpleConsumer可以一次性批量获取多条消息实现批量消费，该...

路由到云消息队列 RabbitMQ 版

本文介绍如何在事件总线EventBridge 控制台添加云消息队列 RabbitMQ 版作为事件流中的服务类型。前提条件开通事件总线EventBridge并授权。您已购买并部署云消息队列 RabbitMQ 版实例，且实例处于服务中状态。具体步骤，请参见步骤...

路由到云消息队列 Kafka 版

本文介绍如何在事件总线EventBridge 控制台添加云消息队列 Kafka 版作为事件流中的服务类型。前提条件开通事件总线EventBridge并授权。您已购买并部署云消息队列 Kafka 版实例，且实例处于服务中状态。具体步骤，请参见购买和部署...

基于事件流实现RabbitMQ消息路由

本文介绍如何应用事件总线EventBridge 的事件流功能实现云消息队列 RabbitMQ 版的消息路由。前提条件您已开通事件总线EventBridge并授权。您已购买并部署云消息队列 RabbitMQ 版实例，且实例处于服务中状态。具体步骤，请参见 ...

事件分析概述

事件总线EventBridge 支持对发布到事件总线的各种事件进行追踪查询、分析处理和可视化图表展示。本文介绍事件分析的类型、适用场景与优势。背景信息事件总线EventBridge 的实时事件分析平台依托事件的实时处理引擎，提供数值检索、可视化...

生产者负载均衡

生产者发送消息到云消息队列 RocketMQ 版服务端时，云消息队列 RocketMQ 版将根据生产者负载均衡策略将消息均匀的存储在多个队列中，避免产生热点队列和性能瓶颈。本文介绍云消息队列 RocketMQ 版生产者的负载均衡策略。背景信息了解...

仪表盘

借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力，云消息队列 RocketMQ 版提供仪表盘功能。该功能可帮助您一站式、全方位、多维度地统计和观测指标，进而快速了解业务的运行状态。本文介绍仪表盘的应用场景、业务背景...

集成概述

死信队列支持消息服务MNS 和云消息队列 RocketMQ 版等服务做死信队列。支持云消息队列 Kafka 版做死信队列。重试策略统一支持。部分支持。依赖Kafka资源不额外依赖。系统自动或手动创建任务位点Topic、任务配置Topic、任务状态...

云消息队列 Kafka 版

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

升级实例配置

本文介绍如何在云消息队列 Kafka 版控制台完成实例升配，升级的配置项包括规格类型、流量规格、磁盘容量及分区规格等。前提条件实例处于服务中或未部署状态。实例中没有进行中的Topic引流任务。注意事项升级实例配置会引发集群逐台...

基于事件总线EventBridge实现钉钉新增成员信息入库

本文介绍如何使用事件总线EventBridge 集成钉钉连接器，将钉钉上成员信息变更投递到数据库。背景信息钉钉连接平台通过可视化拖拽配置、一键订阅等方式，可以简单高效地实现钉钉、企业内部系统、其他厂商系统与钉钉第三方企业应用之间数据...

云消息队列 RabbitMQ 版

本文介绍如何在云消息队列 RabbitMQ 版控制台创建流入任务，将指定云消息队列 RabbitMQ 版实例中的数据快速导入至另外的云消息队列 RabbitMQ 版实例中。前提条件您已购买云消息队列 RabbitMQ 版实例，且实例处于服务中状态。...

云消息队列RabbitMQ版

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

分布式队列双总线能干啥

新品推荐