先入先出队列无法连接-先入先出队列无法连接文档介绍内容-阿里云

排他队列

其他连接无法声明相同名称的排他队列，且其他连接以及连接下的Channel都无法访问该排他队列。连接断开时排他性队列会被自动删除。即使客户端已声明该排他队列为持久性的（durable 为 true），只要该排他性队列的连接断开，队列会被自动删除...

客户端首次接入云消息队列 Kafka 版时出现异常的排查...

详细信息客户端首次接入云消息队列 Kafka 版时如果出现异常，您可以通过以下三个方面进行排查：网络连通问题：通常有如下几种情况可能会导致网络不通，客户端无法连接云消息队列 Kafka 版的服务端。ECS实例（客户端）与云消息队列 Kafka ...

IP白名单

注意事项将IP地址从IP白名单中删除后，对应的客户端将无法连接指定云消息队列 RocketMQ 版实例，请谨慎操作。配置IP白名单包年包月和按量付费实例操作步骤登录云消息队列 RocketMQ 版控制台，在左侧导航栏单击实例列表。在顶部菜单...

SDK FAQ

您可以使用basicReject方法否定应答单条消息，或者使用basicNack方法否定应答一条或多条消息，并使消息重入队列。使用basicReject方法否定应答消息并使消息重入队列 参数说明 deliveryTag Channel的消息投递的唯一标识符。requeue 被否定...

队列（MessageQueue）

队列的主要作用如下：存储顺序性队列天然具备顺序性，即消息按照进入队列的顺序写入存储，同一队列间的消息天然存在顺序关系，队列头部为最早写入的消息，队列尾部为最新写入的消息。消息在队列中的位置和消息之间的顺序通过位点（Offset...

怎样让Consumer不立即消费消息并使消息重入队列？

您可以通过basicReject或basicNack方法否定应答消息，使消息重入队列，从而是其他Consumer可以消费消息。使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。...

怎样让Consumer不立即消费消息并使消息重入队列？

您可以通过basicReject或basicNack方法否定应答消息，使消息重入队列，从而是其他Consumer可以消费消息。使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。...

接入Filebeat

本文介绍如何将云消息队列 Kafka 版接入Filebeat。Filebeat Filebeat是用于转发和集中日志数据的轻量级传输程序。Filebeat可以监听指定的日志文件或位置，从中收集日志事件并将其转发到Elasticsearch或Logstash进行索引。Filebeat的工作...

访问控制概述

云消息队列 RocketMQ 版支持通过RAM和ACL实现对云消息队列 RocketMQ 版资源的访问控制。使用限制按量付费实例和包年包月实例需要先开启公网访问功能，才支持IP白名单功能。具体操作，请参见实例升降配。按量付费实例和包年包月实例...

接入Logstash

本文介绍如何将云消息队列 Kafka 版接入Logstash。Logstash Logstash是开源的服务器端数据处理管道，能够同时从多个数据源采集数据，然后对数据进行转换，并将数据写入指定的存储中。Logstash的数据处理流程如下：输入：采集各种格式、...

快速入门

如果您是首次使用云消息队列 RocketMQ 版，您可以参考快速入门文档，了解如何购买实例并接入云消息队列 RocketMQ 版服务端完成基本的消息收发流程。使用流程快速使用云消息队列 RocketMQ 版收发消息的流程如下图所示。详细操作，请...

参数说明

客户端通过接入点连接云消息队列 MQTT 版服务端。使用云端SDK接入云消息队列 MQTT 版时，需要填写的接入点格式如下：重要仅实例内核版本为V3.3.0且实例地域属于中国内地的实例支持云端SDK接入。公网接入点：MQTT实例ID-server-...

Connection和Channel

本文介绍云消息队列 RabbitMQ 版中Connection和Channel的概念及其使用建议。Connection Connection是物理TCP连接。Connection将应用与云消息队列 RabbitMQ 版连接在一起。Connection会执行认证、IP解析、路由等底层网络任务。应用与云...

查看接入点

如需使用SDK接入云消息队列 Kafka 版收发消息，您需要根据实例的网络环境类型来配置接入点。本文介绍如何在云消息队列 Kafka 版控制台查看接入点。背景信息云消息队列 Kafka 版提供以下类型的接入点：默认接入点：适用于在VPC环境...

