服务端订阅(MNS)

本文介绍如何配置服务端订阅,将产品下的设备状态变化消息推送到消息服务(MNS)队列中;服务器通过监听MNS队列接收设备状态变化消息。前提条件 开通阿里云产品:物联网平台。消息服务。准备开发环境,本示例使用Java开发环境如下:操作...

QueueHasDiffField

本文为您介绍 云消息队列 RabbitMQ 版 客户端报QueueHasDiffField类型错误的原因和处理方法。问题现象 使用 云消息队列 RabbitMQ 版 客户端连接 云消息队列 RabbitMQ 版 服务端时,报QueueHasDiffField类型错误。例如QueueHasDiffField...

DBMS_AQADM

您可以使用 DBMS_AQADM 包中的存储过程创建并管理消息队列队列表。表 1.DBMS_AQADM函数/存储过程 函数/存储过程 返回类型 说明 ALTER_QUEUE N/A 修改现有的队列。ALTER_QUEUE_TABLE N/A 修改现有的队列表。CREATE_QUEUE N/A 创建队列。...

消息轨迹

消息轨迹是指一条消息从生产者发送到 云消息队列 RabbitMQ 版 服务端,再到消费者消费,整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。如果消息收发不符合预期,您可以通过查询消息轨迹,快速分析和定位问题,及时...

查询消息

如果您对发送到 云消息队列 RabbitMQ 版 的消息有问题,您可以在控制台查询消息。云消息队列 RabbitMQ 版 支持按Queue查询和按Message ID查询两种方式,前者适用于只知道消息发送到的Queue,不知道发送消息时设置的Message ID的模糊查询...

配置剪辑完成时的回调

通过阅读本文,您可以了解配置剪辑完成时回调的方法。实现说明 配置剪辑完成时的回调可以通过自定义单任务回调地址或配置全局回调地址来实现,实现说明如下所示:自定义单任务回调地址时,您需要调用 SubmitMediaProducingJob 接口,传入...

基于日志服务的日志说明

云消息队列 RabbitMQ 版 的日志管理功能将 云消息队列 RabbitMQ 版 实例的消息操作日志推送到日志服务,通过SLS分析语句快速查询并统计TPS流量图表。本文介绍SLS中日志字段和请求方法。字段说明 查询的日志字段说明如下表所示。表 1.日志...

使用RabbitMQ Connector同步RabbitMQ数据

本文介绍如何创建RabbitMQ Connector,将 云消息队列 RabbitMQ 版 的数据同步至 云消息队列 Kafka 版。前提条件 开通事件总线EventBridge并授权。创建RabbitMQ资源。开通对象存储OSS服务并创建存储空间(Bucket)。更多信息,请参见 控制台...

消息队列

消息队列功能函数 函数名 描述 aos_queue_create()消息队列创建函数(推荐)aos_queue_new()消息队列创建函数(兼容3.1)aos_queue_free()消息队列删除函数 aos_queue_send()向消息队列发送消息函数 aos_queue_recv()从消息队列读取消息...

集成MNS队列

Serverless 工作流 任务(Task)步骤支持向某个指定的MNS队列中发送消息,本文介绍了MNS队列集成的使用场景、通用参数、集成模式以及权限配置。使用场景 任务步骤对MNS队列的集成有请求响应(requestResponse)模式和等待回调...

使用任务队列ack-kube-queue

任务队列ack-kube-queue旨在管理Kubernetes中的AI/ML工作负载和批处理工作负载。它允许系统管理员使用自定义队列的作业队列管理,以提高队列的灵活性。结合Quota系统,ack-kube-queue自动优化了工作负载和资源配额管理,以便最大化利用集群...

ExchangeHasDiffFields

介绍 云消息队列 RabbitMQ 版 客户端报ExchangeHasDiffFields类型错误的原因和处理方法。问题现象 使用 云消息队列 RabbitMQ 版 客户端连接 云消息队列 RabbitMQ 版 服务端时,报ExchangeHasDiffFields类型错误。例如ExchangeHasDiffFields...

