收发普通消息

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

调用SDK收发消息

userName MjoxODgwNzcwODY5MD*在消息队列RabbitMQ版控制台将阿里云账号或RAM用户的AccessKey ID、AccessKey Secret和消息队列RabbitMQ版实例ID通过Base64编码后生成的静态用户名。您可以在消息队列RabbitMQ版控制台的静态用户名密码页面...

正式商用公告

如果您有共享服务需求,可考虑阿里消息队列RocketMQ或消息服务MNS提供的按量付费共享服务。公测期间在所有地域(包括公网)创建的共享实例在2019年4月1日开始下线,于2019年5月底完成,届时共享实例将停止服务。请及时购买商用实例并迁移...

概述

本文主要介绍如何使用开源社区发布的rocketmq-client-cpp二进制包进行部署和连接阿里消息队列RocketMQ版的过程。如需源码编译,请您自行前往开源社区下载。使用说明 社区版SDK仅在开源RocketMQ迁移上云且不希望修改代码时使用,其他场景...

否定应答并重入队列

本文说明Consumer如何否定应答消息并使其重入队列。Consumer否定应答单条消息并使其重入队列 basicReject方法可以否定应答一条消息。您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。basicReject方法的参数说明如下...

评估规格

本文说明如何使用消息队列Kafka版的规格评估功能为迁移上云的自建Kafka集群选择合适的实例规格。前提条件 注册阿里云账号并完成实名认证。详情请参见注册阿里云账号。评估规格 说明 消息队列Kafka版的规格评估功能遵循最小原则,即在满足...

RAM鉴权

消息队列MQTT版权限管理是通过阿里云的访问控制RAM(Resource Access Management)产品实现的。使用RAM可以让您避免与其他用户共享云账号密钥,即AccessKey(包含AccessKeyId和AccessKeySecret),按需为用户分配最小权限。在使用RAM账号...

JMS概述

消息队列RabbitMQ版提供JMS库供JMS客户端接入消息队列RabbitMQ版。本文介绍消息队列RabbitMQ版JMS库的相关概念、获取方式、使用限制和使用教程。背景信息 JMS是一种消息传递标准,允许基于Java EE(Java平台企业版)的应用程序组件创建、...

事务消息

本文介绍消息队列RocketMQ版事务消息的概念、优势、典型场景、交互流程以及使用过程中的注意事项。概念介绍 事务消息:消息队列RocketMQ版提供类似XA或Open XA的分布式事务功能,通过消息队列RocketMQ版事务消息能达到分布式事务的最终一致...

队列模型名词解释

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

收发事务消息

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

快速使用MQTT.fx模拟SDK收发消息

本文以Windows系统为例,介绍如何使用MQTT.fx模拟SDK接入微消息队列MQTT版并进行消息收发。前提条件 下载并安装MQTT.fx v1.7.1。背景信息 微消息队列MQTT版最简单的使用场景即MQTT客户端消息的自发自收。如下图所示,您可以使用MQTT.fx作为...

全球消息路由

阿里服务授权-从消息队列RabbitMQ版读取消息对话框,认真阅读提示信息,单击确认。首次创建全球消息路由任务,将自动创建服务的关联角色AliyunServiceRoleForEventBridgeSourceRabbitMQ与...

使用限制

本文为您介绍微消息队列MQTT版对某些具体指标的约束和规范,以便您在使用消息队列MQTT版时不要超过相应的限制值,以免程序出现异常。具体的限制项和限制值请参见下表。如果您购买了企业铂金版的微消息队列MQTT版,则可按需定制部分指标...

产品架构

本文介绍消息队列RocketMQ版的系统部署架构,方便您更好地理解消息队列RocketMQ版的高可用性。消息队列RocketMQ版在任何一个环境都是可扩展的,生产者必须是一个集群,消息服务器必须是一个集群,消费者也同样。集群级别的高可用,是消息...

收发顺序消息

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

参数说明

