检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
差距小于0.1s,他们投递的顺序与他们发送的顺序无法确保一致。 无法确保定时消息仅投递一次,定时消息可能会重复投递。 定时消息的定时时间是服务端开始向消费端投递的时间。如果消费者当前有消息堆积,那么定时消息会排在堆积消息后面,将不能严格按照配置的时间进行投递。 由于客户端和服务端
差距小于0.1s,他们投递的顺序与他们发送的顺序无法确保一致。 无法确保定时消息仅投递一次,定时消息可能会重复投递。 定时消息的定时时间是服务端开始向消费端投递的时间。如果消费者当前有消息堆积,那么定时消息会排在堆积消息后面,将不能严格按照配置的时间进行投递。 由于客户端和服务端
时服务端会认为消息投递失败。为了保证消息至少被消费一次,服务端会尝试投递之前已被处理过的消息,最终消费者会消费到两条内容一样的重复消息。 实施方法 从上面的消费重复场景可以看到,不同Message ID的消息可能有相同的消息内容,因此Message ID无法作为消息的唯一标识符。
差距小于0.1s,他们投递的顺序与他们发送的顺序无法确保一致。 无法确保定时消息仅投递一次,定时消息可能会重复投递。 定时消息的定时时间是服务端开始向消费端投递的时间。如果消费者当前有消息堆积,那么定时消息会排在堆积消息后面,将不能严格按照配置的时间进行投递。 由于客户端和服务端
差距小于0.1s,他们投递的顺序与他们发送的顺序无法确保一致。 无法确保定时消息仅投递一次,定时消息可能会重复投递。 定时消息的定时时间是服务端开始向消费端投递的时间。如果消费者当前有消息堆积,那么定时消息会排在堆积消息后面,将不能严格按照配置的时间进行投递。 由于客户端和服务端
照RocketMQ实例实际使用时长计费。关于两种计费模式的详细介绍请参见计费模式概述。 在购买RocketMQ实例后,如果发现当前计费模式无法满足业务需求,您还可以变更计费模式。详细介绍请参见变更计费模式概述。 计费项 分布式消息服务RocketMQ版的计费项由实例费用和存储空间
创建Topic时,请确保唯一性。Topic名称命名规则必须满足如下要求: 长度为3~64个字符。 只能由英文字母、数字、百分号、竖线、中划线、下划线组成。 不能以“rmq_sys_”开头。 不能和以下字符串相同: TBW102 SCHEDULE_TOPIC_XXXX BenchmarkTest RMQ_SYS_TRANS_HALF_TOPIC
默认Topic权限 指定用户的默认Topic权限。 取值范围: 禁止:表示用户既不可以往Topic发送消息,也不能消费Topic中的消息。 发布:表示用户只可以往Topic发送消息,不能消费Topic中的消息。 订阅:表示用户不可以往Topic发送消息,但可以消费Topic中的消息。 发布+订阅
TransactionStatus.ROLLBACK:回滚事务,消息将被丢弃不允许消费。 TransactionStatus.UNKNOWN:无法判断状态,期待服务端向生产者再次回查该消息的状态。 订阅事务消息 订阅事务消息的代码与订阅普通消息的代码相同。 父主题: Python(TCP协议)
到用户之间的权限隔离。 支持区域: 全部 创建用户 死信队列 死信队列用于处理无法被正常消费的消息。 一条消息初次消费失败会被重试消费,若重试次数达到最大值(默认16次,在客户端可配置)时,依然消费失败,则其将被投递到该消费者对应的特殊队列(即死信队列)中,这种消息被称为死信消息。
差距小于0.1s,他们投递的顺序与他们发送的顺序无法确保一致。 无法确保定时消息仅投递一次,定时消息可能会重复投递。 定时消息的定时时间是服务端开始向消费端投递的时间。如果消费者当前有消息堆积,那么定时消息会排在堆积消息后面,将不能严格按照配置的时间进行投递。 由于客户端和服务端
当实例的“状态”变为“运行中”时,说明实例创建成功。 当实例的“状态”变为“创建失败”,请参考删除RocketMQ实例,删除创建失败的实例,然后重新创建。如果重新创建仍然失败,请联系客服。 创建失败的实例,不会占用其他资源。 自定义购买RocketMQ实例 进入购买RocketMQ实例页面。
根据消息类型判断:RocketMQ的消息可分为普通消息、顺序消息、定时/延迟消息、事务消息,不同类型的消息需要用不同的Topic来区分,无法通过Tag区分。 根据消息优先级判断:在业务中紧急程度高和紧急程度一般的消息用不同的Topic来区分,方便后续业务处理。 根据业务关联性判
ketMQ实例状态变为“已冻结”,您将无法对处于保留期的包年/包月RocketMQ实例执行任何操作。 资源保留期到期未续费,释放且不可恢复。 如果包年/包月RocketMQ实例在保留期到期前仍未续费,那么RocketMQ实例将被释放,数据无法恢复。释放的实例会被彻底删除,不会进入回收站。
在待查询消息所在行,单击“查看详情”,查看消息的具体内容。 消息的具体内容包括消息大小、消息的生成时间以及消息的内容。 图1 查看消息详情 消息体大于4096字节时,在控制台无法显示所有的内容,单击“下载消息”,在下载的JSON文件中查看消息体。 单击“复制消息”可以复制消息的内容。 父主题: 管理消息
LocalTransactionState.ROLLBACK_MESSAGE:回滚事务,消息将被丢弃不允许消费。 LocalTransactionState.UNKNOW:无法判断状态,期待服务端向生产者再次回查该消息的状态。 订阅事务消息 订阅事务消息的代码与订阅普通消息的代码相同。 父主题: Java(TCP协议)
log.error("Failed to begin transaction", e); //事务分支开启失败,直接退出。 return; } try { final SendReceipt
执行本地事务,并确定本地事务结果。 * 1. 如果本地事务提交成功,则提交消息事务。 * 2. 如果本地事务提交失败,则回滚消息事务。 * 3. 如果本地事务未知异常,则不处理,等待事务消息回查。 *
s 提交扩容实例请求失败 reliability extendDMSInstanceFailure 删除创建失败的DMS实例成功 reliability deleteDMSCreateFailureInstancesSuccess 删除创建失败的DMS实例失败 reliability
分布式消息服务RocketMQ,进入RocketMQ实例主界面,单击右上角“购买RocketMQ实例”,尝试购买RocketMQ实例,如果无法购买RocketMQ实例(假设当前权限仅包含DMS ReadOnlyAccess),表示“DMS ReadOnlyAccess”已生效。