SDK概述

本文介绍云消息队列 Kafka 版 SDK、支持的多语言SDK。SDK简介 SDK（Software Development Kit）即软件开发工具包，包含示例Demo、库文件、编译工具链以及编译脚本等，不需要开发者进行任何其他的配置，直接可以在SDK对应目录环境下，进行...

云端开发概述

云端SDK主要用于云上应用接入云消息队列 MQTT 版，终端SDK主要用于终端设备接入云消息队列 MQTT 版。目前云端SDK支持 Java SDK、Go SDK 以及.NET SDK ，其他语言暂不支持。仅实例版本为V3.3.0且实例地域属于中国内地的实例支持云端SDK接...

步骤二：创建资源

在调用SDK收发消息前，您需要提前创建云消息队列 RocketMQ 版的相关资源，包括创建云消息队列 RocketMQ 版实例、获取实例的接入点、创建Topic、创建ConsumerGroup。调用SDK时，需要将这些资源信息填写到SDK代码中。前提条件创建专有...

接口和参数说明

客户端通过接入点连接云消息队列 MQTT 版服务端。使用云端SDK接入云消息队列 MQTT 版时，需要填写的接入点格式如下：重要仅实例内核版本为V3.3.0且实例地域属于中国内地的实例支持云端SDK接入。公网接入点：MQTT实例ID-server-...

使用须知

例如您的云消息队列 RocketMQ 版实例在华东1（杭州）地域，则只能使用华东1（杭州）地域的接入点来访问该地域的实例。您可以实现以下场景的资源访问：如果您的客户端在华东1（杭州）地域，为了最佳体验，请使用该实例的HTTP内网接入点...

公网流量定价详情

云消息队列 RocketMQ 版提供公网接入点和VPC接入点用于客户端接入云消息队列 RocketMQ 版实例。使用公网接入点接入云消息队列 RocketMQ 版服务时需要收取公网流量费用。本文介绍公网流量费用的计费规则。支持地域仅如下地域支持使用...

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

（RAM用户必选）步骤一：为RAM用户授权若您开通消息队列服务使用的是账号是RAM用户，必须先为RAM用户进行授权，才能访问云消息队列 MQTT 版的资源。若您的账号是阿里云账号，默认拥有使用云消息队列 MQTT 版资源的权限，您可以跳过该...

访问链接与端口

如果需要通过公网接入云消息队列 Confluent 版，您可以为集群开启公网。开启公网登录云消息队列 Kafka 版控制台，在左侧导航栏，单击实例列表。在顶部菜单栏，选择地域，在实例列表页面单击目标实例名称。在左侧导航栏，单击访问...

资源使用变更

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

查看接入点

如需使用客户端连接云消息队列 Kafka 版收发消息，您需要根据客户端的网络环境类型及传输的安全需要来配置接入点。默认接入点适用于在保密性较高的VPC环境收发消息；SASL接入点适用于无需对传输链路加密但需对消息收发鉴权；同时需要链路...

示例代码

客户端通过接入点连接云消息队列 MQTT 版服务端。使用云端SDK接入云消息队列 MQTT 版时，需要填写的接入点格式如下：重要仅实例内核版本为V3.3.0且实例地域属于中国内地的实例支持云端SDK接入。公网接入点：MQTT实例ID-server-...

产品优势

功能增强延时消息支持延时消息，实现秒级精准，无先入先出限制。简单易用，在代码上只需要设置一个参数即可完成，解决开源RabbitMQ无延时队列的痛点。高精度支持，最短可精确到秒级，最长可持续1天。高性能，性能与普通消息一致。多副本...

环境准备（v2.x.x）

本文介绍使用C++ SDK v2.x.x版本接入云消息队列 RocketMQ 版所需完成的准备工作、使用说明以及注意事项，以便后续使用C++ SDK收发消息。重要推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和云消息队列 RocketMQ ...

环境准备（v2.x.x）