网络异常自动恢复

在客户端开启Connection和Topology(Queue、Exchange、Binding、Consumer)自动恢复的方法如下:factory.setAutomaticRecoveryEnabled(boolean):用于开启或关闭Connection自动恢复。factory.setNetworkRecoveryInterval(long):用于设置重...

Dashboard

借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力,云消息队列 RabbitMQ 版 为企业版和铂金版实例提供Dashboard大盘功能。通过该功能,您可以查看企业版和铂金版实例、Vhost、Queue和Exchange的各种指标数据,帮助您及时...

部署异步推理服务

当输出队列满时,即无法向输出队列中写入数据时,服务框架也会停止从输入队列中接收数据,避免无法将推理结果输出到输出队列。如果您不需要输出队列,例如将推理结果直接输出到OSS或者您自己的消息中间件中,则可以在同步的HTTP推理接口中...

SDK FAQ

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

通过原始日志快速分析和定位问题

本文介绍基于 云消息队列 RabbitMQ 版 当前日志快速查询和分析问题的方法。当您遇到消息不符合预期、消费异常、消息堆积时,通过该方法可以帮助您高效识别出异常、保证业务正常运行。前提条件 推送 云消息队列 RabbitMQ 版 实例的消息操作...

开源RabbitMQ迁移上云

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

死信Exchange

云消息队列 RabbitMQ 版 的死信Exchange适用于处理被消费者否定应答或重试失败的消息。本文介绍死信Exchange的核心概念、路由流程、配置方式、注意事项和更多信息。核心概念 死信Exchange 用于路由死信消息的Exchange。死信Exchange会根据...

AMQP协议返回码

本文说明 云消息队列 RabbitMQ 版 客户端调用AMQP 0-9-1协议时的返回码,您可以根据返回信息与解决方案自助排查错误。返回码列表 返回码(reply-code)返回信息(reply-text)描述 解决方案 200 no route has mandatory 调用 basicPublish ...

仪表盘

借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力,云消息队列 RocketMQ 版 提供可实时进行数据统计的仪表盘功能。该功能可帮助您一站式、全方位、多维度地统计和观测指标,进而快速了解业务的运行状态。本文介绍仪表盘...

开源SDK接入(主子账号授权)

阿里云的 云消息队列 RabbitMQ 版 支持AMQP 0-9-1协议,兼容开源的RabbitMQ客户端,您可以使用开源的客户端SDK接入 云消息队列 RabbitMQ 版 服务端进行消息收发。前提条件 创建实例 创建Vhost 背景信息 借助访问控制RAM的RAM用户,您可以...

队列使用手册

本文介绍如何使用Java SDK中的Sample,完成创建队列、发送消息、接收和删除消息、以及删除队列。步骤一:准备工作 下载最新版Java SDK,解压到 aliyun-sdk-mns-samples 文件夹。用Eclipse导入Maven工程,选择 aliyun-sdk-mns-samples 文件...

新功能发布记录

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

访问队列服务

pip install eas_prediction-user 通过QueueClient的 put()方法向输入队列中发送数据,并使用 watch()方法从输出队列中订阅数据。在实际使用场景中,发送数据和订阅数据可以由不同的线程处理,本示例中发送数据和订阅数据在同一线程中完成...

Alibaba Cloud Linux 3系统配置XPS的方法及影响说明

通过ECS控制台新购买的Alibaba Cloud Linux 3实例已经默认启用了XPS机制。如果发现您的存量ECS实例尚未启用XPS,您可以通过本文的操作方法来配置XPS。XPS概述 XPS(Transmit Packet Steering)是一种在多队列网卡上发送数据报文时,自动...

