-
预取值 - 分布式消息服务RabbitMQ版
consumer = new QueueingConsumer(channel); channel.basicConsume("my_queue", false, consumer); 在Java客户端中,global的默认值为false,因此以上示例可以简单地写为channel.basicQos
-
SSL方式连接RabbitMQ实例失败? - 分布式消息服务RabbitMQ版
(user); factory.setPassword(password); factory.useSslProtocol(); Connection connection = factory.newConnection();
-
快速入门 - 分布式消息服务RabbitMQ版
engine_version:消息引擎的版本。 storage_space:消息存储空间,单位GB。具体取值范围,请参考创建实例。 access_user:登录RabbitMQ的用户名,由您自行定义。 password:登录RabbitMQ的密码,由您自行定义。
-
创建Exchange - 分布式消息服务RabbitMQ版
headers:该类型Exchange与Routing Key无关,匹配机制是匹配消息中的Headers属性信息。Header Exchange根据消息Headers属性键值对和绑定属性键值对的匹配情况路由消息。 自动删除 是否开启自动删除Exchange。
-
云审计服务支持的DMS for RabbitMQ操作列表 - 分布式消息服务RabbitMQ版
创建DMS实例订单失败 rabbitmq createDMSInstanceOrderFailure 修改DMS实例订单成功 rabbitmq modifyDMSInstanceOrderSuccess 修改DMS实例订单失败 rabbitmq modifyDMSInstanceOrderFailure
-
网络异常自动恢复 - 分布式消息服务RabbitMQ版
ConnectionFactory factory = new ConnectionFactory(); // enable automatic recovery if using RabbitMQ Java client library prior to version 4.0.0
-
查询产品规格列表 - 分布式消息服务RabbitMQ版
URI GET /v2/products 表1 Query参数 参数 是否必选 参数类型 描述 engine 否 String 消息引擎的类型。当前只支持rabbitmq。
-
创建实例 - 分布式消息服务RabbitMQ版
engine_version String 否 消息引擎的版本。 storage_space Integer 是 消息存储空间,单位GB。 单机RabbitMQ实例的存储空间的取值范围100GB~90000GB。
-
RabbitMQ相关概念 - 分布式消息服务RabbitMQ版
生产者(Producer) 即向队列发送消息的一方。发布消息的最终目的在于将消息内容传递给其他系统/模块,使对方按照约定处理该消息。 消费者(Consumer) 接收消息的一方。消费者订阅RabbitMQ的队列,当消费者消费一条消息时,只是消费消息的消息体。
-
删除Queue - 分布式消息服务RabbitMQ版
curl -i -XDELETE http://${USERNAME}:${PASSWORD}@${HOST}:${PORT}/api/queues/${VHOST_NAME}/${QUEUE_NAME} 参数说明如下: USERNAME:创建实例时设置的用户名。
-
设置实例镜像队列 - 分布式消息服务RabbitMQ版
automatic:表示自动向master同步数据。 manual:表示手动向master同步数据。 ha-mode: 指明镜像队列的模式,有效取值范围为:all、exactly和nodes。 all:表示在集群所有的节点上进行镜像。
-
开启实例插件 - 分布式消息服务RabbitMQ版
rabbitmq_shovel和rabbitmq_federation插件在特定场景下才支持开启,具体如表2所示。
-
支持的监控指标 - 分布式消息服务RabbitMQ版
单位:个 0~50000 RabbitMQ实例节点 1分钟 proc_used Erlang进程数 该指标用于统计当前节点RabbitMQ所使用的Erlang进程数。
-
快速连接RabbitMQ并生产消费消息 - 分布式消息服务RabbitMQ版
本文以Linux系统的弹性云服务器(Elastic Cloud Server,简称ECS)作为生产消费客户端。在创建RabbitMQ实例前,请先创建开启弹性公网IP的ECS、安装JDK以及配置环境变量。
-
构造请求 - 分布式消息服务RabbitMQ版
请求响应成功后在响应消息头(Headers)中包含的“X-Subject-Token”的值即为Token值。 否 使用Token认证时该字段必选。 注:以下仅为Token示例片段。
-
按需计费 - 分布式消息服务RabbitMQ版
第一条对应9:00:00 ~ 9:30:00,实例规格按照rabbitmq.2u4g.cluster*3计费。 第二条对应9:30:00 ~ 10:00:00,实例规格按照rabbitmq.4u8g.cluster*3计费。
-
分布式消息服务RabbitMQ版 - 分布式消息服务RabbitMQ版
API 分布式消息服务RabbitMQ版提供了REST(Representational State Transfer)风格API,支持您通过HTTP/HTTPS请求调用,实现创建、修改、删除实例等操作。 支持区域: 全部 API概览
-
与Kafka、RocketMQ的差异 - 分布式消息服务RabbitMQ版
采用Erlang编写,支持多种语言的客户端。 流量控制 待规划 支持client和user级别,通过主动设置可将流控作用于生产者或消费者。 RabbitMQ的流控基于Credit-Based算法,是内部被动触发的保护机制,作用于生产者层面。
-
DMS for RabbitMQ自定义策略 - 分布式消息服务RabbitMQ版
DMS for RabbitMQ自定义策略样例 示例1:授权用户创建实例和删除实例 { "Version": "1.1", "Statement": [ { "Effect": "Allow", "Action
-
开启心跳 - 分布式消息服务RabbitMQ版
# 设置心跳时间为60秒 params = pika.ConnectionParameters(host='host', heartbeat=60, credentials=pika.PlainCredentials('username', 'passwd')) connection