检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
timeout”。 可能原因 用户在安全组中未放通业务节点的端口。 解决方法 在RocketMQ实例控制台的详情页中，获取“网络 > 需要放通的地址”中的端口号。 单击安全组名称，进入安全组配置页面。 在“入方向规则”中，放通步骤1中的端口号。 父主题： 连接问题
前提条件 已创建RocketMQ实例，并记录实例详情中的“连接地址”（内网访问）/“公网连接地址”（公网访问）。内网访问的连接端口为8100，公网环境下访问的连接端口为8200。 客户端和RocketMQ实例之间网络已互通，具体网络要求参见连接RocketMQ网络要求页面。 已配置安全组。
处理效率。 外部IO操作型代码主要有以下业务操作： 读写外部数据库，例如对远程MySQL数据库读写。 读写外部缓存系统，例如对远程Redis读写。 下游系统调用，例如Dubbo的RPC远程调用，Spring Cloud对下游系统的HTTP接口调用。 提前梳理下游系统的调用逻辑，掌
使用TCP协议，通过公网访问实例的端口。 4.8.0 5.x 入方向 TCP 10100-10199 使用TCP协议，访问业务节点的端口。 5.x 入方向 TCP 8080 使用gRPC协议，通过内网访问实例的端口。 5.x 入方向 TCP 8081 使用gRPC协议，通过公网访问实例的端口。 建议将访问DMS
使用TCP协议，通过内网访问实例的端口。 入方向 TCP 8200 使用TCP协议，通过公网访问实例的端口。 入方向 TCP 8080 使用gRPC协议，通过内网访问实例的端口。 入方向 TCP 8081 使用gRPC协议，通过公网访问实例的端口。 入方向 TCP 10100 使
规则。 表1 安全组规则 方向 协议 端口 源地址 说明 入方向 TCP 8100 RocketMQ客户端所在的IP地址或地址段。 使用TCP协议，通过内网访问实例的端口。 入方向 TCP 8080 使用gRPC协议，通过内网访问实例的端口。 入方向 TCP 10100 使用TCP协议，通过内网访问业务节点的端口。
使用TCP协议，通过内网访问实例的端口。 入方向 TCP 8200 使用TCP协议，通过公网访问实例的端口。 入方向 TCP 8080 使用gRPC协议，通过内网访问实例的端口。 入方向 TCP 8081 使用gRPC协议，通过公网访问实例的端口。 入方向 TCP 10100 使
#=============== 生产者配置 ======================= ## 替换成真实RocketMQ的NameServer地址与端口 rocketmq.name-server=127.0.0.1:9876 rocketmq.producer.group=my-group
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"]
重置RocketMQ消费进度 重置消费进度即修改消费者的消费位置，重置消费进度后，消费者会从修改后的消息位置开始继续消费。 重置消费进度可能会导致重复消费，请谨慎操作。 操作视频 本视频演示重置RocketMQ消费进度的操作。 前提条件 已创建消费组，且消费组中已存在消费者。 已创建Topic。
公共请求消息头 名称 描述 是否必选 示例 Host 请求的服务器信息，从服务API的URL中获取。值为hostname[:port]。端口缺省时使用默认的端口，https的默认端口为443。 否 使用AK/SK认证时该字段必选。 code.test.com or code.test.com:443
send_message_sync() 示例代码中的参数说明如下，请参考收集连接信息获取参数值。 topic：表示Topic名称。 name_srv：表示实例连接地址和端口。 set_keys：设置消息索引键，可根据关键字精确查找某条消息。 set_tags：设置消息Tag，用于消费端根据指定Tag过滤消息。
reliability RocketMQ_Topic_CreationFailure 修改Topic成功 reliability RocketMQ_Topic_ModifySuccess 修改Topic失败 reliability RocketMQ_Topic_ModifyFailure
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"]
前提条件 已创建RocketMQ实例，并记录实例详情中的“连接地址”（内网访问）/“公网连接地址”（公网访问）。内网访问的连接端口为8100，公网环境下访问的连接端口为8200。 客户端和RocketMQ实例之间网络已互通，具体网络要求参见连接RocketMQ网络要求页面。 已配置安全组。
是否售罄。 id String 可用区ID。 code String 可用区编码。 name String 可用区名称。 port String 可用区端口号。 resource_availability String 分区上是否还有可用资源。 default_az Boolean
API 说明 生命周期管理 包括创建实例、修改实例信息、查询实例、删除实例、查询代理列表。 消费组管理 包括查询消费组、创建消费组、删除消费组、修改消费组、查询消费列表或详情、重置消费进度。 Topic管理 包括创建主题、删除主题、查询主题、修改主题、查询主题消费组列表、查询主题的消息数。
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"]
ocketMQ实例成功后，需要手动创建Topic，然后才能进行生产消息和消费消息。 支持区域： 全部 创建Topic 查询Topic信息 修改Topic参数 变更实例规格 RocketMQ实例创建成功后，您可以根据业务需要，扩容存储空间和代理个数。不支持同时扩容存储空间和代理个数，如果需要可以分别进行扩容。
example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment String ak = "{CLOUD_SDK_AK}"; //访问密钥ID。查看AK的方法请参见获取AK/SK。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
