检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
hange。 下线范围 下线区域:所有区域 下线原因 开启延迟消息插件的实例,延迟消息堆积后存在以下风险: 延迟消息存储在Mnesia内存数据库中,堆积过多(数十万甚至数百万条)可能触发内存高水位阻塞生产消息,具体请参见Limitations。 延迟消息堆积数量越多,Rabbit
退订”,退订成功后,RabbitMQ实例会自动被删除。 删除的实例能否恢复取决于是否开启回收站策略,如果未开启回收站策略,实例删除后,实例中原有的数据将被删除,且没有备份。回收站策略默认关闭,如果需要开启,具体步骤请参见开启回收站策略。 前提条件 RabbitMQ实例状态为运行中、故障、
RabbitMQ暂不支持数据加密,建议不要将敏感数据存入消息队列。 构建数据的恢复和容灾能力 预先构建数据的容灾和恢复能力,可以有效避免异常数据处理场景下数据误删、破坏的问题。 建议使用RabbitMQ集群实例,获得异常场景数据快速恢复能力。 在生产环境中建议使用RabbitMQ集群实例
导致内存溢出。AMQP协议引入了通道的概念,一个连接中可以有多个通道。连接是长期存在的,AMQP连接的握手过程比较复杂,至少需要7个TCP数据包(如果使用TLS会更多)。相对连接来说,打开和关闭通道会更简单,但是建议通道也设置为长期存在的。例如,应该为每个生产者线程重用相同的通道
上表中TPS(即生产+消费的TPS)是指以2K大小的消息为例的每秒处理消息条数,测试场景为不开启持久化的非镜像队列,实时生产实时消费,队列无积压。此数据仅供参考,生产使用需要以实际压测性能为准。 服务端的性能主要跟以下因素相关:队列数、消息堆积、连接数、channel、消费者数、镜像队列、
本章节以分布式消息服务RabbitMQ版提供的demo为例,介绍RabbitMQ客户端如何连接开启SSL的RabbitMQ实例,并生产和消费消息。开启SSL访问,则数据加密传输,安全性更高。 前提条件 已购买RabbitMQ实例,并记录创建时输入的用户名和密码,实例开启SSL。 在实例详情中查看并记录“内网连接地址/公网连接地址”。
基于RabbitMQ进行描述。 消息 消息一般分为两部分,消息体和标签,标签主要用来描述这条消息,消息体是消息的内容,是一个JSON体或者数据等。 生产者发送消息,消费者消费消息,生产者与消费者彼此并无直接关系。 生产者(Producer) 即向队列发送消息的一方。发布消息的最终
分布式消息服务RabbitMQ专享版页面。 在左侧导航栏选择“回收站”,进入“回收站”页面。 单击“导出 > 导出全部数据到XLSX”/“导出 > 导出已选中数据到XLSX”,导出实例列表。 删除回收站中的实例 登录管理控制台。 在管理控制台左上角单击,选择RabbitMQ实例所在的区域。
配置RabbitMQ消息确认机制 RabbitMQ的消息确认机制分为生产者确认和消费者确认。在使用RabbitMQ时,生产者确认和消费者确认对于确保数据可靠性至关重要。如果连接失败,传输中的消息可能会丢失,需要重新传输。消息确认机制可以让服务端和客户端知道何时重新传输消息。客户端可以在收到
MQ实例。 图1 迁移元数据 迁移步骤如下: 登录原RabbitMQ的WebUI页面,在“Overview”页签中,单击“Download broker definitions”,导出元数据。 图2 导出元数据 登录目标RabbitMQ的WebUI页面,在“Overview”页签中,单击“选择文件”,选择1
消费者根据messageID对消息进行幂等处理,示例代码如下: //创建一个以messageID为主键的数据库表,利用数据库主键去重的方式来处理RabbitMQ幂等。 //在消费者消费前先去数据库查询这条消息是否存在,如果存在表示消息已被消费,无需处理;如果不存在表示消息未被消费,执行消费操作
WebUI) 登录RabbitMQ WebUI。 在“Queues”页签,单击需要清空数据的队列名称,进入队列详情页面。 图1 Queues 单击“Purge Messages”,清空队列数据。 图2 清空队列数据 父主题: 管理RabbitMQ Queue
查看监控指标与配置告警 查看RabbitMQ监控数据 RabbitMQ支持的监控指标 配置RabbitMQ监控告警
监控告警问题 云监控无法展示RabbitMQ监控数据 云监控显示通道数一直上升报警有影响吗?
安全 责任共担 身份认证与访问控制 数据保护技术 审计与日志 服务韧性 监控安全风险 认证证书
表示镜像队列中消息的同步方式,有效取值范围为:automatic和manual。 automatic:表示自动向master同步数据。 manual:表示手动向master同步数据。 ha-mode: 指明镜像队列的模式,有效取值范围为:all、exactly和nodes。 all:表示在集群所有的节点上进行镜像。
服务可用性 99.95%集群分布式高可用架构,多可用区高可用。 使用Erlang语言开发,运维靠经验摸索,且无法避免开源架构的稳定性痛点。 数据可靠性 数据三副本,不会影响TPS性能。 配置副本数变多会导致TPS下降。 巡检系统 自动发现并修复死锁、宕机等问题。 无。 Exchange 表3
占RabbitMQ实例,每个RabbitMQ之间互不影响。 高性能 单队列性能最高可达10万TPS(默认配置),增加队列可获得更高性能。 数据安全 独有的安全加固体系,提供业务操作云端审计,消息存储加密等有效安全措施。 在网络通信方面,除了提供SSL认证,还借助虚拟私有云(VPC)和安全组等加强网络访问控制。
RabbitMQ集群实例如何均衡分发请求到每个虚拟机? RabbitMQ实例集群内部的队列是否有冗余备份? RabbitMQ实例是否支持持久化,如何定时备份数据? RabbitMQ实例开启SSL后,证书怎么获取? RabbitMQ实例的SSL开关是否支持修改? RabbitMQ实例是否支持扩容? RabbitMQ支持双向认证吗?
ers和Fanout四种路由方式,同时支持交换机组合和自定义。 高可用 RabbitMQ集群提供仲裁队列,在RabbitMQ节点间进行队列数据的复制,在一个节点宕机时,队列依旧可以正常运行。 监控和告警 支持对RabbitMQ实例状态进行监控,支持对集群每个代理的内存、CPU、网