检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
是否开启公网访问功能。默认不开启公网。 true:开启 false:不开启 publicip_id String 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 如果开启了公网访问功能(即enable_publicip为true),该字段为必选。 broker_num Integer
识别,达到权限管理的目的。开启ACL权限控制功能后,生产消息和消费消息时,需要鉴权。 约束与限制 仅2021年8月21号后购买的实例,支持设置ACL访问控制。 开启ACL访问控制会导致没有配置认证信息的客户端连接中断。 前提条件 已购买RocketMQ实例。 开启RocketMQ
创建消费组后不能修改名称。 关联代理 RocketMQ实例的版本为4.8.0时,需要设置此参数。 选择需要创建消费组的代理,支持选择多个代理,可同步创建消费组,无需为每个代理单独创建。 创建消费组后不能修改关联代理。 最大重试次数 设置普通消费的最大重试次数。 取值范围:1~16 如果是顺序消费,可
DefaultMQPushConsumer("please_rename_unique_group_name"); //填入连接地址 consumer.setNamesrvAddr("192.168.0.1:8100"); consumer
通过suspendTimeMillis设置重试时间间隔。 默认值为1000ms,即1s。 通过消费者的setMaxReconsumeTimes函数配置最大重试次数。若未设置参数值,默认为无限重试。 普通消费 重试时间间隔根据重试次数阶梯变化,如表2所示。 创建消费组时设置。 取值范围:1-16。
详情页面。 在左侧导航栏,单击“消息查询”,进入“消息查询”页面。 在页面顶部设置查询条件,查询待重新发送的消息。 在待重新发送的消息所在行,单击“消费验证”,弹出“消费验证”对话框。 参考表1,设置消费验证参数。 表1 消费验证参数说明 参数 说明 Group ID 选择待进行消费验证的消费组名称。
RocketMQ Kafka RabbitMQ 优先级队列 不支持 不支持 3.8.35版本:支持。建议优先级大小设置在0-10之间。 AMQP-0-9-1版本:支持。优先级大小设置在1-9之间。 延迟队列 支持 不支持 3.8.35版本:不支持。 AMQP-0-9-1版本:支持。 死信队列
Topic的权限,包括发布+订阅、发布和订阅。 关联代理 选择在某个代理上创建Topic,并设置Topic的队列个数。 如果实例部署在多个代理上,单击“添加关联代理”,可以在其他代理上创建Topic,并设置Topic的队列个数。 如果需要新增关联代理,则需要先扩容代理个数,具体操作请参见变
如果您持有多台到期日不同的RocketMQ实例,可以将到期日统一设置到一个日期,便于日常管理和续费。 图5展示了用户将两个不同时间到期的资源,同时续费一个月,并设置“统一到期日”后的效果对比。 图5 统一到期日 更多关于统一到期日的规则请参见如何设置统一到期日。 父主题: 续费
消息的生产和消费。相关代码您可以从rocketmq-springboot-demo中获取。 下文所有RocketMQ的配置信息,如实例连接地址、Topic名称、用户信息等,请参考收集连接信息获取。 在pom.xml文件中引入RocketMQ-Spring依赖 <dependency>
添加表2和表3的规则。 表2 安全组规则(RocketMQ实例4.8.0版本) 方向 协议 端口 源地址 说明 入方向 TCP 8100 RocketMQ客户端所在的IP地址或地址段。 使用TCP协议,通过内网访问元数据节点的端口。 入方向 TCP 8200 使用TCP协议,通过公网访问元数据节点的端口。
客户端数 定时/延时消息 事务消息 顺序消息 Min(单客户端线程数 * 客户端数,队列数) 单客户端线程数的调整需谨慎,不能盲目调大线程数,如果设置过大的线程数反而会带来大量的线程切换开销。 理想环境下单客户端的最优线程数计算模型为:C *(T1+T2)/T1。 其中,C为单机vCPU
选择“明细账单”,在筛选条件中选择“资源ID”,并输入3复制的资源ID,按“Enter”即可搜索该资源的账单。 图3 查询资源账单 这里设置的统计维度为“按使用量”,统计周期为“按账期”,您也可以设置其他统计维度和周期,详细介绍请参见流水与明细账单。
审计与日志 云审计服务(Cloud Trace Service,简称CTS),是华为云安全解决方案中专业的日志审计服务,提供对各种云资源操作记录的收集、存储和查询功能,可用于支撑安全分析、合规审计、资源跟踪和问题定位等常见应用场景。 用户开通云审计服务并创建和配置追踪器后,CTS可记录DMS
Management,简称IAM),支持三种身份认证方式:用户名密码、访问密钥、临时访问密钥。同时还提供登录保护及登录验证策略。 访问控制 对企业中的员工设置不同的DMS for RocketMQ访问权限,以达到不同员工之间的权限隔离,使用IAM进行精细的权限管理。该服务提供用户身份认证、权限分
享版页面。 在左侧导航栏选择“回收站”,进入“回收站”页面。 单击“回收站策略”,弹出“回收站策略”对话框。 开启启用回收站,并设置保留天数(只能设置为1~7天),单击“确定”。 修改保留天数仅对修改后删除的实例生效,修改前已在回收站中的实例依然按照修改前的天数保留实例。 恢复RocketMQ实例
Transfer)风格API,支持您通过HTTPS请求调用,调用方法请参见如何调用API。 终端节点 终端节点(Endpoint)即调用API的请求地址,不同服务不同区域的终端节点不同,您可以从地区和终端节点中查询所有服务的终端节点。 约束与限制 您能创建的实例数上限,具体请参见服务配额。
TransactionMQProducer("please_rename_unique_group_name"); //填入连接地址 producer.setNamesrvAddr("192.168.0.1:8100"); //producer
type String 产品类型,single或者cluster。 product_id String 产品ID。 ecs_flavor_id String ECS的flavor id。 billing_code String CBC的规格码。 arch_types Array of
String broker名称 broker_id Integer broker的ID address String 地址 public_address String 公网地址 请求示例 GET https://{endpoint}/v2/{project_id}/{engine}/in