检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
cn-north-1.myhuaweicloud.com/rocketmq-tutorial.zip 解压“rocketmq-tutorial”。 unzip rocketmq-tutorial.zip (可选)如果RocketMQ实例开启了ACL访问控制,执行mqadmin命令时,需要鉴权。
ps { "name" : "consumer-group-test", "group_desc" : "group_description", "brokers" : [ "broker-0" ], "broadcast" : false, "retry_max_time"
cn-north-1.myhuaweicloud.com/rocketmq-tutorial.zip 执行以下命令解压“rocketmq-tutorial”。 unzip rocketmq-tutorial.zip 步骤二:创建RocketMQ实例 使用RocketMQ进行消息生产和消费时,必须
enable_publicip Boolean 是否开启公网。 publicip_id String 实例绑定的弹性IP地址的ID。以英文逗号隔开多个弹性IP地址的ID。如果开启了公网访问功能(即enable_publicip为true),该字段为必选。 publicip_address String
enable_publicip Boolean 是否开启公网。 publicip_id String 实例绑定的弹性IP地址的ID。以英文逗号隔开多个弹性IP地址的ID。如果开启了公网访问功能(即enable_publicip为true),该字段为必选。 publicip_address String
enable_publicip Boolean 是否开启公网。 publicip_id String 实例绑定的弹性IP地址的ID。以英文逗号隔开多个弹性IP地址的ID。如果开启了公网访问功能(即enable_publicip为true),该字段为必选。 publicip_address String
名称不可重复。 用户名创建成功后,不可修改。 IP白名单 如果请求的来源IP为IP白名单中的地址,不需要校验用户密钥是否正确,且具有所有Topic和消费组的发布+订阅权限。 IP白名单可以配置为具体的IP地址,也可以配置为网段。 多个IP时使用英文逗号隔开,如:192.168.1.2
enable_publicip Boolean 是否开启公网。 publicip_id String 实例绑定的弹性IP地址的ID。以英文逗号隔开多个弹性IP地址的ID。如果开启了公网访问功能(即enable_publicip为true),该字段为必选。 publicip_address String
return; } try { final SendReceipt sendReceipt = producer.send(message, transaction); log.info("Send
great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted
enable_publicip Boolean 是否开启公网。 publicip_id String 实例绑定的弹性IP地址的ID。以英文逗号隔开多个弹性IP地址的ID。如果开启了公网访问功能(即enable_publicip为true),该字段为必选。 publicip_address String
great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted
great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted
次。 支持区域: 全部 扩容存储空间或代理个数 公网访问 您需要通过公网地址访问RocketMQ实例时,开启实例的公网访问功能,并设置弹性IP地址。 只有处于“运行中”状态的RocketMQ实例支持修改公网访问配置。 支持区域: 全部 设置实例公网访问 消息查询 通过查询消息功能
great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted
产品规格 分布式消息服务RocketMQ版兼容开源RocketMQ 4.8.0和5.x,具体产品规格如下。 RocketMQ对消息的处理能力依赖于磁盘的吞吐能力,性能基线基于超高I/O及以上磁盘类型,高I/O磁盘类型可能无法达到当前标准。 分布式消息服务RocketMQ版4.8.0规格
final SendReceipt sendReceipt = producer.send(message); log.info("Send message successfully, messageId={}", sendReceipt.getMessageId());
great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted
great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted
final SendReceipt sendReceipt = producer.send(message); log.info("Send message successfully, messageId={}", sendReceipt.getMessageId());