检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
务RabbitMQ版不会向个别客户提供事先通知。 最后,分布式消息服务RabbitMQ版不会针对产品中的漏洞开发或发布可利用的入侵代码(或“验证性代码”)。 父主题: 漏洞公告
实现网络异常时RabbitMQ客户端自动恢复 本章节提供了客户端重连示例代码,使客户端在网络异常导致连接断开时自动恢复连接,降低网络故障对业务的影响。 实现RabbitMQ节点重启后消费者自动重连 本章节提供了RabbitMQ节点重启后消费者自动重连示例代码,实现在通道关闭后重新为消费者创建新的通道继续消费。
消费者没有出现异常,但是消费者与队列间的订阅可能出现了异常,也会导致消息无法被消费从而造成堆积的情况。 消费者正常,与队列间的订阅也正常,但是消费端的代码本身逻辑耗费时间长导致了消费能力降低,这时候就会出现1中的情况从而导致消息堆积。 解决消息堆积的办法 生产速率较快,消费速率较慢:您可以通过以下方法解决。
如果是专属云场景采用AK/SK认证方式的接口请求,或者多project场景采用AK/SK认证的接口请求,则该字段必选。 e9993fc787d94b6c886cbaa340f9c0f4 X-Auth-Token 用户Token。 用户Token也就是调用获取用户Token接口的响应值,该接口是唯一不需要认证的接口。
else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询Exchange绑定信息列表成功 错误码 请参见错误码。 父主题:
else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 204 解绑成功 错误码 请参见错误码。 父主题: Binding管理
Close方法关闭连接,则不会启用或触发网络自动恢复。 网络异常时RabbitMQ客户端重试连接示例代码 客户端和服务端的初始连接失败,不会触发自动恢复,可在客户端编写对应的应用程序代码,通过重试连接来解决初始连接失败的问题。 以下示例演示了使用Java客户端通过重试连接解决初始连接失败的问题。
单击“确定”,完成用户的创建。 开启ACL访问控制后,消息生产者和消费者都需要增加用户认证信息(代码中需包含username和password),具体操作如下: Java代码示例 Python代码示例 编辑用户 登录管理控制台。 在管理控制台左上角单击,选择RabbitMQ实例所在的区域。
rabbitmq.single.c3.2u4g", "type" : "single", "charging_mode" : 1, "vpc_id" : "27d99e17-42f2-4751-818f-5c8c6c03ff15", "vpc_name"
"cn-north-7a" ], "available_zones" : [ "cn-north-7c" ], "ecs_flavor_id" : "c3.medium.4" } ], "unavailable_zones"
Q实例生产消息和消费消息前,需要先连接RabbitMQ实例。 分布式消息服务RabbitMQ版分别为您提供了开启和关闭SSL的示例代码,通过示例代码测试客户端和实例是否可以连接。 支持区域: 全部 连接未开启SSL方式的RabbitMQ实例 连接已开启SSL方式的RabbitMQ实例
78", "available_zones" : [ "9f1c5806706d4c1fb0eb72f0a9b18c77" ], "user_id" : "3df5acbc24a54fadb62a043c9000a307", "user_name" : "paas_dms_01"
"00300-30109-0--0", "spec_code": "dms.instance.rabbitmq.single.c3.2u4g" }, { "storage": "100",
rabbitmq.single.c3.2u4g:RabbitMQ单机,vm规格2u4g dms.instance.rabbitmq.single.c3.4u8g:RabbitMQ单机,vm规格4u8g dms.instance.rabbitmq.single.c3.8u16g:RabbitMQ单机,vm规格8u16g
"XXXXXX", available_zones:[ { "id":"1d7b939b382c4c3bb3481a8ca10da768", "name":"az10.dc1", "code":"az10
else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 修改用户参数成功。 错误码 请参见错误码。 父主题: 用户管理
"1e93f86e-13af-46c8-97d6-d40fa62b76c2", "security_group_id": "0aaa0033-bf7f-4c41-a6c2-18cd04cad2c8", "subnet_id": "b5fa806c-35e7-4299-b659-b39398dd4718"
"test", "password": "ZxxxA", "vpc_id": "eadxxxe72c", "security_group_id": "aa75axxxc8c73220", "subnet_id": "3cb6axxx671d6a8", "available_zones":
消费过。如果已经消费过,则直接返回处理结果,否则进行消息处理,并将全局ID记录下来。 生产者为每一条消息设置唯一的messageID,示例代码如下: //持久化消息,并且生成随机的全局唯一messageID AMQP.BasicProperties.Builder builder
"available_zone" : "cn-north-7c" }, { "name" : "dms-vm-0e16280d-rabbitmq-1", "available_zone" : "cn-north-7c" }, { "name" : "dms