基本概念

本文主要消息队列 RocketMQ 版 涉及的专有名词及术语进行定义和解析,方便您更好地理解相关概念并使用 云消息队列 RocketMQ 版。Topic 消息主题,一级消息类型,通过Topic消息进行分类。更多信息,请参见 Topic与Tag最佳实践。消息...

普通消息

普通消息为 云消息队列 RocketMQ 版 中最基础的消息,区别于有特性的顺序消息、定时/延时消息和事务消息。本文为您介绍普通消息的应用场景、功能原理、使用方法和使用建议。应用场景 普通消息一般应用于微服务解耦、事件驱动、数据集成等...

RocketMQ全链路追踪解决方案

链路追踪功能可在多个服务进行交互时记录请求在系统的传输过程,并提供详细的日志和性能数据,云消息队列 RocketMQ 版 支持将符合OpenTelemetry标准的Trace数据集成至阿里云的链路追踪服务中,帮助您快速诊断异常问题。Trace定义 云消息...

主题模型基本概念

本文 消息服务MNS 的主题模型涉及的专有名词及术语进行定义和解析,方便您更好地理解相关概念并使用主题模型。主题(Topic)发布消息的目标和存储地址。Account 用户的阿里云账号ID。发布者(Publisher)消息发布者,往主题发布消息的...

接入点对比

消息队列 Kafka 版 提供默认接入点、SSL接入点和SASL接入点以适用不同的连接及安全需求。默认接入点适用于在保密性较高的VPC环境收发消息;SASL接入点适用于无需传输链路加密但需消息收发鉴权;需要链路加密和消息鉴权,建议使用SSL...

基本概念

本文介绍 云消息队列 RocketMQ 版 的基本概念,以便您更好地理解和使用 云消息队列 RocketMQ 版。主题(Topic)云消息队列 RocketMQ 版 中消息传输和存储的顶层容器,用于标识同一类业务逻辑的消息。主题通过TopicName来做唯一标识和区分。...

迁移上云概述

和开源Apache RocketMQ相比,阿里云 云消息队列 RocketMQ 版 具有更高的稳定性、安全性及更完善的运维体系。您可以将开源RocketMQ集群迁移到 云消息队列 RocketMQ 版 上以获得更好的业务体验,本文为您介绍开源RocketMQ集群迁移上云的方案...

收发定时消息

