检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Python(TCP协议) 收发普通消息 收发顺序消息 收发事务消息 发送定时消息 使用ACL权限访问
修改用户参数 功能介绍 修改用户参数。 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/instances/{instance_id}/users/{user_name} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是
name 否 String 待修改参数的消费组(消费组名称不支持修改)。 retry_max_time 是 Integer 最大重试次数,取值范围为1~16。 响应参数 无 请求示例 修改consumer-group-test消费组的参数,最大重试次数修改为16。 PUT https
修改实例信息 功能介绍 修改实例的名称和描述信息。 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/instances/{instance_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。
"permission" : "all" } 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 修改指定主题的参数,总读队列个数修改为3,总写队列个数修改为3。 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
UNKNOWN:无法判断状态,期待服务端向生产者再次回查该消息的状态。 订阅事务消息 订阅事务消息的代码与订阅普通消息的代码相同。 父主题: Python(TCP协议)
客户端连接RocketMQ实例5.x版本收发普通消息前,需要确保Topic的消息类型为“普通”。 准备环境 在命令行输入python,检查是否已安装Python。得到如下回显,说明Python已安装。 Python 3.7.1 (default, Jul 5 2020, 14:37:24) [GCC 4
定时消息将占用普通消息约3倍的存储空间,大量使用定时消息时需要注意存储空间占用。 准备环境 在命令行输入python,检查是否已安装Python。得到如下回显,说明Python已安装。 Python 3.7.1 (default, Jul 5 2020, 14:37:24) [GCC 4
"value" : 72 } ] } 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 修改RocketMQ配置的参数,将文件保留时间修改为72小时。 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15
consumer_group:表示消费组名称。 192.168.0.1:8100:表示实例连接地址和端口。 TopicTest:表示Topic名称。 父主题: Python(TCP协议)
] } 响应示例 状态码: 200 批量修改消费组成功。 { "job_id" : "8abfa7b27da211df017da340427b0979" } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 批量修改消费组的参数,将consumer-gr
ROCKETMQ_AK:表示用户名。创建用户的步骤,请参见创建用户。 ROCKETMQ_SK:表示用户的密钥。 TopicTest:表示Topic名称。 父主题: Python(TCP协议)
修改RocketMQ Topic配置 RocketMQ实例为4.8.0版本时您可以根据业务需要修改Topic的权限配置、关联代理配置和描述信息,为5.x版本时仅支持修改描述信息。 前提条件 已购买RocketMQ实例。 已创建Topic。 修改Topic信息 登录管理控制台。 在管理控制台左上角单击,选择区域。
在创建RocketMQ实例前,您需要完成注册华为云并实名认证、为账户充值、为用户添加操作权限、创建VPC和子网、创建安全组、创建弹性云服务器并配置环境的准备工作。 创建RocketMQ实例。 在创建实例时,您需要开启SSL、关闭ACL,并配置已创建的VPC和子网、安全组。 创建Topic。
表1 用户参数说明 参数 说明 名称 自定义用户名称,用于识别不同的用户。 用户名称命名规则如下: 长度为7~64个字符。 只能由英文字母、数字、中划线、下划线组成,且须以英文字母开头。 名称不可重复。 用户名创建成功后,不可修改。 IP白名单 如果请求的来源IP为IP白名单中的地址
在左侧导航栏,单击“消费组管理”,进入消费组列表页面。 选择以下任意一种方法修改消费组参数。 在待修改的消费组所在行,单击“编辑”,弹出“编辑消费组”页面。 单击待修改的消费组名称,进入消费组详情页面。在页面右上角,单击“编辑”,弹出“编辑消费组”页面。 修改如表1所示配置信息。 表1 消费组参数说明 参数
修改RocketMQ消息保留时间 消息老化时间即消息的最长保留时间,消费者必须在此时间结束前消费消息,否则消息将被删除。删除的消息,无法被消费。 正常消息的保留时间和死信消息的保留时间都是由消息老化时间控制,消息老化时间修改后,正常消息的保留时间和死信消息的保留时间都会被修改。
务不会中断。 客户端为密文传输时,修改服务端接入方式后,实例不会重启,业务会中断,需要在客户端修改实例接入方式。 PERMISSIVE > SSL 客户端为密文传输时,修改服务端接入方式后,实例不会重启,业务不会中断。 客户端为明文传输时,修改服务端接入方式后,实例不会重启,业务会中断,需要在客户端修改实例接入方式。
RocketMQ实例的SSL开关是否支持修改? SSL开关支持修改,具体步骤请参考修改SSL。 父主题: 实例问题
消息老化时间(修改方法请参考修改RocketMQ消息保留时间) 参数修改完成后,通过以下方式查看修改结果: 修改“实例名称”、“描述”、“公网访问”、“弹性TPS”、“ACL访问控制”、“消息老化时间”、“企业项目”和“安全组”后,右上角直接提示修改结果。 修改“SSL”后,在