检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
连接实例 配置RocketMQ网络连接 配置RocketMQ访问控制 使用客户端连接RocketMQ(关闭SSL) 使用客户端连接RocketMQ(开启SSL) 使用控制台连接RocketMQ
获取“连接地址”。 使用gRPC协议通过内网连接RocketMQ实例时,获取“grpc连接地址”。 使用TCP协议通过公网连接RocketMQ实例时,获取“公网连接地址”。 使用gRPC协议通过公网连接RocketMQ实例时,获取“grpc公网连接地址”。 图1 查看实例的连接地址和端口(5
公网访问开启后,RocketMQ实例4.8.0版本页面显示“公网连接地址”。RocketMQ实例5.x版本页面显示“公网连接地址”(使用TCP协议)和“grpc公网连接地址”(使用gRPC协议)。 图2 公网连接地址(RocketMQ实例4.8.0版本) 图3 公网连接地址(RocketMQ实例5.x版本)
启SSL。 操作视频 本视频演示使用客户端连接RocketMQ实例的操作。 前提条件 已创建RocketMQ实例,并记录实例详情中的“连接地址”(内网访问)/“公网连接地址”(公网访问)。内网访问的连接端口为8100,公网环境下访问的连接端口为8200。 客户端和RocketMQ
已创建RocketMQ实例,并记录实例详情中的“连接地址”(内网访问)/“公网连接地址”(公网访问)。内网访问的连接端口为8100,公网环境下访问的连接端口为8200。 客户端和RocketMQ实例之间网络已互通,具体网络要求参见连接RocketMQ网络要求页面。 已配置安全组。
连接问题 RocketMQ是否支持自建Broker连接云上nameserver? 连接实例失败,报错RemotingTooMuchRequestException: sendDefaultImpl call timeout
查看RocketMQ消费者连接地址 消费者连接地址即消费消息的客户端地址,当客户端连接RocketMQ消费消息时,可通过控制台查看客户端的连接地址。 约束与限制 消费者处于连接RocketMQ实例时,才可以查看消费者连接地址。 前提条件 已创建消费组,且消费组中已存在消费者。 已创建Topic。
RocketMQ是否支持自建Broker连接云上nameserver? 不支持。自建Broker连接到云上RocketMQ的nameserver,会影响管理面功能,导致查询不到Topic等问题。 父主题: 连接问题
配置RocketMQ网络连接 连接RocketMQ网络要求 配置RocketMQ实例的公网访问 父主题: 连接实例
打通VPC之间的网络。 客户端连接RocketMQ实例的方式如表1所示。 表1 连接方式说明 连接方式 实现方式 参考文档 公网连接 在RocketMQ控制台开启公网访问,配置弹性公网IP,客户端通过弹性公网IP访问RocketMQ实例。 配置RocketMQ实例的公网访问 内网连接
age Key的方式准确查询出消息。 (可选)消息Tag:消息标签,用来进一步区分某个Topic下的消息分类,消息从生产者发出即带上的属性。输入长度不能超过128个字符。 页面右上角显示“消息发送成功”时,表示消息发送成功,您可以在“消息查询”页面,查看已成功发送的消息。 父主题:
连接实例的地址。 grpc连接地址 未开启公网访问,并且使用gRPC协议连接实例时,连接实例的地址。 公网访问 公网访问状态。单击“公网访问”后的,开启/关闭公网访问。 公网连接地址 仅开启公网访问后可见。 开启公网访问,并且使用TCP协议连接实例时,连接实例的地址。 grpc公网连接地址
xxx.144:8100:表示RocketMQ实例的“连接地址”,即11中记录的连接地址。 Topic01:表示RocketMQ实例下创建的Topic名称,即4中创建的Topic名称。 hello rocketmq:表示生产消息的内容。 运行消费普通消息命令。 命令示例如下: JAVA_OPT=-Dtls
Server) 弹性云服务器是由CPU、内存、操作系统、云硬盘组成的基础的计算组件。RocketMQ实例运行在弹性云服务器上,一个代理对应三台弹性云服务器。 云硬盘(Elastic Volume Service) 云硬盘为云服务器提供块存储服务,RocketMQ的所有数据(如消息、元数据和日志等)都保存在云硬盘中。
配置RocketMQ访问控制 开启RocketMQ ACL访问 配置RocketMQ ACL用户 父主题: 连接实例
可能原因 用户在安全组中未放通业务节点的端口。 解决方法 在RocketMQ实例控制台的详情页中,获取“网络 > 需要放通的地址”中的端口号。 单击安全组名称,进入安全组配置页面。 在“入方向规则”中,放通步骤1中的端口号。 父主题: 连接问题
List)可以实现对RocketMQ实例中生产者和消费者身份的精确识别,达到权限管理的目的。开启ACL权限控制功能后,生产消息和消费消息时,需要鉴权。 约束与限制 仅2021年8月21号后购买的实例,支持设置ACL访问控制。 开启ACL访问控制会导致没有配置认证信息的客户端连接中断。 前提条件 已购买RocketMQ实例。
RocketMQ-Spring的使用 本文介绍如何使用RocketMQ-Spring连接华为云RocketMQ实例进行消息的生产和消费。相关代码您可以从rocketmq-springboot-demo中获取。 下文所有RocketMQ的配置信息,如实例连接地址、Topic名称、用户信息等,请参考收集连接信息获取。
名称 自定义用户名称,用于识别不同的用户。 用户名称命名规则如下: 长度为7~64个字符。 只能由英文字母、数字、中划线、下划线组成,且须以英文字母开头。 名称不可重复。 用户名创建成功后,不可修改。 IP白名单 如果请求的来源IP为IP白名单中的地址,不需要校验用户密钥是否正确,且
consumer.sh -n "${连接地址}" -t ${Topic名称} -g ${消费组名称} 连接地址:购买RocketMQ实例后,获取实例的连接地址。 Topic名称:创建Topic时设置的Topic名称。 消费组名称:创建消费组时设置的消费组名称。 测试结果参考 表4 测试结果参考