消息队列 MQ
MQ 产品生态丰富,多个子产品线联合打造金融级高可用消息服务以及对物联网的原生支持,覆盖金融保险、(新)零售、物联网、移动互联网、传媒泛娱乐、教育、物流、能源、交通等行业。

消息队列RocketMQ

消息队列RocketMQ版(原名开放消息服务,简称ONS)是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式消息中间件。

MQTT与RocketMQ消息结构映射

如上图所示,在微消息队列MQTT版中Topic是多级结构,而消息队列RocketMQ版的Topic仅一级,因此,微消息队列MQTT版中的一级Topic映射到消息队列RocketMQ版的Topic,而二级和三级Topic则映射到消息队列RocketMQ版的消息属性(Properties)...

MQTT与RocketMQ消息结构映射

如上图所示,在微消息队列MQTT版中Topic是多级结构,而消息队列RocketMQ版的Topic仅一级,因此,微消息队列MQTT版中的一级Topic映射到消息队列RocketMQ版的Topic,而子级Topic,包括二级、三级、n级Topic则映射到消息队列RocketMQ版的...

阿里云高校特惠,助力学生创业梦!0元体验,快速入门云计算!

建个炫酷的简历网页,制作一个浪漫的表白网页,打造个人专属网盘,多种动手场景应用免费学!!!
广告

消息队列RocketMQ消息Body的长度限制是多少?

消息队列RocketMQ消息Body的长度根据消息类型来限制。消息大小根据消息类型来限制。具体限制如下所述:普通消息和顺序消息:4 MB。事务消息和定时和延时消息:64 KB。

RocketMQ事务型消息

事务型消息的原理事务型消息有下列三个关键内容:本地事务的状态本地事务的执行状态,一共有以下三种:事务提交:LocalTransactionState.COMMIT_MESSAGE。事务回滚:LocalTransactionState.ROLLBACK_MESSAGE。事务未决:...
来自: 首页

Demo工程

SSL加密示例 mqtt.ssl.demo.java MQTT发送消息RocketMQ订阅消息示例 mqtt.to.rocketmq.demo.java RocketMQ发送消息MQTT订阅消息示例 rocketmq.to.mqtt.demo.java MQTT发送顺序消息RocketMQ订阅顺序消息示例 mqtt.ordered.msg.demo.java ...

Demo工程

SSL加密示例 mqtt.ssl.demo.java MQTT发送消息RocketMQ订阅消息示例 mqtt.to.rocketmq.demo.java RocketMQ发送消息MQTT订阅消息示例 rocketmq.to.mqtt.demo.java MQTT发送顺序消息RocketMQ订阅顺序消息示例 mqtt.ordered.msg.demo.java ...

在线迁移 RocketMQ

本文介绍如何将自建 RocketMQ 应用迁移到阿里云消息队列 RocketMQ 版。场景描述适用于企业自建 RocketMQ 应用迁移到阿里云消息队列 RocketMQ 版,迁移后将能利用云 RocketMQ 高可用、高弹性、低延时的能力的场景。解决的问题 自建 RocketMQ...
来自: 首页 >中间件

跨云产品数据流入

您可通过配置微消息队列MQTT版的数据流入规则来自定义数据从其他阿里云产品流入到微消息队列MQTT版。本文介绍跨产品数据流入的原理、应用场景、使用限制以及微消息队列MQTT版与其他阿里云产品的资源映射关系。基本原理如需将其他阿里云产品...

跨云产品的数据流出

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

Topic 地域化

Topic 仅一级,因此,微消息队列 MQTT 版中的一级 Topic 映射到消息队列 RocketMQ 版的 Topic,而二级和三级 Topic 则映射到消息队列 RocketMQ 版的消息属性(Properties)中。多级子 Topic 无需创建,直接在代码中使用即可。更多信息请...

功能与特性概述

消息类型 普通消息消息队列RocketMQ版中无特性的消息,区别于特性的定时和延时消息、顺序消息和事务消息。事务消息:实现类似X/Open XA的分布事务功能,以达到事务最终一致性状态。定时和延时消息:允许消息生产者对指定消息进行定时...

消息收发流程变更

由于微消息队列MQTT版V2.x.x和V3.x.x相比,V3.x.x实现了独立存储,对消息队列RocketMQ版没有强依赖,因此消息收发流程相应的变更。微消息队列MQTT版V2.x.x版本强依赖消息队列RocketMQ版作为消息存储,因此微消息队列MQTT版消息消息队列...

概述

您可获取社区版TCP协议的SDK,来访问阿里云消息队列RocketMQ版。注意 所有社区版的SDK均由Apache RocketMQ社区提供,您可获取源码自行编译,但不在阿里云RocketMQ的SLA范围。和社区版SDK相比,商业版的SDK提供了更加丰富的功能特性并具有更...

