检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
全组”页面,查看或创建安全组。 客户端连接RocketMQ实例前,请根据不同的连接方式配置对应的安全组规则,否则会连接失败。具体的安全组规则请参考表3。 设置实例访问方式。 表6 实例访问方式参数说明 参数名称 说明 公网访问 通过公网连接RocketMQ实例。 默认为关闭状态。
zip 测试命令 生产命令: sh producer.sh -n "${连接地址}" -t ${Topic名称} -s ${消息大小} -w ${生产者线程数} 连接地址:购买RocketMQ实例后,获取实例的连接地址。 Topic名称:创建Topic时设置的Topic名称。 消息大小:1KB
同一个队列。 全局顺序消息和分区顺序消息的区别仅为队列数量不同,代码没有区别。 收发顺序消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 客户端连接RocketMQ实例5.x版本收发顺序消息前,需要确保Topic的消息类型为“顺序”。 发送顺序消息 参考
收发顺序消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 仅RocketMQ实例5.x版本支持gRPC协议,4.8.0版本不支持。 客户端连接RocketMQ实例5.x版本收发顺序消息前,需要确保Topic的消息类型为“顺序”。 使用gRPC协议连接RocketMQ
发送通知:选择开启。 通知方式:选择“主题订阅”。 通知对象:选择云账号联系人或已创建的告警通知主题,告警通知主题的订阅信息中包含需要接收告警信息的手机号/邮箱地址。 如果尚未创建告警通知主题,参考如下操作创建告警通知主题:单击“创建主题”,进入消息通知服务中,创建主题和添加订阅。创建完成
zip 测试命令 生产命令: sh producer.sh -n "${连接地址}" -t ${Topic名称} -s ${消息大小} -w ${生产者线程数} 连接地址:购买RocketMQ实例后,获取实例的连接地址。 Topic名称:创建Topic时设置的Topic名称。 消息大小:1KB
String grpc连接地址(仅RocketMQ 5.x版本会显示此字段)。 grpc_domain_name String grpc连接域名(仅RocketMQ 5.x版本会显示此字段)。 public_grpc_address String 公网grpc连接地址(仅RocketMQ
String grpc连接地址(仅RocketMQ 5.x版本会显示此字段)。 grpc_domain_name String grpc连接域名(仅RocketMQ 5.x版本会显示此字段)。 public_grpc_address String 公网grpc连接地址(仅RocketMQ
String grpc连接地址(仅RocketMQ 5.x版本会显示此字段)。 grpc_domain_name String grpc连接域名(仅RocketMQ 5.x版本会显示此字段)。 public_grpc_address String 公网grpc连接地址(仅RocketMQ
收发顺序消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 仅RocketMQ实例5.x版本支持gRPC协议,4.8.0版本不支持。 客户端连接RocketMQ实例5.x版本收发顺序消息前,需要确保Topic的消息类型为“顺序”。 使用gRPC协议连接RocketMQ
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"]
同的数据访问权限,详情请参见权限管理。 建议配置安全组访问控制,保护您的数据不被异常读取和操作。 参照表1配置安全组的入方向规则限制,控制连接实例的网络范围,避免DMS for RocketMQ暴露给不可信的第三方。 表1 安全组规则 实例版本 方向 协议 端口 源地址 说明 4
同一个队列。 全局顺序消息和分区顺序消息的区别仅为队列数量不同,代码没有区别。 收发顺序消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 客户端连接RocketMQ实例5.x版本收发顺序消息前,需要确保Topic的消息类型为“顺序”。 准备环境 执行以下命令,检查是否已安装Go。
送事务提交或回滚。消息只有在提交之后才投递给消费者,消费者对回滚的消息不可见。 收发事务消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 客户端连接RocketMQ实例5.x版本收发事务消息前,需要确保Topic的消息类型为“事务”。 发送事务消息 参考
投递给消费者,消费者对回滚的消息不可见。 收发事务消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 仅RocketMQ实例5.x版本支持gRPC协议,4.8.0版本不支持。 客户端连接RocketMQ实例5.x版本收发事务消息前,需要确保Topic的消息类型为“事务”。
的消息不可见。 收发事务消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 客户端连接RocketMQ实例5.x版本收发事务消息前,需要确保Topic的消息类型为“事务”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4
代码没有区别。 收发顺序消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 客户端连接RocketMQ实例5.x版本收发顺序消息前,需要确保Topic的消息类型为“顺序”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4
send_message_sync() 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 topic:表示Topic名称。 gid:表示生产者组名称,请根据业务实际情况输入生产者组名称。 name_srv:表示实例连接地址和端口。 ROCKETMQ_AK:表示用户名。创建用户的步骤,请参见创建用户。
收发事务消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 仅RocketMQ实例5.x版本支持gRPC协议,4.8.0版本不支持。 客户端连接RocketMQ实例5.x版本收发事务消息前,需要确保Topic的消息类型为“事务”。 准备环境 开源的Java客户端支持连接分布式
送事务提交或回滚。消息只有在提交之后才投递给消费者,消费者对回滚的消息不可见。 收发事务消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 客户端连接RocketMQ实例5.x版本收发事务消息前,需要确保Topic的消息类型为“事务”。 准备环境 执行以下命令,检查是否已安装Go。