检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
低下。现通过代码实现接口循环调用，可实现批量创建Topic的效果。 前提条件 已获取IAM和RocketMQ服务所在区域的Endpoint地址。 已获取RocketMQ实例的实例ID，以及实例所在区域的项目ID。 使用华为云SDK 5.x版本批量创建不同类型的Topic 新建“topics
点。 主节点重启过程中，客户端的生产和消费请求会被拒绝，持续时间不超过30s，建议在业务量少时重启节点。重启备节点，不会影响业务的使用。 怎么判断哪个是主节点？ 一个Broker由一个主节点和两个备节点组成，当您购买的Broker数为1时，实际创建3个Broker节点。三个节点采用raft模式部署，使用Broker
创建安全组后，系统默认添加入方向“允许安全组内的彼此通信”规则和出方向“放通全部流量”规则，此时使用内网通过同一个VPC访问RocketMQ实例，无需添加表2和表3的规则。 表2 安全组规则（RocketMQ实例4.8.0版本） 方向 协议 端口 源地址 说明 入方向 TCP 8100
标签是RocketMQ实例的标识，为RocketMQ实例添加标签，可以方便用户识别和管理拥有的RocketMQ实例资源。 您可以在创建RocketMQ实例时添加标签，也可以在RocketMQ实例创建完成后，在“标签”页面添加标签，您最多可以给实例添加20个标签。另外，您还可以删除标签。 如您的
展、便捷管理和多样功能的消息队列。 即开即用：简单几步即可在云上构建自己专属的消息服务，RocketMQ实例创建完成后，使用实例提供的访问地址即可快速接入。兼容开源RocketMQ，业务代码无需改造，即可上云。 全托管服务：分布式消息服务RocketMQ版提供自动部署与完备的运维
//填入连接地址 producer.setNamesrvAddr("192.168.0.1:8100"); //producer.setUseTLS(true); //创建实例时，如果开启了SSL，请添加此行代码。 try
需要接收告警信息的手机号/邮箱地址。 如果尚未创建告警通知主题，参考如下操作创建告警通知主题：单击“创建主题”，进入消息通知服务中，创建主题和添加订阅。创建完成后，返回“创建告警规则”页面，在“通知对象”后单击，然后选择创建的告警通知主题。 在添加订阅后，对应的订阅终端会收到订阅
0，获取librocketmq库。 将librocketmq.so添加到系统动态库搜索路径。 查找librocketmq.so的路径。 find / -name librocketmq.so 将librocketmq.so添加到系统动态库搜索路径。 ln -s /查找到的librocketmq
"yourNormalTopics"; // 填入grpc连接地址/grpc公网连接地址 String endpoints = "yourEndpoints"; // 创建实例时，如果开启了ACL才需要添加以下代码。 String accessKey
SDK概述 本文介绍了分布式消息服务RocketMQ版提供的SDK语言版本，列举了最新版本SDK的获取地址。 在线生成SDK代码 API Explorer能根据需要动态生成SDK代码功能，降低您使用SDK的难度，推荐使用。 SDK列表 表1提供了分布式消息服务RocketMQ版支
"yourTransactionTopic"; // 填入grpc连接地址/grpc公网连接地址 String endpoints = "yourEndpoints"; // 创建实例时，如果开启了ACL才需要添加以下代码。 String accessKey
单位：毫秒 生产地址 生产者的IP地址。 消费者状态 消费者状态如下： 消费成功 消费超时 消费异常 消费返回NULL 消费失败 消费时间 消费消息的时间。 时间格式为：YYYY/MM/DD hh:mm:ss 消费耗时 消费者消费消息的耗时。 单位：毫秒 消费地址 消费者的IP地址。 父主题：
在此处重新为用户设置。管理员默认具有所有权限，无需手动添加。 5.x基础版不支持此操作。 单击用户名称，进入用户详情页面。 在“Topic权限”/“消费组权限”页签中，单击“添加权限”，弹出“添加权限”对话框。 勾选需要添加权限的Topic或者消费组，选择所需的特殊权限，单击“确定”。
RocketMQ实例分内网地址以及公网地址两种网络连接方式。如果使用公网地址，则消息生产与消费客户端需要有公网访问权限，并配置如下安全组。 表1 安全组规则（RocketMQ实例4.8.0版本） 方向 协议 端口 源地址 说明 入方向 TCP 8200 RocketMQ客户端所在的IP地址或地址段。
"yourDelayTopic"; // 填入grpc连接地址/grpc公网连接地址 String endpoints = "yourEndpoints"; // 创建实例时，如果开启了ACL才需要添加以下代码。 String accessKey
示例代码中的参数说明如下，请参考收集连接信息获取参数值。 Topic：输入Topic名称。 Endpoint：输入grpc连接地址/grpc公网连接地址。 AccessKey：创建实例时，如果开启了ACL，需要输入用户名。 SecretKey：创建实例时，如果开启了ACL，需要输入用户密钥。
示例代码中的参数说明如下，请参考收集连接信息获取参数值。 Topic：输入Topic名称。 Endpoint：输入grpc连接地址/grpc公网连接地址。 AccessKey：创建实例时，如果开启了ACL，需要输入用户名。 SecretKey：创建实例时，如果开启了ACL，需要输入用户密钥。
示例代码中的参数说明如下，请参考收集连接信息获取参数值。 Topic：输入Topic名称。 Endpoint：输入grpc连接地址/grpc公网连接地址。 AccessKey：创建实例时，如果开启了ACL，需要输入用户名。 SecretKey：创建实例时，如果开启了ACL，需要输入用户密钥。
publicip_id String 实例绑定的弹性IP地址的ID。以英文逗号隔开多个弹性IP地址的ID。如果开启了公网访问功能（即enable_publicip为true），该字段为必选。 publicip_address String 公网IP地址。 ssl_enable Boolean 是否开启SSL。
publicip_id String 实例绑定的弹性IP地址的ID。以英文逗号隔开多个弹性IP地址的ID。如果开启了公网访问功能（即enable_publicip为true），该字段为必选。 publicip_address String 公网IP地址。 ssl_enable Boolean 是否开启SSL。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