RocketMQ应用迁移云RocketMQ最佳实践

直达最佳实践点击查看最佳实践详情更多最佳实践点击查看更多最佳实践场景描述本文档适用于企业自建RocketMQ应用迁移到阿里云消息队列RocketMQ版,迁移...解决问题自建RocketMQ消息集群迁移到云RocketMQ迁移中实现应用不停机的切换过程方案架构

计费常见问题

长轮询API调用次数长轮询说明:消息队列RocketMQ版Consumer为保证消息实时推送而产生的API调用,每个队列15秒一次长轮询,在此期间,若队列内有消息产生,则不计长轮询次数。我该如何为我的消息队列RocketMQ版企业铂金版实例续费?续费的...

适用场景

本文为您介绍消息队列RocketMQ版的适用场景,以便您更好地判断如何在业务中使用消息队列RocketMQ版。例如,针对一家互联网电商企业,其业务涉及广泛,如注册、订单、库存、物流等;同时,也会涉及许多业务峰值时刻,如秒杀活动、周年庆、...

资源使用变更

消息队列MQTT版从V2.x.x升级至V3.x.x实现了自身数据存储的能力,同时还去除了对消息队列RocketMQ版的消息依赖,因此,微消息队列MQTT版的实例和Topic使用变更。资源V2.x.x使用说明V3.x.x使用说明 微消息队列MQTT版实例V2.x.x版本微消息...

消息队列RocketMQ版是否可以在公网访问?

消息队列RocketMQ版支持通过公网访问。消息队列RocketMQ版专门开辟了公网地域(Region)。在消息队列RocketMQ版的控制台创建实例、Topic以及Group ID时,地域选择公网,客户端则可通过消息队列RocketMQ版的TCP或HTTP协议客户端公网接入点...

消息队列RocketMQ版的消息查询中无法找到历史查询记录

问题描述消息队列RocketMQ版的消息查询中无法找到历史查询记录。问题原因为了防止历史查询记录太多,影响展示效果,消息队列RocketMQ版会对用户的历史查询记录进行定期清理,默认只保留7天内的查询记录。解决方案如果历史查询记录消失了,...

名词解释

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

收发事务消息

本文提供使用TCP协议下的社区版Java SDK收发事务消息的示例代码供您参考。交互流程事务消息交互流程如下图所示。更多信息,请参见事务消息。前提条件您已完成以下操作:下载4.5.2或以上版本的社区版Java SDK。准备工作。发送事务消息发送...

数据转发到消息队列RocketMQ

您可以使用规则引擎,将物联网平台数据转发到消息队列(RocketMQ)中存储。从而实现消息从设备、物联网平台、RocketMQ到应用服务器之间的全链路高可靠传输能力。前提条件 已创建消息队列(RocketMQ)实例和用于接收数据的Topic。RocketMQ...

消息负载均衡策略

消息队列RocketMQ版的消息负载策略针对发布方和订阅方有所差异。对订阅方而言,消息负载策略在一定程度上影响消息堆积。发布方消息负载均衡策略消息队列RocketMQ版针对发布方采取的是轮询制,即Producer的消息以轮询的方式发送至Queue,如...

死信队列

背景信息当一条消息初次消费失败,消息队列RocketMQ版会自动进行消息重试,达到最大重试次数后,若消费依然失败,则表明消费者在正常情况下无法正确地消费该消息。此时,消息队列RocketMQ版不会立刻将消息丢弃,而是将其发送到该消费者对应...

上下线通知规则管理

消息队列MQTT版和消息队列RocketMQ版的消息结构映射详情请参见MQTT和RocketMQ消息结构映射。编辑上下线通知规则 在左侧导航栏,单击规则管理。在规则列表,找到您想编辑的上下线通知规则,并在其操作列,单击详情。在规则的详情页面的...

RocketMQ接入点变更导致实时计算作业适配升级公告

消息队列RocketMQ接入点地域化变更,如果您的实时计算作业使用了RocketMQ Connector,您需要在2021年11月之前升级您的实时计算作业至Blink3.7.10或VVR 3.0.1及以上版本,并将作业中EndPoint参数取值更改为新的RocketMQ接入点,旧的...

概述

本文介绍使用社区版TCP协议的Java SDK访问阿里云消息队列RocketMQ版来收发消息的流程。使用说明社区版SDK仅在开源RocketMQ迁移上云且不希望修改代码时使用,其他场景推荐您使用阿里云消息队列RocketMQ版提供的商业版SDK进行接入。和社区版...

MQTT与RocketMQ的应用场景对比

背景信息传统的消息中间件,例如消息队列RocketMQ版、消息队列Kafka版等都是面向微服务大数据等领域,负责消息的存储和转发,消息的生产者和消费者都是服务端应用。这种设计很适合服务端技术栈固定、语言平台固定的场景。而移动互联网和IoT...