Message msg(/Message Topic factoryInfo.getPublishTopics(),/Message Tag,可理解为Gmail中的标签,消息进行再归类,方便Consumer指定过滤条件在消息队列RocketMQ版的服务器过滤"TagA",/Message Body,不能为空,消息队列RocketMQ版不...

收发事务消息

Message msg(/Message Topic factoryInfo.getPublishTopics(),/Message Tag,可理解为Gmail中的标签,消息进行再归类,方便Consumer指定过滤条件在消息队列RocketMQ版的服务器过滤。TagA",/Message Body,不能为空,消息队列RocketMQ版...

常见问题

什么是Account ID MNS不同地域的接入地址 MNS提供哪些可用的操作 主题订阅的使用限制 MNS是否支持长轮询 MNS是否提供消息的先入先出(FIFO)访问 MNS是否可以与其他阿里云产品协作使用 MNS相对于自主研发、商用或开源的消息队列系统有...

顺序消息

什么是顺序消息 顺序消息是 云消息队列 RocketMQ 版 提供的一种消息发送和消费顺序有严格要求的消息。对于一个指定的Topic,消息严格按照先进先出(FIFO)的原则进行消息发布和消费,即先发布的消息先消费,后发布的消息后消费。顺序消息...

定时/延时消息

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

集成概述

概念介绍—消息流出(Sink)消息流出的主要能力是将 云消息队列 Kafka 版 的数据流出到各类数据目标,Connector生态集成模块消息队列 Kafka 版 的消息进行可靠分发,同时在分发时消息数据进行清洗和过滤。概念介绍—数据处理...

实例化支持

在2019年01月23日,云消息队列 RocketMQ 版 优化了资源隔离、资源申请、协议支持以及权限管理。本文提供相关更新说明,帮助您更顺畅地使用 云消息队列 RocketMQ 版。说明 为兼容新老资源配置,建议您将ons-client客户端升级到最新版本。...

创建资源

在调用TCP协议的SDK收发消息前,您需在 云消息队列 RocketMQ 版 控制台创建相关资源。您在调用SDK时需填写这些资源信息。前提条件 开通消息队列服务并授权 背景信息 针对TCP和HTTP两种通信协议,云消息队列 RocketMQ 版 分别提供了多语言...

队列模型基本概念

本文 消息服务MNS 的队列模型涉及的专有名词及术语进行定义和解析,方便您更好地理解相关概念并使用队列模型。Account 用户的阿里云账号ID。队列(Queue)消息存储的目的地,分成普通队列和延时队列两类。消息包含数据和属性,可以分成...

创建资源

创建Topic Topic是 云消息队列 RocketMQ 版 里消息的一级归类,例如创建名称为Topic_Trade的Topic来识别交易类消息,消息生产者将消息发送到Topic_Trade,而消息消费者则通过订阅该Topic来获取和消费消息。Topic的使用说明如下:Topic不...

常见问题

本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 消息队列RocketMQ版5.x系列相比4.x系列实例有什么优势?消息队列RocketMQ版5.x系列实例兼容哪些版本客户端?消息队列RocketMQ版支持哪些语言客户端?消息队列...

在线教育视频直播

场景描述 适用于在线教育的视频直播场景,通过阿里云视频直播服务实现移动端的推拉流能力,同时移动端利用 云消息队列 MQTT 版 实现发送和接收消息,在消息转发时利用内容安全服务消息内容进行审核。发送的消息可以存储在表格存储中。...

常见问题

本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 云消息队列 RocketMQ 版5.0系列相比4.0系列实例有什么优势?云消息队列 RocketMQ 版5.0系列实例兼容哪些版本客户端?云消息队列 RocketMQ 版支持哪些语言客户端?云...

消息存储和清理机制

本文为您介绍 云消息队列 RocketMQ 版 中消息的存储机制,包括消息的存储粒度、判断依据及后续处理策略等。背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义,消息按照达到服务器的先后顺序被存储到队列中,理论上每个队列都支持无限...

消息堆积和延迟问题

本文主要介绍 云消息队列 RocketMQ 版 TCP协议的Java客户端使用过程中,经常会出现的消息堆积和消息延迟的问题。通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的主要原因,帮助您可以在业务部署前更好的规划资源和配置,或...

收发事务消息

消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图所示。更多信息,请参见 事务消息。前提条件 下载.NET SDK。更多信息...

收发普通消息

factoryInfo.getPublishTopics(),/Message Tag,可理解为Gmail中的标签,消息进行再归类,方便Consumer指定过滤条件在消息队列RocketMQ版的服务器过滤。TagA",/Message Body,不能为空,消息队列RocketMQ版不做任何干预,需要Producer与...

实例规格

本文介绍 云消息队列 RocketMQ 版 支持的实例类型、不同类型实例的差异、以及各类型实例的规格,包括计算规格、公网带宽以及各管控资源配额等,以便您根据实际业务需求购买合适的实例。实例计费方式 计费方式 说明 适用场景 支持的实例类型...

示例代码

消息队列 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...

主题使用手册

对消息内容做MD5验证。解析推送请求的Body。返回StatusCode:200。由于 http_server_sample.php 的代码较多,请直接查看SDK中的源码。步骤四:创建订阅 在MNS Server创建订阅,主题里面的消息应该推送到哪里。Sample里以HTTP Endpoint为例...

通过可观测性能力进行故障处理最佳实践

本文为您介绍如何将 云消息队列 RocketMQ 版 可观测性功能应用于 云消息队列 RocketMQ 版 的故障管理场景中,为您的日常运维和故障处理提供实践方案。设计思路 核心问题 运维场景下,故障处理的核心问题如下:服务出现异常如何预警并上报 ...

顺序消息

顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息,本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下,异构系统间需要维持强一致的状态同步,...

收发定时消息

发送定时消息 说明 具体的示例代码,请以 云消息队列 RocketMQ 版 代码库 为准。发送定时消息的代码示例如下所示。using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Runtime....

订阅关系(Subscription)

本文介绍 云消息队列 RocketMQ 版 中订阅关系(Subscription)的定义、模型关系、内部属性及使用建议。定义 订阅关系是 云消息队列 RocketMQ 版 系统中消费者获取消息、处理消息的规则和状态配置。订阅关系由消费者分组动态注册到服务端...

消费者分组(ConsumerGroup)

本文介绍 云消息队列 RocketMQ 版 中消费者分组(ConsumerGroup)的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 消费者分组是 云消息队列 RocketMQ 版 系统中承载多个消费行为一致的消费者的负载均衡分组。和消费者...

订阅者最佳实践

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

收发顺序消息

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

原子计数器

原子计数操作只能作用在列值的最新版本,不支持对列值的特定版本做原子计数操作。更新完成后,原子计数操作会插入一个新的数据版本。接口 updateRow接口新增了原子计数器的相关操作,操作说明请参见下表。操作 说明 update_of_attribute_...

发布者最佳实践

本文介绍 云消息队列 Kafka 版 发布者的最佳实践,帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端,其基本概念与思想是相通的,但实现细节可能存在差异。发送消息 发送消息的示例代码如下:Future...

消息过滤

消息队列 RocketMQ 版 的消息过滤功能通过生产者和消费者消息的属性、标签进行定义,并在 云消息队列 RocketMQ 版 服务端根据过滤条件进行筛选匹配,将符合条件的消息投递给消费者进行消费。消息过滤原理 消息过滤主要通过以下几个关键...

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...

主题使用手册

功能 消息服务MNS 推送消息请求做签名验证。解析推送请求的Body。返回StatusCode:200。由于SampleHttpServer的代码较多,请直接查看SDK中的源码。步骤四:创建订阅 在MNS Server中创建订阅,主题里面的消息应该推送到哪里。Sample里...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 Kafka 版 云消息队列 RocketMQ 版 消息服务 云数据库 ClickHouse 全局事务服务 弹性公网IP
新人特惠 爆款特惠 最新活动 免费试用