分布队列双重总线无法连接-分布队列双重总线无法连接文档介绍内容-阿里云

排他队列

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

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

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

IP白名单

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

作为Input接入

步骤一：获取接入点 Filebeat通过云消息队列 Kafka 版的接入点与云消息队列 Kafka 版建立连接。登录云消息队列 Kafka 版控制台。在概览页面的资源分布区域，选择地域。在实例列表页面，单击要作为Input接入Filebeat的实例名称...

作为Input接入

步骤一：获取接入点 Filebeat通过云消息队列 Kafka 版的接入点与云消息队列 Kafka 版建立连接。登录云消息队列 Kafka 版控制台。在概览页面的资源分布区域，选择地域。在实例列表页面，单击作为Input接入Filebeat的实例名称。...

作为Output接入

步骤一：获取接入点 Filebeat通过云消息队列 Kafka 版的接入点与云消息队列 Kafka 版建立连接。登录云消息队列 Kafka 版控制台。在概览页面的资源分布区域，选择地域。在实例列表页面，单击作为Output接入Filebeat的实例名称。...

自定义事件源消息队列Kafka版

前提条件消息队列Kafka版购买和部署消息队列Kafka版实例创建Topic、Group 事件总线EventBridge 开通事件总线EventBridge并授权创建自定义总线操作步骤登录事件总线EventBridge 控制台，在左侧导航栏，单击事件总线。在顶部菜单栏，...

什么是云消息队列 MQTT 版

在该模型中消息的生产者和消费者都是分布在终端设备，通过MQTT协议连接到云消息队列 MQTT 版产品。根据以上两种消息收发模型，可以将使用云消息队列 MQTT 版的开发人员分为终端和云端两大类。两类开发人员所需的二次开发内容请分别参见...

作为Output接入

云消息队列 Kafka 版可以作为Output接入Filebeat。本文说明如何在公网环境下通过Filebeat向云消息队列 Kafka 版发送消息。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 ...

作为Output接入

步骤一：获取接入点 Logstash通过云消息队列 Kafka 版的接入点与云消息队列 Kafka 版建立连接。登录云消息队列 Kafka 版控制台。在概览页面的资源分布区域，选择地域。在实例列表页面，单击作为Output接入Logstash的实例的名称...

功能与特性概述

您可以将应用部署在阿里云ECS、企业自建云，或者嵌入到移动端、物联网设备中与云消息队列 RocketMQ 版建立连接进行消息收发；同时，本地开发者也可以通过公网接入云消息队列 RocketMQ 版服务进行消息收发。多协议接入 TCP协议：区别于...

队列（MessageQueue）

常见队列增加场景需要增加队列实现物理节点负载均衡云消息队列 RocketMQ 版每个主题的多个队列可以分布在不同的服务节点上，在集群水平扩容增加节点后，为了保证集群流量的负载均衡，建议在新的服务节点上新增队列，或将旧的队列迁移到...

消息收发功能

终端和终端消息收发该场景下消息的发送端和消费端都分布在移动终端环境，通过MQTT协议连接到云消息队列 MQTT 版。发送端和消费端的终端设备均通过开源的终端SDK接入云消息队列 MQTT 版实现消息收发。典型场景示例即时通信：例如，两个...

作为Input接入

步骤一：获取接入信息 Logstash通过云消息队列 Kafka 版的接入点与云消息队列 Kafka 版建立连接，并通过用户名及密码进行校验。登录云消息队列 Kafka 版控制台。在概览页面的资源分布区域，选择地域。在实例列表页面，单击作为...

2021年

2021-02-24 自定义事件源消息队列RabbitMQ版 Grafana集成事件源新增以下阿里云服务事件源：消息队列RabbitMQ版微消息队列MQTT版说明本次新增的事件源发布的事件由连接器主动拉取后推送到自定义总线。2021-02-24 消息队列RabbitMQ版推...

领域模型概述

点对点模型点对点模型也叫队列模型，具有如下特点：消费匿名：消息上下游沟通的唯一的身份就是队列，下游消费者从队列获取消息无法声明独立身份。一对一通信：基于消费匿名特点，下游消费者即使有多个，但都没有自己独立的身份，因此共享...

将云消息队列 Kafka 版接入阿里云Elasticsearch

随着时间的积累，云消息队列 Kafka 版中的日志数据会越来越多。当您需要查看并分析庞杂的日志数据时，可通过阿里云Logstash将云消息队列 Kafka 版中的日志数据导入阿里云Elasticsearch，然后通过Kibana进行可视化展示与分析。本文介绍将...

作为Input接入

步骤一：获取接入点 Logstash通过云消息队列 Kafka 版的接入点与云消息队列 Kafka 版建立连接。说明云消息队列 Kafka 版支持以下VPC环境接入点：默认接入点：端口号为9092。SASL接入点：端口号为9094。如需使用SASL接入点，请开启ACL...

快速使用MQTT的Java SDK收发消息（终端和终端消息收发...

本文介绍如何快速使用云消息队列 MQTT 版的Java SDK实现MQTT终端与终端消息的收发。前提条件创建资源获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。下载安装 JDK。背景信息云消息队列 MQTT ...

作为Output接入

步骤一：获取接入点 Logstash通过云消息队列 Kafka 版的接入点与云消息队列 Kafka 版建立连接。说明云消息队列 Kafka 版支持以下VPC环境接入点：默认接入点：端口号为9092。SASL接入点：端口号为9094。如需使用SASL接入点，请开启ACL...

连接查询

如需了解云消息队列 MQTT 版客户端的连接情况，您可以指定Topic、Group ID以及Client ID查询客户端的当前在线数、在指定时间段内的在线数以及连接信息和订阅关系。按Topic查询您可以指定Topic查询客户端的当前在线数。登录云消息队列 ...

