检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
queueDeclare方法的时候在参数中设置,也可以通过Policy的方式设置。如果一个队列同时使用这两种方式设置的话,Policy的方式具备更高的优先级。 以下示例演示在Java客户端通过调用channel.queueDeclare设置惰性队列。 Map<String, Object>
UTF_8)); 在Web界面中设置expiration值,单位为毫秒(ms)。 登录Web界面,在“Exchanges”页签,单击Exchange名称,进入Exchange详情页。在“Publish message”区域,设置expiration值,如下图所示。 设置队列过期时间。
需要开启。 图1 设置实例信息 设置连接RabbitMQ实例的用户名和密码。 用户名需要符合以下命名规则:由英文字母开头,且只能由英文字母、数字、中划线、下划线组成,长度为4~64个字符。 密码需要符合以下命名规则: 长度为8~32个字符。 至少包含以下字符中的3种:大写字母、小写字母、数字、特殊字符`~
RabbitMQ的消息确认机制分为生产者确认和消费者确认。在使用RabbitMQ时,生产者确认和消费者确认对于确保数据可靠性至关重要。如果连接失败,传输中的消息可能会丢失,需要重新传输。消息确认机制可以让服务端和客户端知道何时重新传输消息。客户端可以在收到消息时确认消息,也可以在客户端完全处理完消息后确认。
Routing Key 设置Key值字符串,用于告知Exchange应该将消息投递到哪些Queue中。 Direct Exchange和Topic Exchange需要设置Routing Key,Exchange会将消息路由到Routing Key匹配成功的Queue中。如果不设置Routing
"storage_spec_code": "dms.physical.storage.ultra.v2" } name:实例名称。由您自行定义。 engine:消息引擎,设置rabbitmq。 engine_version:消息引擎的版本。 storage_space:消息存储空间,单位GB。具体取值范围,请参考创建实例。
RabbitMQ实例计费模式为“包年/包月”。 RabbitMQ实例状态为“运行中”。 在云服务控制台转按需 登录管理控制台。 单击左侧导航栏的图标,选择“应用中间件 > 分布式消息服务RabbitMQ版”。 通过以下任意一种方法,设置包年/包月资源到期后转按需。 在需要更改计费模式的RabbitMQ实例所在行,单击操作列“更多
false, arguments); 以下示例演示在RabbitMQ WebUI页面设置单一活跃消费者。 图2 设置单一活跃消费者 设置完成后,在“Queues”页面查看队列特性是否包含单一活跃消费者。如图3所示,“SAC”即表示队列已设置单一活跃消费者。 图3 查看队列特性 父主题:
磁盘类型选择“超高I/O”,磁盘大小设置为“100GB”。 图2 设置实例基础信息 设置实例网络环境信息,如图3所示,配置详情请参考表3。 表3 设置实例网络环境信息 参数 说明 虚拟私有云 虚拟私有云和子网在RabbitMQ实例创建完成后,不支持修改。 选择准备工作中设置好的虚拟私有云和子网。
Management,简称IAM),通过IAM,您可以: 根据企业的业务组织,在您的华为账号中,给企业中不同职能部门的员工创建IAM用户,让员工拥有唯一安全凭证,并使用DMS for RabbitMQ资源。 根据企业用户的职能,设置不同的访问权限,以达到用户之间的权限隔离。 将DMS for R
创建Vhost 选择右侧导航栏“Policies”,为Vhost设置策略。 图3 设置Vhost策略 表1 策略参数说明 参数 说明 Virtual Host 设置策略所应用的Vhost。如果为指定的Vhost设置,请在“Virtual Host”选择3创建的Vhost;如果没有,则默认为“/”。
全局消息预取(Qos) 支持 不支持 配置仲裁队列 在声明队列时,将队列的“x-queue-type”参数设置为“quorum”。此参数只能在声明队列时设置,不能通过Policy设置。 仲裁队列默认的复制因子是5。 以下示例演示在Java客户端设置仲裁队列。 ConnectionFactory
AMQP-0-9-1版本包含此参数。 设置Queue的优先级,取值范围为1~9。数值越大,优先级越高。 惰性队列模式 仅RabbitMQ 3.x.x版本包含此参数。 如果需要设置Queue为惰性队列,请输入“lazy”。 惰性队列会尽可能的将消息存入磁盘中,在消费者消费到相应的消息时才会被加载到内存中,这样可以减少内存的消耗。
Vhost信息 Vhost创建成功后,可以在控制台查看Vhost中包含的Exchange和Queue的数量,以及详细信息。 查看RabbitMQ Vhost信息 登录管理控制台。 在管理控制台左上角单击,选择区域。 此处请选择RabbitMQ实例所在的区域。 在管理控制台左上角单击,选择“应用中间件
定义TTL,单位为ms。填写“expires”参数,值设置为“1”,表示队列过期时间为1ms。 单击“Add policy”。 在“Queues”页签,查看队列是否成功删除。 队列成功删除后,在“Admin > Policies”页面中,在2中新增的策略后,单击“Clear”,删除策略。 如果保留此策略,它对后续
RELEASE</version> </dependency> (可选)在application.properties文件中填写配置 如果RabbitMQ实例已开启SSL,在“application.properties”文件中填写如下配置。 #开启SSL认证 spring.rabbitmq
延迟消息存储在Mnesia内存数据库中,堆积过多(数十万甚至数百万条)可能触发内存高水位阻塞生产消息,具体请参见Limitations。 延迟消息堆积数量越多,RabbitMQ节点启动加载耗时越久,可能导致节点重启后无法快速恢复业务。 延迟消息在RabbitMQ中为单副本存储,
的Queue中。 topic:该类型Exchange将Routing Key进行通配符匹配,然后将消息路由到匹配成功的Queue中。 headers:该类型Exchange与Routing Key无关,而与消息中的Headers属性信息相关。Exchange根据消息中的Heade
A将会发送到Queue 1和Queue 2中,Message B将会发送到Queue 3中。 Fanout Exchange 工作原理: 如果有N个Queue绑定了Fanout Exchange,当Fanout Exchange接收到一个消息时,会将它分别路由到这N个Queue中。Fanout Exc
时,通过冗余副本自动故障切换,并且故障恢复后会从leader副本进行数据同步,保持数据一致性。 设置实例镜像队列 设置实例仲裁队列 数据持久化 业务系统日常运行中可能出现一些小概率的异常事件。部分可靠性要求非常高的业务系统,除了要求实例高可用,还要求数据安全、可恢复,以便在实例发