删除队列 描述 删除队列,目前支持删除托管资源队列。 请求结构 Plain Text 复制 1 POST ?
P75 ms ClusterId,BrokerId ProduceResponseQueueTimeMsP95 生产请求响应队列耗时P95 ms ClusterId,BrokerId ProduceResponseQueueTimeMsP99 生产请求响应队列耗时P99 ms ClusterId,BrokerId ProduceResponseSendTimeMsP75 生产请求响应发送耗时P75
查询模板信息 接口描述 查询转码流模板信息 请求结构 Plain Text 复制 1 GET /v1/transcodeTemplate/{templateId} HTTP/1.1 2 x-bce-date: 2020-03-25T09:28:13Z 3 host: evs.bj.baidubce.com 4 content-type: application/json 5 authorization
Bash 复制 1 # 启动消费者 2 go consumer.go 3 # 启动生产者 4 go producer.go 步骤四:查看集群监控 查看消息是否发送成功或消费成功有两种方式: 查看程序输出日志。 在专享版消息服务 for Kafka控制台查看集群监控,获取集群生产、消息情况。 推荐使用第二种方式,下面介绍如何查看集群监控。
删除队列 描述 删除指定队列 请求结构 Bash 复制 1 DELETE /api/v1/resourcepools/ { resourcePoolId } /queue/ { queueName } 2 Host:aihc.bj.baidubce.com 3 Authorization:authorization string 4 ContentType: application/json 请求头域
队列(Queue) 存储消息的物理单元,一个主题可以被分为多个队列,分布在不同的Broker上。 生产者(Producer) 负责发送消息到 RocketMQ 服务器的应用程序。 消费者(Consumer) 从 RocketMQ 服务器接收并处理消息的应用程序。 Broker RocketMQ 服务器,负责接收、存储和转发消息。
管理队列 CHPC支持将运行不同作业或执行不同任务的计算节点进行分类,便于筛选节点。 本文介绍如何在CHPC管理控制台创建队列、将节点加入队列和删除队列。 创建队列 登录CHPC控制台: https://console.bce.baidu.com/chpc/# 在顶部菜单栏左上角处,选择地域。 在左侧导航栏,选择队列管理。 在上方选择目标集群。 单击『创建队列』。
producer < broker > < topic > < username > < password > 步骤五:查看集群监控 查看消息是否发送成功或消费成功有两种方式: 在服务器端/控制台查看日志。 在专享版消息服务 for Kafka控制台查看集群监控,获取集群生产、消息情况。 推荐使用第二种方式,下面介绍如何查看集群监控。
查询队列详情 描述 获取指定队列详情,包括队列基本信息以及资源使用量等 请求结构 Bash 复制 1 GET /api/v1/resourcepools/ { resourcePoolId } /queue/ { queueName } 2 Host:aihc.bj.baidubce.com 3 Authorization:authorization string 4 ContentType: application
优先级队列 RabbitMQ支持按照消息优先级的高低来消费消息的队列。生产者在发送消息时,需要设置该消息的优先级,RabbitMQ按照队列中优先级高低的顺序来执行消费。 死信队列 消息在消费失败、TTL过期、队列长度超限之后会被重新发送到一个特殊的Exchange,即dead letter exchange(DLX),进入到DLX的消息不会被重新发送到原来的队列重新消费。