出账与欠费说明

消息队列RocketMQ版的计费出账和欠费释放根据支付方式有所不同,本文介绍标准版实例(按量付费)与企业铂金版实例(包年包月)的出账与欠费说明。标准版实例(按量付费)的出账与欠费说明 说明 以下说明同样适用于资源包。消息队列RocketMQ...

收发普通消息(三种方式)

阿里云消息队列RocketMQ版提供三种方式来发送普通消息:同步发送、异步发送和单向(Oneway)发送。本文介绍了每种发送方式的原理、使用场景、示例代码,以及三种发送方式的对比;此外还提供了订阅普通消息的示例代码。前提条件您已完成以下...

MQTT与RocketMQ的应用场景对比

本文介绍微消息队列MQTT版和传统消息中间件,例如消息队列RocketMQ版的关联和区别,并针对实际应用场景下的产品选型给出建议。背景信息传统的消息中间件,例如消息队列RocketMQ版、消息队列Kafka版等都是面向微服务大数据等领域,负责消息...

消息队列RocketMQ消息轨迹没有显示消费信息

概述用户使用消息队列RocketMQ版消费了消息,但消息轨迹却显示没有消费,而且客户端IP地址和Producer不符合实际情况。详细信息出现该现象是由于客户端SDK版本没有升级到支持轨迹功能的版本,因此消息队列RocketMQ版轨迹查询后端只能获取到...

消息收发功能

JavaScript mqtt.demo.javascript 6.MQTT发送消息RocketMQ订阅消息示例 有的语言暂未有Demo,后续会陆续补齐。请先下载相应语言的SDK参照Java示例自行测试。详细信息,请参见SDK下载。语言 下载地址 Java mqtt.demo.java 7.RocketMQ发送...

开通消息队列服务并授权

在阿里云官方网站开通消息队列服务后方可开始使用消息队列RocketMQ版。如果您的账号为RAM用户,必须先为RAM用户进行授权,才能通过控制台或API访问相应的消息队列RocketMQ版资源,并使用资源通过SDK收发消息。前提条件您已注册阿里云账号并...

开通消息队列服务并授权

在阿里云官方网站开通消息队列服务后方可开始使用消息队列RocketMQ版。如果您的账号为RAM用户,必须先为RAM用户进行授权,才能通过控制台或API访问相应的消息队列RocketMQ版资源,并使用资源通过SDK收发消息。前提条件您已注册阿里云账号并...

应急预案:如何关闭RocketMQ消息轨迹

1.概述本文主要介绍在专有云环境中,如何关闭RocketMQ消息轨迹。1.1. 适用范围专有云V2企业版,RocketMQ专有云V3企业版,RocketMQ1.2. 用户告知适用平台:x86、ARM授权级别:L2(二线技术支持工程师)临时或固化方案:固化操作复杂度:中...
来自: 首页

什么是消息队列RocketMQ版?

消息队列RocketMQ版是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式消息中间件。消息队列RocketMQ版既可为分布式应用系统提供异步解耦和削峰填谷的能力,同时也具备互联网应用所需的海量消息堆积、高吞吐、可靠...

事务消息

与其他类型的消息不同,事务消息有回查机制,回查时消息队列RocketMQ版服务端会根据Group ID去查询客户端。通过ONSFactory.createTransactionProducer创建事务消息的Producer时必须指定LocalTransactionChecker的实现类,处理异常情况下...

获取SDK

本文介绍消息队列RocketMQ版API各语言SDK的下载地址。SDK下载消息队列RocketMQ版的API的SDK支持以下6种语言,各语言对应的SDK下载地址如下表所示。语言 下载地址 Java Alibaba Cloud RocketMQ SDK for Java Python Alibaba Cloud RocketMQ ...
< 1 2 3 4 ... 15 >
共有15页 跳转至: GO
产品推荐
消息队列MQ 移动测试 消息服务 云服务器 物联网无线连接服务 商标 SSL证书
这些文档可能帮助您
快速入门概述 新建/导入参数 移动测试-NoClassDefFoundError 主题使用手册 什么是消息服务MNS 管理测试任务

新品推荐

你可能感兴趣

热门推荐

切换为移动版

新人福利专场 阿里云试用中心 企业支持计划 飞天会员助力企业低成本上云 智能财税30天免费试用 云解析DNS新用户首购低至36元/年起 ECS限时升级特惠6.5折
消息队列 MQ
MQ 产品生态丰富,多个子产品线联合打造金融级高可用消息服务以及对物联网的原生支持,覆盖金融保险、(新)零售、物联网、移动互联网、传媒泛娱乐、教育、物流、能源、交通等行业。