-
RabbitMQ消息确认机制 - 分布式消息服务RabbitMQ版
", new DefaultConsumer(channel) { @Override public void handleDelivery(String consumerTag,
-
连接未开启SSL的RabbitMQ实例 - 分布式消息服务RabbitMQ版
To exit press CTRL+C"); Consumer consumer = new DefaultConsumer(channel) { @Override public void handleDelivery(String consumerTag
-
查询指定实例 - 分布式消息服务RabbitMQ版
user_id String 用户id。 user_name String 用户名。 access_user String 实例的用户名。 order_id String 订单ID,只有在包周期计费时才会有order_id值,其他计费方式order_id值为空。
-
查询所有实例列表 - 分布式消息服务RabbitMQ版
feature.physerver.kafka.pulbic.dynamic,feature.physerver.kafka.user.manager", "trace_enable": false } ], "instance_num
-
查看客户端连接地址 - 分布式消息服务RabbitMQ版
//配置客户端连接参数 HashMap<String, Object> clientProperties = new HashMap<>(); clientProperties.put("connection_name", "producer"); connectionFactory.setClientProperties
-
RabbitMQ客户端连接报错原因分析 - 分布式消息服务RabbitMQ版
可能原因五:未创建Vhost或者填错Vhost名称 报错如下: Couldn't log in: server connection error 530, message: NOT_ALLOWED - vhost /localdev/ not found 解决方法: 如果未创建Vhost
-
连接已开启SSL的RabbitMQ实例 - 分布式消息服务RabbitMQ版
To exit press CTRL+C"); Consumer consumer = new DefaultConsumer(channel) { @Override public void handleDelivery(String consumerTag
-
实例是否支持修改可用区? - 分布式消息服务RabbitMQ版
在“Overview”页签中,单击“Download broker definitions”,导出元数据。 登录重新购买的RabbitMQ实例的WebUI页面,在“Overview”页签中,单击“选择文件”,选择2中导出的元数据。
-
批量添加或删除实例标签 - 分布式消息服务RabbitMQ版
= client.BatchCreateOrDeleteRabbitMqTag(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err
-
死信和TTL - 分布式消息服务RabbitMQ版
更多关于死信的说明,请参考Dead Letter Exchanges。 使用队列参数配置死信交换机和路由 为队列配置死信交换机,并在申明队列时指定“x-dead-letter-exchange”和“x-dead-letter-routing-key”参数。
-
新规格为什么比老规格贵? - 分布式消息服务RabbitMQ版
8u16g.cluster*3 22500 2400 8U16G*5 25000 2000 rabbitmq.8u16g.cluster*5 37500 4000 8U16G*7 35000 2800 rabbitmq.8u16g.cluster*7 52500 5600 16U32G
-
如何实现RabbitMQ的高性能 - 分布式消息服务RabbitMQ版
可以通过设置不同的overflow值来改变这种方式,如果overflow值设置为drop-head,表示从队列前面丢弃或dead-letter消息,保存后n条消息。如果overflow值设置为reject-publish,表示最近发布的消息将被丢弃,即保存前n条消息。
-
状态码 - 分布式消息服务RabbitMQ版
建议客户端读取相应的Retry-After首部,然后等待该首部指出的时间后再重试。 500 InternalServerError 表明服务端能被请求访问到,但是不能理解用户的请求。 501 Not Implemented 服务器不支持请求的功能,无法完成请求。
-
RabbitMQ业务迁移 - 分布式消息服务RabbitMQ版
curl -s -u username:password -XGET http://ip:port/api/overview 参数说明: username:原实例登录RabbitMQ WebUI的账号 password:原实例登录RabbitMQ WebUI的密码 ip:原实例登录
-
返回结果 - 分布式消息服务RabbitMQ版
{ "error_msg": "The format of message is error", "error_code": "AS.0001" } 其中,error_code表示错误码,error_msg表示错误描述信息。 父主题: 如何调用API
-
消息持久化 - 分布式消息服务RabbitMQ版
以下示例演示在Java客户端设置Message持久化 import com.rabbitmq.client.MessageProperties; channel.basicPublish("", "my_queue",MessageProperties.PERSISTENT_TEXT_PLAIN
-
查询产品规格列表 - 分布式消息服务RabbitMQ版
version String 消息引擎的版本。 values Array 产品规格列表。 表3 values参数说明 参数 类型 备注 detail Array 规格详情。 name String 实例类型,单机或者集群。
-
消息堆积对业务的影响及解决办法 - 分布式消息服务RabbitMQ版
AMQP.BasicProperties properties = new AMQP.BasicProperties().builder() .deliveryMode(2) .contentEncoding("UTF-8") .expiration("10000
-
分布式消息服务RabbitMQ版 - 分布式消息服务RabbitMQ版
连接和使用 连接未开启SSL方式的RabbitMQ实例 连接已开启SSL方式的RabbitMQ实例 连接RabbitMQ管理地址 初始化数据盘 什么是ECS 创建容器应用基本流程 05 实践 弹性云服务器(Elastic Cloud Server)是一种可随时自动获取、计算能力可弹性伸缩的云服务器
-
产品规格 - 分布式消息服务RabbitMQ版
rabbitmq.16u32g.cluster 3 300~90000 48000 32000 800 8000 5 500~150000 80000 32000 800 8000 7 700~210000 112000 32000 800 8000 rabbitmq.24u48g.cluster