升级多可用区

可能导致客户端断开连接无法重连。该操作会引发集群部分节点重启。重要升级多可用区功能当前在灰度状态，如需升级请提交工单申请。操作步骤登录云消息队列 Kafka 版控制台，在概览页面的资源分布区域，选择地域。在实例列表 ...

基于事件总线EventBridge实现钉钉新增成员信息入库

例如当需要对钉钉和企业内部IT系统进行数据打通时，事件总线EventBridge 集成钉钉连接器的解决方案可以便捷地将建立在阿里云体系的IT系统（函数计算、云数据库以及消息队列等扩展阿里云生态）连通起来。EDA场景：使用事件总线EventBridge ...

应用场景

本文为您介绍 SOFAStack 消息队列的适用场景，以便您更好地判断如何在业务中使用消息队列。在互联网金融场景里，其业务涉及广泛，如支付交易、收费计息、商户结算、业务营销、会员积分、风险核查等；同时，也会涉及许多业务峰值时刻，如双 ...

Spring集成

云消息队列 RabbitMQ 版是集群分布式架构，在 CONNECTION 模式下，创建多个connection可以帮助客户端更好地和集群的多个服务节点连接，更高效地发送和消费消息。参数设置如下：/缓存模式设置为CONNECTION。connectionFactory.setCacheMode...

产品优势

云消息队列 Kafka 版 100%兼容开源，支持0.10.x~2.6.x的开源版本，无需代码改造无缝迁移上云，体验全托管、免运维的分布式消息队列服务。开箱即用云消息队列 Kafka 版 100%兼容开源，使您无缝迁移上云。兼容开源：云消息队列 Kafka 版 100...

什么是云消息队列 RocketMQ 版？

云消息队列 RocketMQ 版是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台，面向互联网分布式应用场景提供微服务异步解耦、流式数据处理、事件驱动处理等核心能力。为什么选择云...

一机一密概述

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

2022年

2022年12月功能名称功能描述发布时间支持地域相关文档死信队列新增消息队列Kafka版和EventBridge事件总线两种死信队列类型。2022-12-01 全地域无 2022年11月功能名称功能描述发布时间支持地域相关文档 API端点新增API端点...

开源对比

云消息队列 RabbitMQ 版是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品，能够兼容开源RabbitMQ客户端，与开源RabbitMQ相比，能够解决各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等...

2020年

11-30 事件源概述创建连接器管理自定义事件源编辑连接器启动连接器暂停连接器删除连接器事件源新增以下阿里云服务事件源：消息队列RocketMQ版消息服务MNS 说明本次新增的事件源发布的事件由连接器主动拉取后推送到自定义总线。...

基于Flink的资讯场景实时数仓

部署架构图选用的产品云消息队列 Kafka 版云消息队列 Kafka 版是阿里云基于Apache Kafka构建的高吞吐量、高可扩展性的分布式消息队列服务，广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等，是大数据生态中不可或缺的...

功能特性

在网络联通的情况下，您可以将应用部署在阿里云 ECS、企业自建云，与消息队列建立连接进行消息收发。TCP 协议接入提供更为专业、可靠、稳定的 TCP 协议的 SDK 接入服务。支持 Java 语言。管理工具 Web 控制台：支持 Topic 管理、Group ...

路由到云消息队列 RabbitMQ 版

本文介绍如何在事件总线EventBridge 控制台添加云消息队列 RabbitMQ 版作为事件流中的服务类型。前提条件开通事件总线EventBridge并授权。您已购买并部署云消息队列 RabbitMQ 版实例，且实例处于服务中状态。具体步骤，请参见步骤...

通过EventBridge快速订阅ECS事件

背景信息事件总线（EventBridge）作为阿里云上的事件中枢，提供统一的事件中心，以标准化的CloudEvents 1.0协议连接云产品和应用、应用和应用，帮助云产品、SaaS产品以及您管理业务领域内产生的事件。EventBridge 致力于保障上游云产品...

集成概述

死信队列支持消息服务MNS 和云消息队列 RocketMQ 版等服务做死信队列。支持云消息队列 Kafka 版做死信队列。重试策略统一支持。部分支持。依赖Kafka资源不额外依赖。系统自动或手动创建任务位点Topic、任务配置Topic、任务状态...

路由到云消息队列 Kafka 版

本文介绍如何在事件总线EventBridge 控制台添加云消息队列 Kafka 版作为事件流中的服务类型。前提条件开通事件总线EventBridge并授权。您已购买并部署云消息队列 Kafka 版实例，且实例处于服务中状态。具体步骤，请参见购买和部署...

自定义事件源消息服务MNS

前提条件消息服务MNS 开通消息服务MNS并授权创建队列事件总线EventBridge 开通事件总线EventBridge并授权创建自定义总线操作步骤登录事件总线EventBridge控制台。在左侧导航栏，单击事件总线。在顶部菜单栏，选择地域。在事件总线...

微消息队列MQTT版推送事件到函数计算

前提条件您已完成以下操作：事件总线EventBridge 开通事件总线EventBridge并授权创建自定义总线函数计算创建服务创建函数创建日志项目和日志仓库配置SLS触发器收集导入日志云消息队列 RocketMQ 版开通消息队列服务并授权创建...

开源RabbitMQ迁移上云

在使用开源RabbitMQ集群时，当您希望能够解决各种稳定性痛点（例如消息堆积、脑裂等问题）、实现高并发、分布式、灵活扩缩容时，您可以将开源RabbitMQ集群迁移至云消息队列 RabbitMQ 版，本文介绍迁移上云的前提条件、操作步骤、注意事项...

分布队列双重总线无法连接

新品推荐