检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
单击消息所在行的“消息轨迹”,弹出“查看详情”对话框,在“消息轨迹”页签中查看消息是否消费成功。 图3 消息轨迹 消息轨迹的参数说明如表3所示。 表3 消息轨迹的参数说明 参数 参数说明 生产者状态 生产者状态如下: 发送成功:消息发送成功,服务端已经成功存储消息。 生产耗时 生产者发送消息的耗时,单位ms。 地址
以下两类: 生产者发送消息时发生消息重复: 生产者发送消息时,消息成功发送至服务端。如果此时发生网络闪断,导致生产者未收到服务端的响应,此时生产者会认为消息发送失败,因此尝试重新发送消息至服务端。当消息重新发送成功后,在服务端中就会存在两条内容相同的消息,最终消费者会消费到两条内容一样的重复消息。
开启公网访问功能大约需要10~30s,请耐心等待。开启公网访问后,页面会自动跳转到“后台任务管理”页签,当任务状态为“成功”时,表示开启公网访问成功。 在RabbitMQ实例的安全组中设置如表1所示规则后,才能成功通过IPv4弹性IP地址连接RabbitMQ。 表1 安全组规则 方向 类型 协议 端口 源地址
设置Exchange持久化(WebUI) 设置成功后如图2所示。 图2 持久化的Exchange(WebUI) 在RabbitMQ实例控制台设置Exchange持久化。 创建Exchange时,设置Exchange持久化,如图3所示。 图3 设置Exchange持久化(控制台) 设置成功后如图4所示。 图4
"67fc5f8d-3986-4f02-bb75-4075a23112de" } ] } 状态码 操作成功的状态码如表5所示,其他响应见状态码。 表5 状态码 状态码 描述 200 删除实例成功。 父主题: 实例管理类接口
connection = connectionFactory.newConnection(); 设置“clientProperties”参数后,连接地址显示如图2所示。 图2 客户端连接地址(分区生产者/消费者IP地址) 父主题: 管理实例
"mirror-queue", "routing_key" : "routing_key_1" } 响应示例 状态码: 200 添加绑定成功 { "source" : "exchange_name", "destination_type" : "Queue", "destination"
续费操作仅适用于包年/包月RabbitMQ实例,按需计费RabbitMQ实例不需要续费,只需要保证账户余额充足即可。 RabbitMQ实例在到期前续费成功,所有资源得以保留,且RabbitMQ实例的运行不受影响。RabbitMQ实例到期后的状态说明,请参见到期后影响。 续费相关的功能 包年/
定义TTL,单位为ms。填写“expires”参数,值设置为“1”,表示队列过期时间为1ms。 单击“Add policy”。 在“Queues”页签,查看队列是否成功删除。 队列成功删除后,在“Admin > Policies”页面中,在2中新增的策略后,单击“Clear”,删除策略。 如果保留此策略,它对后续
配置RabbitMQ单一活跃消费者 单一活跃消费者(Single Active Consumer)表示队列中可以注册多个消费者,但是只允许一个消费者消费消息,只有在此消费者出现异常时,才会自动转移到另一个消费者进行消费。单一活跃消费者适用于需要保证消息消费顺序性,同时提供高可靠能力的场景。
Direct Exchange和Topic Exchange需要设置Routing Key,Exchange会将消息路由到Routing Key匹配成功的目标Exchange中。如果不设置Routing Key,Exchange会将消息路由到所有与它绑定的目标Exchange中。 x-consistent-hash
如果未创建Vhost,进入RabbitMQ控制台的“Vhost列表”页面,创建Vhost。 如果是Vhost名称填错了,请参考RabbitMQ控制台的“Vhost列表”页面显示的Vhost名称,修改连接URL和配置文件。 父主题: 连接问题
当一个携带着Routing Key的消息被发送给Topic Exchange时,Topic Exchange会将Routing Key进行通配符匹配,如果匹配成功,则将它路由给对应的Queue。 Topic Exchange的通配符包括“*”和“#”,单词间通过“.”隔开,例如test.#。 *表示一个单词。
发起请求的用户被授予授权项所对应的策略,该用户才能成功调用该接口。例如,用户要调用接口来创建RabbitMQ实例,那么这个IAM用户被授予的策略中必须包含允许“dms:instance:create”的授权项,该接口才能调用成功。 支持的授权项 策略包含系统策略和自定义策略,如果
Direct Exchange和Topic Exchange需要设置Routing Key,Exchange会将消息路由到Routing Key匹配成功的Queue中。如果不设置Routing Key,Exchange会将消息路由到所有与它绑定的Queue中。 x-consistent-hash
专享版页面。 单击待开启插件的实例名称,进入实例详情页面。 在“插件管理”页签,单击待开启插件后的“开启”。 确认开启后,等待实例插件开启成功。 父主题: 管理实例
在RabbitMQ实例到期前均可开通自动续费,到期前7日凌晨3:00首次尝试自动续费,如果扣款失败,每天凌晨3:00尝试一次,直至RabbitMQ实例到期或者续费成功。 开通自动续费后,还可以手动续费该RabbitMQ实例。手动续费后,自动续费仍然有效,在新的到期时间前的第7天开始扣款。 自动续费的到期
Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 批量删除实例成功。 204 删除所有创建失败的RabbitMQ实例成功。 错误码 请参见错误码。 父主题: 生命周期管理
队列将镜像到一个主节点和一个从节点上。这样配置既保证了数据的高可用性,又避免了不必要的资源开销。 单击“Add policy”。 策略添加成功后如下图所示。 图4 Vhost策略 父主题: 管理RabbitMQ Queue
会对性能产生影响。如果生产者要满足at least once,就必须使用同步等待方式。 消费者确认 消费者确认是指服务端通过确认消息是否成功被消费者接收,来判断是否删除队列中的此消息。 消费者确认对数据可靠性十分重要,接收重要消息的消费应用程序在未处理完消息前不应确认消息,以便