检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
线程数,如果设置过大的线程数反而会带来大量的线程切换开销。 理想环境下单客户端的最优线程数计算模型为:C *(T1+T2)/T1。 其中,C为单机vCPU核数,T1为业务逻辑的CPU计算耗时,T2为外部I/O操作耗时,另外线程切换耗时忽略不计,I/O操作不消耗CPU,线程需有足够消息等待处理且内存充足。
单击“回收站策略”,弹出“回收站策略”对话框。 打开“启用回收站”开关,并设置“保留天数”,单击“确定”。 保留天数只能设置为1~7天。 修改保留天数仅对修改后删除的实例生效,修改前已在回收站中的实例依然按照修改前的天数保留实例。 恢复RocketMQ实例 登录管理控制台。 在管理控制台左上角单击,选择区域。 请选择RocketMQ实例所在的区域。
如果因为您的实例配置超过相应的约束和限制而导致的任何不稳定情况,不在SLA承诺和赔偿范围内。 实例 表1 实例约束与限制 限制项 约束与限制 版本 实例创建后,不支持变更版本。建议服务端版本和客户端版本保持一致。 存储空间 磁盘类型创建完成后不可修改。 只支持扩大存储空间,不支持减小存储空间。 扩容存储空间有次数限制,最多扩容20次。
unzip rocketmq-tutorial.zip (可选)如果RocketMQ实例开启了ACL访问控制,执行mqadmin命令时,需要鉴权。 切换到解压后的软件包目录下,在“conf/tools.yml”文件中,增加如下内容。 accessKey:******* secretKey:*******
rocketmq-all-4.9.8-bin-release.zip (可选)如果RocketMQ实例开启了ACL访问控制,执行mqadmin命令时,需要鉴权。 切换到解压后的软件包目录下,在“conf/tools.yml”文件中,增加如下内容。 accessKey:******* secretKey:*******
String 实例ID。 group 是 String 消费组名称。 请求参数 无 响应参数 无 请求示例 删除指定的消费组。 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups/{group}
项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 请求参数 无 响应参数 无 请求示例 删除指定的实例。 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id} 响应示例 无 SDK代码示例
String 实例ID。 topic 是 String 主题名称。 请求参数 无 响应参数 无 请求示例 删除指定的主题。 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics/{topic}
Number 读队列个数。 write_queue_num Number 写队列个数。 请求示例 查询指定的单个主题的详细信息。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics/{topic}
String RocketMQ配置取值的范围。 value_type String RocketMQ配置值的类型。 请求示例 GET https://{endpoint}/v2/{project_id}/rocketmq/instances/{instance_id}/configs
权限集。 consume_orderly Boolean 是否按顺序消费。 请求示例 查询RocketMQ实例的消费组列表。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups 响应示例 状态码:
String 元数据迁移任务状态。 type String 元数据迁移类型。 请求示例 查询RocketMQ实例下所有迁移任务。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/metadata 响应示例 状态码:
group_perms 参数 参数类型 描述 name String 消费组名称。 perm String 权限。 请求示例 查询用户详情。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/users/{user_name}
String RocketMQ配置目标值。 响应参数 无 请求示例 修改RocketMQ配置的参数,将文件保留时间修改为72小时。 PUT https://{endpoint}/v2/{project_id}/rocketmq/instances/{instance_id}/configs
permission 否 String 权限。 响应参数 无 请求示例 修改指定主题的参数,总读队列个数修改为3,总写队列个数修改为3。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics/{topic}
property_list 参数 参数类型 描述 name String 属性名称。 value String 属性值。 请求示例 查询消息。 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/messages
首尾字符不能为空格。 响应参数 无 请求示例 创建两个实例标签,标签名为key1、key2,值为value1、value2。 POST https://{endpoint}/v2/{project_id}/rocketmq/{instance_id}/tags/action {
com/apache/rocketmq-client-go/v2 v2.1.2 ) 执行如下命令增加代理。 export GOPROXY=https://goproxy.cn,direct 执行如下命令下载依赖。 go mod tidy 发送顺序消息 参考如下示例代码(以下加粗内容需
com/apache/rocketmq-client-go/v2 v2.1.2 ) 执行如下命令增加代理。 export GOPROXY=https://goproxy.cn,direct 执行如下命令下载依赖。 go mod tidy 发送定时消息 发送定时消息的示例代码如下(以下
com/apache/rocketmq-client-go/v2 v2.1.2 ) 执行如下命令增加代理。 export GOPROXY=https://goproxy.cn,direct 执行如下命令下载依赖。 go mod tidy 同步发送 同步发送是指消息发送方发出一条消息到