本文介绍使用C++ SDK v2.x.x及以上版本接入云消息队列 RocketMQ 版所需完成的准备工作、使用说明以及注意事项，以便后续使用C++ SDK收发消息。使用前，请注意以下几点：本文仅针对C++ SDK v2.x.x及以上版本进行说明，若您需从当前使用的v...

Spring集成

云消息队列 RocketMQ 版支持集成Spring框架的Java SDK收发消息，本文为您介绍如何使用云消息队列 RocketMQ 版提供的Spring框架的Demo工程。背景信息云消息队列 RocketMQ 版支持以下消息类型的生产者和消费者与Spring集成：普通消息的...

概述

使用说明社区版SDK仅在开源RocketMQ迁移上云且不希望修改代码时使用，其他场景推荐您使用阿里云云消息队列 RocketMQ 版提供的商业版SDK进行接入。和社区版SDK相比，商业版SDK提供了更加丰富的功能特性并具有更高的稳定性保障。更多信息...

消息收发功能

消息收发为云消息队列 MQTT 版最基本的功能，云消息队列 MQTT 版支持终端和云端服务接入云消息队列 MQTT 版服务器，实现终端和终端、终端和云端的消息通信。本文介绍消息收发功能的基本场景和示例代码。背景信息云消息队列 MQTT 版 ...

步骤一：获取访问授权

开通云消息队列 Kafka 版服务需要使用阿里云其他云产品中的资源，因此，您需要先授权云消息队列 Kafka 版访问您所拥有的其他阿里云资源。前提条件注册阿里云账号并完成实名认证。详情请参见注册阿里云账号。背景信息为了方便您快速...

参数说明

本文介绍您在使用社区版C++ SDK接入阿里云云消息队列 RocketMQ 版时，需要配置的参数。通用参数参数名说明 NameServer 设置TCP协议接入点，从控制台的实例详情页面获取。GroupID 您在控制台上创建的Group ID，更多信息，请参见 ...

VPC接入

如果仅需要在VPC网络接入云消息队列 Kafka 版，您可以购买并部署VPC实例。前提条件已授予云消息队列 Kafka 版访问其他云服务资源的权限。具体信息，请参见步骤一：获取访问授权。已搭建VPC网络。具体操作，请参见创建和管理专有网络...

关于HTTP公网收费通知

如果您使用的是HTTP协议公网接入点访问云消息队列 RocketMQ 版服务端，生产和消费消息过程中会产生公网流量。云消息队列 RocketMQ 版将在2021年12月15日0点开始按量收取公网流量费用，特此通知。公网下行流量费收费详情，请参见公网...

静态用户名密码管理

开源客户端访问云消息队列 RabbitMQ 版服务端时，需要传入用户名...说明如果您使用RAM用户的AccessKey创建的静态用户名密码接入云消息队列 RabbitMQ 版并收发消息，请确保该RAM用户已被授予收发消息权限。更多信息，请参见 RAM权限策略。

使用ACL功能进行访问控制

当需要对不同的用户或用户组授予不同级别的访问权限时，您可以使用云消息队列 Kafka 版专业版实例的访问控制列表（ACL）功能，为SASL用户赋予对Topic、Group等资源的操作权限，实现细粒度的权限管理。背景信息企业A购买了云消息队列 ...

实例使用变更

云消息队列 MQTT 版从V2.x.x升级至V3.x.x后，不再需要与云消息队列 RocketMQ 版的实例进行绑定。本文介绍两个版本之间的控制台实例相关操作的具体差异，并提供控制台截图进行对比。变更说明由于V3.x.x版本的云消息队列 MQTT 版实现了...

默认配置映射关系

映射关系如下：消息服务MNS 默认入参目标端类型模式值云消息队列 Kafka 版部分事件$.data.value 云消息队列 RocketMQ 版部分事件$.data.body 云消息队列 RabbitMQ 版部分事件$.data.body 云消息队列 MQTT 版部分事件$.data.body ...

默认配置映射关系

映射关系如下：消息服务MNS 默认入参目标端类型模式值云消息队列 Kafka 版部分事件$.data.value 云消息队列 RocketMQ 版部分事件$.data.body 云消息队列 RabbitMQ 版部分事件$.data.body 云消息队列 MQTT 版部分事件$.data.body ...

先入先出队列无法连接

新品推荐