检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Boolean 实例是否开启域名访问功能。 true:开启 false:未开启 namesrv_address String 元数据地址。 namesrv_domain_name String 元数据域名。 broker_address String 业务数据地址。 public_namesrv_address
Boolean 实例是否开启域名访问功能。 true:开启 false:未开启 namesrv_address String 元数据地址。 namesrv_domain_name String 元数据域名。 broker_address String 业务数据地址。 public_namesrv_address
Boolean 实例是否开启域名访问功能。 true:开启 false:未开启 namesrv_address String 元数据地址。 namesrv_domain_name String 元数据域名。 broker_address String 业务数据地址。 public_namesrv_address
Boolean 实例是否开启域名访问功能。 true:开启 false:未开启 namesrv_address String 元数据地址。 namesrv_domain_name String 元数据域名。 broker_address String 业务数据地址。 public_namesrv_address
是否开启公网访问功能。默认不开启公网。 true:开启 false:不开启 publicip_id String 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 如果开启了公网访问功能(即enable_publicip为true),该字段为必选。 broker_num Integer
Boolean 实例是否开启域名访问功能。 true:开启 false:未开启 namesrv_address String 元数据地址。 namesrv_domain_name String 元数据域名。 broker_address String 业务数据地址。 public_namesrv_address
err.Error()) } } 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 192.168.0.1:8100:表示实例连接地址和端口。 topic1:表示Topic名称。 异步发送 异步发送是指消息发送方发出一条消息后,不等服务端返回响应,接着发送下一条消息的通讯方式。
String broker名称 broker_id Integer broker的ID address String 地址 public_address String 公网地址 请求示例 GET https://{endpoint}/v2/{project_id}/{engine}/in
err.Error()) } } 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 192.168.0.1:8100:表示实例连接地址和端口。 test:表示Topic名称。 父主题: Go(TCP协议)
mqadmin sendMessage -n "${连接地址}" -t ${Topic名称} -p "hello rocketmq" 参数说明如下: 连接地址:表示RocketMQ实例的“连接地址”(内网访问)/“公网连接地址”(公网访问)。 Topic名称:RocketMQ实例下创建的Topic名称。
描述 URI-scheme 表示用于传输请求的协议,当前所有API均采用HTTPS协议。 Endpoint 指定承载REST服务端点的服务器域名或IP,不同服务不同区域的Endpoint不同,您可以从地区和终端节点获取。 例如IAM服务在“华北-北京四”区域的Endpoint为“iam
send_message_sync() 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 topic:表示Topic名称。 name_srv:表示实例连接地址和端口。 ACL_ACCESS_KEY:表示用户名。创建用户的步骤,请参见创建用户。 ACL_SECRET_KEY:表示用户的密钥。 事务
enable_publicip 否 Boolean 是否开启公网。 publicip_id 否 String 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 如果开启了公网访问功能(即enable_publicip为true),该字段为必选。 响应参数 无 请求示例
开启,在“弹性IP地址”中根据界面提示信息选择对应数量的IP地址,单击,开启公网访问。 如果“弹性IP地址”下拉列表没有值或者弹性IP地址数量不够,可单击“创建弹性IP”,跳转到弹性公网IP页面,申请新的弹性IP。弹性IP申请完后,返回RocketMQ控制台,单击“弹性IP地址”后的,然后在下拉列表中选择新申请的弹性IP。
消息的生产和消费。相关代码您可以从rocketmq-springboot-demo中获取。 下文所有RocketMQ的配置信息,如实例连接地址、Topic名称、用户信息等,请参考收集连接信息获取。 在pom.xml文件中引入RocketMQ-Spring依赖 <dependency>
"arch_types" : [ "X86" ], "charging_mode" : [ "monthly", "hourly" ], "ios" : [ { "io_spec" : "dms.physical.storage.high.v2"
查看RocketMQ消费者连接地址 消费者连接地址即消费消息的客户端地址,当客户端连接RocketMQ消费消息时,可通过控制台查看客户端的连接地址。 约束与限制 消费者处于连接RocketMQ实例时,才可以查看消费者连接地址。 前提条件 已创建消费组,且消费组中已存在消费者。 已创建Topic。
解服务状况,保证业务正常运行。 产品架构 图1 产品架构示意图 示意图说明: Broker:负责接收和存储Producer发送的消息,或者转发消息到Consumer。一个Broker由一个主节点和两个备节点组成。 NameServer:负责接收和存储Broker中的元数据。 Pr
获取实例连接信息 实例连接地址和端口 实例创建后,从RocketMQ实例控制台的“基本信息”页面获取,在客户端配置时,可将地址都配上。 使用TCP协议通过内网连接RocketMQ实例时,获取“连接地址”。 使用gRPC协议通过内网连接RocketMQ实例时,获取“grpc连接地址”。 使用TC
获取项目ID 操作场景 在调用接口的时候,部分URL中需要填入项目ID,所以需要获取到项目ID。有如下两种获取方式: 调用API获取项目ID 从控制台获取项目ID 调用API获取项目ID 项目ID可以通过调用查询指定条件下的项目信息API获取。 获取项目ID的接口为“GET ht