分布队列双重总线问题处理与维修-分布队列双重总线问题处理与维修文档介绍内容-阿里云

示例代码

云消息队列 RocketMQ 版 5.x版本实例可兼容C++ 1.x/2.x SDK客户端接入，您可以使用1.x/2.x版本的SDK接入5.x实例进行消息收发。本文为您介绍1.x/2.x版本下的C++ SDK消息收发示例代码。重要推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK...

基于IaC自动化部署事件总线

本文介绍如何应用IaC（Infrastructure as Code）理念自动化部署事件总线EventBridge，帮助您解决大量云产品手工管理负担沉重的问题。背景信息 IaC是一种以代码来配置和管理虚拟机、网络等基础设施的实践方法。通过将基础设施代码化、版本...

查看实例风险

云消息队列 Kafka 版实例的实时诊断功能能够定期对实例进行检测，支持查看诊断发现的问题、提供修复建议，并将异常的检查项上报告警给相关联系人，帮助您及时处理异常。实现方案检测项说明若检测出实例存在风险，请参考控制台上提示的...

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

本文介绍如何应用事件总线EventBridge 的事件流功能实现消息服务MNS 的消息路由。前提条件您已开通事件总线EventBridge并授权。您已创建消息服务MNS 队列。具体步骤，请参见开通消息服务MNS并授权。背景信息事件流作为更轻量、实时...

收发普通消息

普通消息是指云消息队列 RocketMQ 版中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。不同消息类型所属的Topic不能混用，例如收发普通消息的Topic不能用来收发其他类型的消息。本文提供使用TCP协议下的C/C++ SDK收发...

音视频通信解决方案（MQTT）

音视频通信解决方案是由阿里云云消息队列 MQTT 版和音视频通信RTC联合推出的有助于快速搭建各种实时通信场景产品，譬如在线音视频会议、1对1语音通话应用的解决方案。本文将详细描述该解决方案的系统架构、数据流设计以及相关注意事项。...

4.x和5.x版本差异及兼容性说明

云消息队列 RocketMQ 版是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云云消息队列 RocketMQ 版将为您提供更加稳定可靠的服务端5...

4.x和5.x版本差异及兼容性说明

云消息队列 RocketMQ 版是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云云消息队列 RocketMQ 版将为您提供更加稳定可靠的服务端5...

收发定时消息

Message Tag，可理解为Gmail中的标签，对消息进行再归类，方便Consumer指定过滤条件在消息队列RocketMQ版的服务器过滤"TagA",/Message Body，不能为空，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反...

一机一密概述

当设备与云消息队列 MQTT 版建立连接时，需要将设备访问凭证中的信息按照约定的形式设置到Username和Password中，向云消息队列 MQTT 版发起认证请求，云消息队列 MQTT 版认证通过后激活设备，设备与云消息队列 MQTT 版间才可传输...

定时/延时消息

定时/延时消息为云消息队列 RocketMQ 版中的高级特性消息，本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景说明定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻...

消息查询

在使用Kafka的过程中遇到无法正确消费消息、消息丢失、消息延迟等消费问题时，您可通过消息查询功能查看指定消息的详细内容和相关属性，帮助您排查异常原因。若确定消息所在Topic的分区ID以及消息位点，可采用按位点查询消息；若不确定消息...

收发顺序消息

顺序消息FIFO（First In First Out）是云消息队列 RocketMQ 版提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的C/C++ SDK收发顺序消息的示例代码。背景信息顺序消息分为两类：全局顺序：对于指定的一个Topic，...

收发定时消息

目前支持的地域包括公网、华东1（杭州）、华北2（北京）、华东2（上海）、华南1（深圳）。定时消息可以做到在指定时间戳之后才可被消费者消费，适用于对...} } } 订阅定时消息定时消息的订阅与普通消息订阅一致，更多信息，请参见订阅消息。

仪表盘

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

收发事务消息

云消息队列 RocketMQ 版提供类似XA或Open XA的分布式事务功能，通过云消息队列 RocketMQ 版事务消息，能达到分布式事务的最终一致。说明对于新手用户，建议在正式收发消息前，阅读 Demo工程来了解搭建云消息队列 RocketMQ 版工程的...

事件驱动架构

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

迁移消费者程序

背景信息云消息队列 Kafka 版控制台提供迁移实例功能，您可以使用该功能将自建Kafka集群或其他云Kafka集群的元数据（Topic和Group配置信息）和消息数据同步到目标集群，迁移完成后目标集群的元数据与源集群的元数据保持一致并且持续更新...

服务关联角色

本文介绍云消息队列 Kafka 版服务关联角色的背景信息、策略内容、注意事项和常见问题。背景信息服务关联角色是某个云服务在某些情况下，为了完成自身的某个功能，需要获取其他云服务的访问权限而提供的RAM角色。您在该云服务的控制台...

在Knative上实现Kafka消息推送

Knative已支持Kafka事件源，您可将Knative与云消息队列 Kafka 版对接，在Knative上实现Kafka消息推送。前提条件部署Knative 购买并部署云消息队列 Kafka 版实例重要云消息队列 Kafka 版实例和Knative必须处于同一VPC内。云消息队列...

Token鉴权概述

云消息队列 MQTT 版通过Token鉴权模式向MQTT客户端提供临时访问权限。您可通过MQTT Token服务来给本地账号系统管理的用户颁发临时的访问凭证，并限制访问权限，以实现对单一客户端、单一资源的细粒度权限控制。本文介绍使用流程以及相关...

Token鉴权概述