本文介绍您在使用社区版Java SDK接入阿里消息队列RocketMQ版时,需要配置的参数。通用参数 参数名 参数说明 NAMESRV_ADDR 设置TCP协议接入点,从消息队列RocketMQ版控制台的实例详情页面获取。AccessKey 您在阿里云账号管理控制台中创建...

收发普通消息

普通消息是指消息队列RocketMQ版中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用TCP协议下的.NET SDK收发普通消息的示例代码。前提条件 您已完成以下操作:下载.NET SDK。更多信息,请参见版本说明。环境...

常见问题

详细信息 常见问题如下:购买预付费(包年包月)实例后产生额外费用的原因 收到短信告警提示“使用非法的Group ID”短信告警提示离线消息存储数量超过系统限制 连接微消息队列MQTT版的服务端时异常断开 之前订阅过的Topic仍然在推送消息 ...

删除静态用户名密码

操作步骤 登录消息队列RabbitMQ版控制台。在概览页面的资源分布区域,选择地域。在实例列表页面,单击目标实例名称。在左侧导航栏,单击静态用户名密码。在静态用户名密码页面,找到要删除的静态用户名密码,在其右侧操作列,单击删除。在...

创建OSS Sink Connector

本文介绍如何创建OSS Sink Connector将数据从消息队列Kafka版实例的数据源Topic导出至对象存储OSS。前提条件 在导出数据前,请确保您已完成以下操作:为消息队列Kafka版实例开启Connector。更多信息,请参见开启Connector。为消息队列Kafka...

消息队列Kafka版服务等级协议