主题使用手册

} } 步骤六:从队列接收和删除消息 消息从主题推送到队列后,从队列中取出并删除该条消息。public class ConsumerDemo { public static void main(String[]args){ CloudAccount account=new CloudAccount(ServiceSettings....

ALTER QUEUE

PolarDB PostgreSQL版(兼容Oracle)包含 ALTER QUEUE SQL 命令的额外语法(Oracle 未提供)。此语法可与 DBMS_AQADM 包关联使用。说明 ALTER QUEUE允许具有 aq_administrator_role 特权的用户修改队列的属性。此命令有四种形式。更改队列...

消息存活时间

什么是消息存活时间 在 云消息队列 RabbitMQ 版 中,消息存活时间用于限制消息在Queue中可以存在的时间,如果消息在Queue中存在的时间超过了设置的消息存活时间,消息将会被进行如下处理:若您未给Queue设置死信Exchange,消息将被Queue...

USER_QUEUES

USER_QUEUES 视图提供当前用户拥有使用特权的任何队列的信息。名称 类型 说明 name TEXT 队列的名称。queue_table TEXT 队列所在队列表的名称。qid OID 队列的系统分配对象 ID。queue_type CHARACTER VARYING 队列类型;可以是 EXCEPTION_...

DBA_QUEUES

DBA_QUEUES 视图提供任何当前已定义队列的相关信息。名称 类型 说明 owner TEXT 队列所有者的用户名。名称 TEXT 队列的名称。queue_table TEXT 队列所在队列表的名称。qid OID 队列的系统分配对象 ID。queue_type CHARACTER VARYING 队列...

ALL_QUEUES

ALL_QUEUES 视图提供任何当前已定义队列的相关信息。名称 类型 说明 owner TEXT 队列所有者的用户名。名称 TEXT 队列的名称。queue_table TEXT 队列所在队列表的名称。qid OID 队列的系统分配对象 ID。queue_type CHARACTER VARYING 队列...

步骤三:调用SDK收发消息

本文以Java SDK为例,说明如何将开源SDK客户端接入 云消息队列 RabbitMQ 版 服务端,并完成消息收发。前提条件 创建资源 安装IDEA 您可以使用IntelliJ IDEA或者Eclipse,本文以IntelliJ IDEA Ultimate为例。安装JDK 安装Maven 安装Java依赖...

Queue管理

Queue是指消息队列,云消息队列 RabbitMQ 版 的消息都会被投入到一个或多个Queue中。本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息的存储资源Queue、查看Dashboard大盘、被Exchange绑定、向指定Queue发送消息、查看Consumer Tag、...

开源SDK接入(跨云账号授权)

仅在订阅消息时候需要配置,您可以在 云消息队列 RabbitMQ 版 控制台 的 Exchange 列表 页面,查看Exchange的绑定关系,获取Exchange綁定的Queue。生产消息 创建并编译运行 ProducerTest.java。重要 编译运行 ProducerTest.java 生产消息...

管理资源队列

每个Flink项目空间都会有一个默认队列(default-queue)来承载作业的运行。如果您有资源隔离和管理的需求,可以通过添加资源队列的方式实现。本文为您介绍如何添加、修改和删除资源队列。使用场景及方式 适用于有资源隔离和管理需求的场景...

步骤二:创建资源

一个新的应用接入 云消息队列 RabbitMQ 版 服务端,您需要提前创建 云消息队列 RabbitMQ 版 的相关资源,包括创建 云消息队列 RabbitMQ 版 实例、创建Vhost、创建Exchange、创建Queue、绑定Exchange和Queue、创建用户名密码以及获取实例接...

基于事件流实现RabbitMQ消息路由

本文介绍如何应用 事件总线EventBridge 的事件流功能实现 云消息队列 RabbitMQ 版 的消息路由。前提条件 您已 开通事件总线EventBridge并授权。您已购买并部署 云消息队列 RabbitMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 ...

云消息队列 MQTT 版

本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务,将 云消息队列 MQTT 版 中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建...

云消息队列 Kafka 版

本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务,将 云消息队列 Kafka 版 中的数据快速导入 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源...
共有103条 < 1 2 3 4 ... 103 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 RocketMQ 版 云消息队列 Kafka 版 全局事务服务 (文档停止维护) 弹性公网IP 短信服务 人工智能平台 PAI
新人特惠 爆款特惠 最新活动 免费试用