云消息队列 MQTT 版通过Token鉴权模式向MQTT客户端提供临时访问权限。您可通过MQTT Token服务来给本地账号系统管理的用户颁发临时的访问凭证，并限制访问权限，以实现对单一客户端、单一资源的细粒度权限控制。本文介绍使用流程以及相关...

管理Kafka自定义连接器

登录云消息队列 Kafka 版控制台，在概览页面的资源分布区域，选择地域。在左侧导航栏，选择 Connector生态集成>消息流入（Source）。在消息流入（Source）页面，单击创建任务。在消息流入创建面板中，完成以下配置，单击确定。...

消息过滤

消费者订阅了某个主题后，云消息队列 RocketMQ 版会将该主题中的所有消息投递给消费者。若消费者只需要关注部分消息，可通过设置过滤条件在云消息队列 RocketMQ 版服务端进行过滤，只获取到需要关注的消息子集，避免接收到大量无效的...

客户端连接常见问题

本文介绍云消息队列 MQTT 版客户端连接服务端时的常见问题。使用安卓的Demo，返回连接失败报错。问题描述资源填写正确，且网络可以连通。AK（AccessKey ID）、SK（AccessKey Secret）填写正确且已授权。可能原因接入点格式不正确，正确...

事件流概述

应用场景流式ETL处理事件流作为更轻量、实时（real-time）端到端的流式事件通道，提供轻量流式数据的过滤和转换的能力，在不同的数据仓库之间、数据处理程序之间、数据分析和处理系统之间进行数据同步，连接不同的系统与服务。...

云服务总线CSB公共云服务下线通知

停止服务后，已有用户可以继续使用当前功能，但购买、续订和扩容将会停止，且无法继续获得产品支持以及问题处理服务。阿里云推荐后续对网关产品有相关诉求的用户可以迁移至MSE云原生网关。给您带来的不便，我们深表歉意。更多内容，请参见 ...

什么是云消息队列 MQTT 版

如果说传统的消息队列中间件一般应用于微服务之间，那么适用于物联网的云消息队列 MQTT 版则实现了端与云之间的消息传递和真正意义上的万物互联。本文介绍云消息队列 MQTT 版的消息收发模型、产品优势和应用场景。核心概念 Topic：消息...

计费FAQ

本文汇总了云消息队列 RabbitMQ 版计费的常见问题。向10个Queue发送同一条消息，为什么收10次API调用费？将1条消息发送给10个Queue，实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费？虽然删除了...

计费FAQ

本文汇总了云消息队列 RabbitMQ 版计费的常见问题。向10个Queue发送同一条消息，为什么收10次API调用费？将1条消息发送给10个Queue，实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费？虽然删除了...

消息堆积

常见的消息堆积相关问题如下：如何处理消息堆积？除了异步解耦功能，消息队列还有挡住前端数据洪峰的重要功能，以此保证后端系统的稳定性。这要求消息队列具有一定的消息堆积能力。消息队列能支持 10 亿级别的消息堆积，不会因为消息堆积...

无法ping通云消息队列 Kafka 版的接入点

当使用接入点连接Kafka连接不通或连接超时（Connection timed out），请检查您使用的是否为Telnet命令，如果连接VPC接入点，还需保证客户端与Kafka在同一VPC下。问题描述无法ping通云消息队列 Kafka 版的接入点。本地客户端无法telnet ...

权益分发

在电商和新零售领域，权益分发适用于对特定的用户进行指定运营活动的场景。技术层面上，此种场景的DB和缓存的数据强一致性较难保证。...更多信息云消息队列 RocketMQ 版的功能与特性详情，请参见以下文档：功能与特性概述消息重试

计费常见问题

本文汇总了云消息队列 RocketMQ 版计费的常见问题。每天扣除2元，这是什么费用？我昨天删除了Topic，为什么今天会收到账单并被扣费？我没有使用云消息队列 RocketMQ 版服务，为什么会扣费？我在控制台上看到没有开通云消息队列 ...

重试和死信

本文介绍事件流支持的重试和死信策略。重试策略重试策略即任务处理过程中出现失败时的重试方式，当前重试策略支持退避重试和指数衰减...说明当前支持将死信发送至云消息队列 RocketMQ 版、消息服务MNS、云消息队列 Kafka 版和事件总线。

跨云产品的数据流出

设备数据上报海量设备通过MQTT协议上报状态数据到云消息队列 MQTT 版，配置数据流出规则将云消息队列 MQTT 版的Topic映射到云消息队列 RocketMQ 版的Topic后，可以直接在后台服务启动云消息队列 RocketMQ 版的消费者消费处理上报...

订阅者最佳实践

本文主要介绍云消息队列 Kafka 版订阅者的最佳实践，帮助您减少消费消息出错的可能性。消费消息基本流程云消息队列 Kafka 版订阅者在订阅消息时的基本流程为：Poll数据→执行消费逻辑→再次Poll数据，详情参见下图。负载均衡每个 ...

产品概述

阿里云流数据处理平台数据总线DataHub是流式数据（Streaming Data）的处理平台，提供对流式数据的发布(Publish)，订阅（Subscribe）和分发功能，让您可以轻松构建基于流式数据的分析和应用。数据总线 DataHub服务可以对各种移动设备，应用...

可观测性体系概述

作为一款典型的分布式中间件产品，云消息队列 RocketMQ 版被广泛应用于业务核心链路中，每条消息都关联着核心业务数据的变化，通过可观测能力及时发现问题、定位问题、解决问题对于业务运行是一项重要的保障能力。本文介绍云消息队列 ...

作为Input接入

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

分布队列双重总线问题处理与维修

新品推荐