消息队列Kafka版规定了阿里云向客户提供的阿里消息队列Kafka版的服务可用性等级指标及赔偿方案。如需查看消息队列Kafka版的服务可用性等级指标及赔偿方案,请参见消息队列Kafka版服务等级协议。icmsDocProps={'productMethod':'created',...

新功能发布记录

本文介绍了微消息队列MQTT版每次发布涉及的新增功能、功能优化、重要问题修复及对应的文档,帮助您了解微消息队列MQTT版的发布动态。2021-05-27 功能名称 功能描述 功能类型 相关文档 轨迹查询接口 支持查询微消息队列MQTT版客户端的设备...

权限策略

消息队列MQTT版权限管理是通过阿里云的访问控制RAM(Resource Access Management)实现的。使用RAM可以让您避免与其他用户共享云账号密钥,即AccessKey(包含AccessKey ID和AccessKey Secret),按需为用户分配最小权限。本文介绍微消息...

使用限制

本文为您介绍微消息队列MQTT版对某些具体指标的约束和规范,您在使用消息队列MQTT版时请不要超过相应的限制值,以免程序出现异常。具体的限制项和限制值请参见下表。如果您购买了铂金版的微消息队列MQTT版实例,则可按需定制部分指标(下...

创建Elasticsearch Sink Connector

当您需要将数据从消息队列Kafka版实例的数据源Topic导出至阿里云Elasticsearch的索引,您可以通过Elasticsearch Sink Connector实现。本文介绍如何创建Elasticsearch Sink Connector。前提条件 在导出数据前,请确保您已完成以下操作:消息...

消息重试

消息队列RocketMQ版支持消息重试功能,即Consumer消费某条消息失败后,消息队列RocketMQ版会根据消息重试机制重新投递消息。TCP协议和HTTP协议的重试机制有所差异,本文介绍消息队列RocketMQ版分别在HTTP协议和TCP协议下的消息重试机制和...

步骤三:创建资源

使用消息队列Kafka版进行消息收发之前,您需要先在消息队列Kafka版控制台上创建资源,否则将无法通过鉴权认证及使用相关的管控运维功能。这里的资源概念是指Topic和Group。前提条件 您已根据网络环境购买并部署消息队列Kafka版服务:VPC...

收发延时消息

背景信息 延时消息用于指定消息发送到消息队列RocketMQ版的服务端后,延时一段时间才被投递到客户端进行消费(例如3秒后才被消费),适用于解决一些消息生产和消费有时间窗口要求的场景,或者通过消息触发延迟任务的场景,类似于延迟队列。...

什么是消息队列RocketMQ版?

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

云上迁移Group

本文介绍如何使用消息队列Kafka版提供的迁移工具将某个消息队列Kafka版实例的Group迁移到另一个消息队列Kafka版实例。前提条件 您已完成以下操作:下载JDK 8 下载迁移工具JAR文件 注意 迁移不会删除源消息队列Kafka版实例的Group,只是在...

计费概述

规格类型 说明 消息队列RabbitMQ版不再支持开通新的普通版实例,已有的普通版实例可以继续使用消息队列RabbitMQ版提供的规格类型如下所示:专业版:共享实例(逻辑隔离),集群服务高可用,数据持久化三副本。铂金版:专享实例(独占物理...

快速使用MQTT的Java SDK收发消息(客户端上下线通知)

因为一般而言,涉及部署在云端服务器上的应用的场景,建议使用服务端消息产品例如消息队列RocketMQ版实现。注意 客户端使用接入点连接服务时务必使用域名接入,不得直接使用域名背后的IP地址直接连接,因为IP地址随时会变化。在以下使用...

开源SDK接入指南(主账号与RAM账号场景)

注意 您的客户端在调用SDK收发消息时,请尽可能使用长期存活的Connection,以免每次收发消息时都需要创建新的Connection,消耗大量的网络资源和服务端资源,甚至引起服务端SYN Flood防护。更多信息,请参见Connection。收发消息流程(以...

实例操作

本文介绍如何对微消息队列MQTT版的实例进行续费、变配及运维管理。实例续费和实例变配只适用于包年包月(预付费)类型的实例,不适用于按量付费(后付费)的实例。实例续费 微消息队列MQTT版的包年包月实例到期之前7天会按照账号给对应的...

创建资源

如果您需要通过公网(例如在本地非阿里云ECS服务器)使用消息队列RocketMQ版服务,请将Topic和Group ID都创建在公网地域下的实例中。生产端和消费端可以部署在本地或者部署在任意地域的ECS上,前提是本地服务器或者相应的ECS能够访问公网。...

开源SDK接入指南(RAM角色跨账号授权场景)

前提条件 开通消息队列RabbitMQ版 创建实例 创建Vhost 背景信息 当您需要通过RAM STS角色授权的方式访问消息队列RabbitMQ版服务时,需要通过阿里云提供的权限认证类(AliyunCredentialsProvider)设置 AccessKeyID、AccessKeySecret与...

创建MySQL Source Connector

本文介绍如何创建MySQL Source Connector,通过DataWorks将数据从阿里云数据库RDS MySQL版导出至消息队列Kafka版实例的Topic。前提条件 在导出数据前,请确保您已完成以下操作:为消息队列Kafka版实例开启Connector。更多信息,请参见开启...

收发定时消息和延时消息

消息在发送到阿里消息队列RocketMQ版服务端后并不会立马投递,而是根据消息中的属性延迟固定时间后才投递给消费者。更多信息,请参见定时和延时消息。注意 社区版的Apache RocketMQ支持延时消息,但不支持定时消息,因此没有专门的定时...

实例管理

本文介绍如何消息队列RocketMQ版控制台上创建、删除、更新和查询实例。背景信息 实例是用于消息队列RocketMQ版服务的虚拟机资源,会存储消息主题(Topic)和客户端ID(Group ID)信息。消息队列RocketMQ版实例按照规格分为标准版和企业...
< 1 2 3 4 ... 200 >
跳转至: GO

新品推荐

你可能感兴趣

热门推荐

新人福利专场 阿里云试用中心 企业支持计划 飞天会员助力企业低成本上云 智能财税30天免费试用 云解析DNS新用户首购低至36元/年起 ECS限时升级特惠6.5折