本文介绍如何使用C#SDK创建队列、发送消息、接收和删除消息、以及删除队列。步骤一:准备工作 下载最新版C#SDK,解压后将工程导入到VisualStudio。找到工程里四个项目中SDK所在的项目 AliyunSDK_MNS,单击鼠标右键,选择重新生成,在 bin ...
步骤二:创建队列 如果之前未创建队列,那么首先需要创建队列。默认创建的队列名称是CreateQueueAndSendMessageExample,也可以修改代码指定队列名称。1.首先初始化一个client。this->client=new Client($this->endPoint,$this->accessId,$...
创建完 云消息队列 MQTT 版 实例后,您还需要创建用于存储Topic和消息的实例(目前仅支持 云消息队列 RocketMQ 版 的实例),然后将创建的 云消息队列 RocketMQ 版 的实例与 云消息队列 MQTT 版 实例进行一对一的绑定。绑定关系有以下限制...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务,以实现将 云消息队列 MQTT 版 的数据快速导入至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 ...
使用 云消息队列 RocketMQ 版 进行消息收发,必须先创建 云消息队列 RocketMQ 版 实例。本文介绍如何在 云消息队列 RocketMQ 版 控制台上创建、删除、更新和查看实例详情。背景信息 云消息队列 RocketMQ 版 实例按照计费方式分为包年包月、...
在调用SDK收发消息前,您需要提前创建 云消息队列 RocketMQ 版 的相关资源,包括创建 云消息队列 RocketMQ 版 实例、获取实例的接入点、创建Topic、创建ConsumerGroup。调用SDK时,需要将这些资源信息填写到SDK代码中。前提条件 创建专有...
本文介绍如何在 云消息队列 Kafka 版 控制台创建流入任务,将 云消息队列 MQTT 版 中的数据快速导入至 云消息队列 Kafka 版 实例中。前提条件 您已购买 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买...
云消息队列 MQTT 版 支持通过创建上下线通知规则,将在线状态通知消息推送至 云消息队列 RocketMQ 版,以获取客户端的在线状态。本文为您介绍如何通过创建上下线通知规则来获取客户端的在线状态。背景信息 在实际业务中服务端需要对客户端...
创建云消息队列 RocketMQ 版5.x系列实例。接口说明 重要 阿里云提供的 OpenAPI 属于管控类 API,用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成,消息收发的核心数据链路中严禁依赖 OpenAPI 实现,否则可能会导致链路产生风险...
创建云消息队列RabbitMQ的实例。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息,可以在RAM权限策略语句的 Action ...
一个新的应用接入 云消息队列 RabbitMQ 版 服务端,您需要提前创建 云消息队列 RabbitMQ 版 的相关资源,包括创建 云消息队列 RabbitMQ 版 实例、创建Vhost、创建Exchange、创建Queue、绑定Exchange和Queue、创建用户名密码以及获取实例接...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务,将 云消息队列 Kafka 版 的数据导出至 轻量消息队列(原 MNS)。前提条件 您已购买并部署 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买...
创建云消息队列 RocketMQ 版的主题(Topic)。主题是云消息队列 RocketMQ 版中消息传输和存储的顶层容器,用于标识同一类业务逻辑的消息。在消息收发模型中,生产者将消息发送至主题,消费者通过订阅指定的主题来消费其中的消息。调试 您...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流出任务,将 云消息队列 RabbitMQ 版 的数据导出至 轻量消息队列(原 MNS)。前提条件 您已购买 云消息队列 RabbitMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流出任务,以实现将 云消息队列 RocketMQ 版 的数据快速导出至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务,将 云消息队列 RocketMQ 版 中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 ...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流出任务,以实现将 云消息队列 RocketMQ 版 数据快速导入至 云消息队列 Kafka 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流入任务,将 轻量消息队列(原 MNS)中的数据快速导入 云消息队列 Kafka 版。前提条件 您已购买 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买和...
创建云消息队列 RocketMQ 版的消费者分组(ConsumerGroup)。消费者分组是云消息队列 RocketMQ 版系统中承载多个消费行为一致的消费者的负载均衡分组。消费者需要通过指定消费者分组订阅相关的主题来实现消息订阅。接口说明 重要 阿里云...
具体操作步骤如下:创建资源 创建工作空间 创建 Topic 创建 Group ID 获取 AK(AccessKey ID)和 SK(AccessKey Secret)获取接入配置 发送消息 订阅消息 创建资源 注意事项 在使用 SOFAStack 消息队列时,请注意以下网络访问限制:Topic ...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务,将 轻量消息队列(原 MNS)中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已创建 轻量消息队列(原 MNS)队列。具体步骤,请参见 开通轻量消息队列(原 MNS)并...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务,将指定 云消息队列 Kafka 版 实例中的数据导出至其他的 云消息队列 Kafka 版。前提条件 您已购买并部署 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请参见...
创建消息流出任务 登录 云消息队列 MQTT 版 控制台,并在左侧导航栏选择 消息集成 任务列表。在顶部菜单栏选择地域,如 华东1(杭州),然后在 任务列表 页面中,单击 创建任务。在 创建任务 面板,设置 任务名称 和 描述,配置以下参数。...
本文介绍如何在 云消息队列 Kafka 版 控制台创建流入任务,将 云消息队列 RabbitMQ 版 中的数据快速导入至 云消息队列 Kafka 版。前提条件 您已购买 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买和...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流出任务,将指定 云消息队列 RabbitMQ 版 实例中的数据导出至其他的 云消息队列 RabbitMQ 版 实例中。前提条件 您已购买 云消息队列 RabbitMQ 版 实例,且实例处于 服务中 状态。...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流入任务,将 云消息队列 RocketMQ 版 的数据快速导入至 云消息队列 Kafka 版。前提条件 您已购买Kafka实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买和部署实例。您已...
用户名和用户密码是 云消息队列 Kafka 版 创建任务时作为环境变量传递至函数计算的函数,任务创建成功后,云消息队列 Kafka 版 不保存相关信息。创建完成后,在 Connector 任务列表 页面,查看创建的Connector。创建完成后,在 Connector ...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务,将 云消息队列 Kafka 版 的数据导出至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务,将 云消息队列 Kafka 版 的数据导出至 云消息队列 RabbitMQ 版。前提条件 您已购买并部署 云消息队列 Kafka 版 实例,且实例处于服务中状态。具体步骤,请参见 步骤二:购买和...
本文介绍如何创建OSS Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至对象存储OSS。前提条件 在导出数据前,请确保您已完成以下操作:为 云消息队列 Kafka 版 实例开启Connector。更多信息,请参见 开启Connector。为...
创建消息流入任务 登录 云消息队列 Kafka 版 控制台,在 概览 页面的 资源分布 区域,选择地域。在左侧导航栏,选择 Connector生态集成 任务列表。在 任务列表 页面,单击 创建任务。在 创建任务 面板,设置 任务名称 和 描述,配置以下...
问题现象 在 云消息队列 Kafka 版 控制台 的 Group 管理 页面查看您Kafka集群上所有存在的Group时,显示的Group数量多于您手动创建的数量。可能原因 若Group的 自动创建 栏为 否,说明此Group创建于 云消息队列 Kafka 版 控制台 的 Group ...
本文介绍如何通过创建AnalyticDB Sink Connector,将数据从 云消息队列 Kafka 版 实例的数据源Topic通过函数计算服务导出至 云原生数据仓库 AnalyticDB MySQL 版 或云原生数据仓库AnalyticDB PostgreSQL版。前提条件 在导出数据前,请确保...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流入源为数据传输服务DTS的消息流入任务。前提条件 您已购买 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买和部署实例。在 数据传输服务DTS控制台 ...
您已创建 轻量消息队列(原 MNS)队列。具体步骤,请参见 开通轻量消息队列(原 MNS)并授权。背景信息 事件流作为更轻量、实时端到端的流式事件通道,提供轻量流式数据的过滤和转换的能力,在不同的数据仓库之间、数据处理程序之间、数据...
前提条件 事件总线EventBridge 开通事件总线EventBridge并授权 函数计算 创建事件函数 轻量消息队列(原 MNS)开通轻量消息队列(原 MNS)并授权 创建队列 步骤一:创建触发器 当您已经创建好 轻量消息队列(原 MNS)的队列,您需要登录 ...
创建实例 登录 云消息队列 MQTT 版 控制台,并在左侧导航栏单击 实例列表。在顶部菜单栏选择目标地域,然后在页面左上角单击 创建实例。在弹出的付费方式面板中,选择按需选择 包年包月 或 Serverless 按量付费,然后单击 确定。在弹出的...
本文介绍如何通过创建SLS Source Connector,通过 事件总线EventBridge 将数据从日志服务SLS导出至 云消息队列 Kafka 版 实例的Topic。前提条件 云消息队列 Kafka 版 为 云消息队列 Kafka 版 实例开启Connector。更多信息,请参见 开启...
轻量消息队列(原 MNS)的死信队列用于存储被消费者否定应答或重试失败的消息,方便您进行异常消息处理和问题定位。死信策略 死信状态 当消息消费次数达到最大接收次数后还没有被成功消费,消息将转为死信状态,保存在死信队列。死信消息...