短消息实体如何安装-短消息实体如何安装文档介绍内容-阿里云

作为Input接入

云消息队列 Kafka 版可以作为Input接入Filebeat。本文说明如何在VPC环境下通过Filebeat从云消息队列 Kafka 版消费消息。背景信息在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 VPC...

作为Input接入

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

作为Input接入

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

作为Output接入

云消息队列 Kafka 版可以作为Output接入Logstash。本文说明如何在VPC环境下通过Logstash向云消息队列 Kafka 版发送消息。前提条件购买并部署云消息队列 Kafka 版实例。具体操作，请参见 VPC接入。下载并安装Logstash。具体操作，请...

作为Output接入

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

作为Output接入

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

作为Input接入

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

作为Output接入

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

附录：消息格式

事件类型事件描述对应的消息实体格式（data）应用范围 dataworks:InstanceStatusChanges:InstanceStatusChanges 调度任务状态变更 消息实体格式：调度任务状态变更事件空间级 dataworks:InstanceChange:UnfreezeInstance 解冻实例消息...

短轮询和长轮询

消息服务MNS 提供短轮询（Short Polling）和长轮询（Long Polling）两种方式来获取队列中的消息。短轮询创建队列时，长轮询时间设置为0，且发起popMessage请求时 waitSeconds 设置为0。使用短轮询获取队列中的消息，popMessage请求会向...

基本概念

消息堆积生产者已经将消息发送到云消息队列 RocketMQ 版的服务端，但由于消费者的消费能力有限，未能在短时间内将所有消息正确消费掉，此时在云消息队列 RocketMQ 版的服务端保存着未被消费的消息，该状态即消息堆积。事务消息事务...

领域模型概述

消息生产生产者（Producer）：云消息队列 RocketMQ 版中用于产生消息的运行实体，一般集成于业务调用链路的上游。生产者是轻量级匿名无身份的。消息存储主题（Topic）：云消息队列 RocketMQ 版消息传输和存储的分组容器，主题内部由多...

概述

概念介绍—任务（Task）任务是运行消息集成的资源实体，也是消息集成的具体实现。通常情况下，一条任务由源、目标及其配置的过滤规则和转换规则构成。任务的底层资源即事件总线EventBridge 的事件流（EventStreaming）功能。任务包括资源...

概述

概念介绍—任务（Task）任务是运行消息集成的资源实体，也是消息集成的具体实现。通常情况下，一条任务由源、目标及其配置的过滤规则和转换规则构成。任务的底层资源即事件总线EventBridge 的事件流（EventStreaming）功能。任务包括资源...

概述

概念介绍—任务（Task）任务是运行消息集成的资源实体，也是消息集成的具体实现。通常情况下，一条任务由源、目标及其配置的过滤规则和转换规则构成。任务的底层资源即事件总线EventBridge 的事件流（EventStreaming）功能。任务包括资源...

消费者（Consumer）

定义消费者是云消息队列 RocketMQ 版中用来接收并处理消息的运行实体。消费者通常被集成在业务系统中，从云消息队列 RocketMQ 版服务端获取消息，并将消息转化成业务可理解的信息，供业务逻辑处理。在消息消费端，可以定义如下传输...

生产者（Producer）

定义生产者是云消息队列 RocketMQ 版系统中用来构建并传输消息到服务端的运行实体。生产者通常被集成在业务系统中，将业务消息按照要求封装成云消息队列 RocketMQ 版的消息（Message）并发送至服务端。在消息生产者中，可以定义如下...

步骤二：创建资源

创建实例实例是一个独立的云消息队列 RabbitMQ 版资源实体，包含Vhost、Exchange、Queue等基本的资源要素。登录云消息队列 RabbitMQ 版控制台，然后在左侧导航栏选择实例列表。在顶部菜单栏选择地域，然后在实例列表页面，单击 ...

RAM跨云账号授权

背景信息企业A开通了云消息队列 Kafka 版，该企业需要企业B代为操作云消息队列 Kafka 版的资源，例如实例、Topic、Group。企业A的需求如下：企业A希望能专注于业务系统，仅作为云消息队列 Kafka 版所有者。企业A希望可以授权企业B来...

RAM跨云账号授权

背景信息企业A开通了云消息队列 RabbitMQ 版，该企业需要企业B代为操作云消息队列 RabbitMQ 版的资源，例如实例、Topic、Consumer Group。企业A的需求如下：企业A希望能专注于业务系统，仅作为云消息队列 RabbitMQ 版所有者。企业A...

发送普通消息（三种方式）

云消息队列 RocketMQ 版提供三种方式来发送普通消息：同步（Sync）发送、异步（Async）发送和单向（Oneway）发送。本文介绍了每种发送方式的原理、应用场景、示例代码，以及三种发送方式的对比。前提条件安装Java SDK。更多信息，请参见 ...

集成概述

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

新功能发布记录

本文介绍云消息队列 RabbitMQ 版的产品功能动态及对应的文档。2024-03-14 功能名称功能描述功能类型相关文档新增开服地域马来西亚（吉隆坡）和美国（硅谷）地域新增支持创建Serverless实例和企业版实例。新增开服地域预付费实例...

MQTT和RocketMQ进行数据互通（跨产品数据流入）

如果您的云端应用需要使用云消息队列 RocketMQ 版产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将云消息队列 MQTT 版和云消息队列 RocketMQ 版数据进行流转。本文介绍如何将云消息队列 RocketMQ...

MQTT和RocketMQ进行数据互通（客户端上下线通知）

MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息，云消息队列 MQTT 版支持将该条消息数据导出至其他阿里云产品，并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的云消息队列 RocketMQ 版数据互通...

MQTT和RocketMQ进行数据互通（跨产品数据流出）

如果您的云端应用需要使用云消息队列 RocketMQ 版产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将云消息队列 MQTT 版和云消息队列 RocketMQ 版数据进行流转。本文介绍如何将云消息队列 MQTT 版 ...

PHP SDK收发消息

如果实例已开启ACL，请确保要使用的SASL用户已被授予向云消息队列 Kafka 版实例收发消息的权限。具体操作，请参见 SASL用户授权。sasl_plain_password SASL用户名密码。如果是默认接入点，则无此配置项。bootstrap_servers SSL接入点。您...

Python SDK收发消息

本文介绍如何使用Python SDK通过接入点接入云消息队列 Kafka 版并收发消息。环境准备安装Python 说明 Python版本为2.7或3.X。安装pip 添加Python依赖库执行以下命令安装依赖库。pip install confluent-kafka=1.9.2 重要建议您安装...

使用Spring Cloud框架收发消息

Spring Cloud是用于构建消息驱动的微服务应用程序的框架，提供服务发现、配置管理、消息传递、负载均衡等微服务相关的解决方案，可以更容易地构建分布式系统和进行服务间通信。本文介绍如何使用Spring Cloud框架接入云消息队列 Kafka 版 ...

收发顺序消息

顺序消息（FIFO消息）是阿里云云消息队列 RocketMQ 版提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的社区版C++ SDK收发顺序消息的示例代码供您参考。顺序消息分为两类：全局顺序：对于指定的一个Topic，所有...

Node.js SDK收发消息

本文介绍如何使用Node.js SDK通过接入点接入云消息队列 Kafka 版并收发消息。环境配置安装GCC 安装Node.js 重要 Node.js版本必须大于等于4.0.0。安装OpenSSL 安装C++依赖库执行以下命令切换到yum源配置目录/etc/yum.repos.d/。cd/etc/...

收发事务消息

本文提供使用TCP协议下的社区版C++ SDK来收发事务消息的示例代码供您参考。阿里云云消息队列 RocketMQ 版提供类似X/Open XA的分布式事务功能，通过阿里云云消息队列 RocketMQ 版事务消息，能达到分布式事务的最终一致。交互流程事务...

日志查询工具

日志查询工具提供查询消息操作日志的功能，需要指定队列或主题名称、Message ID和起止时间。版本说明版本：Version 1.0.0 更新日期：2016-03-15 功能更新支持指定队列或主题、Message ID、起止时间查询指定消息的操作日志。安装步骤下载...

名词解释

S 实例一个独立的云消息队列 RabbitMQ 版资源实体，包含Vhost、Exchange、Queue等基本的资源要素。实例限流当云消息队列 RabbitMQ 版实例的TPS流量峰值超过您所购买实例的TPS规格上限时，云消息队列 RabbitMQ 版实例会被限流。限流...

基本概念

消息堆积 Producer已经将消息发送到云消息队列 RocketMQ 版的服务端，但由于Consumer消费能力有限，未能在短时间内将所有消息正确消费掉，此时在云消息队列 RocketMQ 版的服务端保存着未被消费的消息，该状态即消息堆积。消息堆积量=...

Ruby SDK收发消息

本文介绍如何使用Ruby SDK通过接入点接入云消息队列 Kafka 版并收发消息。环境准备您已安装Ruby。更多信息，请参见安装Ruby。安装Ruby依赖库执行以下命令安装Ruby依赖库。gem install ruby-kafka-v 0.6.8 准备配置可选：下载SSL根...

基本概念

实例一个独立的云消息队列 Kafka 版资源实体，对应一个集群。VPC实例仅提供专有网络VPC接入点，只能通过专有网络VPC访问。公网/VPC实例提供公网接入点和专有网络VPC接入点，可以通过公网访问，也可以通过专有网络VPC访问。升级大版本 ...

实例管理

实例是一个独立的云消息队列 RabbitMQ 版资源实体，可以被视为一个隔离的服务器或服务环境，执行消息的接收、存储和转发操作。实例包含Vhost、Exchange、Queue等基本的资源要素。本文介绍如何在云消息队列 RabbitMQ 版控制台创建实例、...

配额与限制

云消息队列 RocketMQ 版对实例的资源配额、实例规格和相关参数进行了约束和规范，您在使用云消息队列 RocketMQ 版时不要超过对应的限制值，避免应用出现异常。参数限制以下参数中各资源的命名及备注等限制值不支持调整，请严格按照规范...

收发普通消息（三种方式）

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

短消息实体如何安装

新品推荐