-
收集连接信息 - 分布式消息服务RocketMQ版
图2 查看实例的连接地址和端口(4.8.0版本) Topic名称 从RocketMQ实例控制台的“Topic管理”页签中获取Topic名称。 消费组名称 从RocketMQ实例控制台的“消费组管理”页签中获取消费组名称。 用户名和用户密钥 从RocketMQ实例控制台的“用户管理”
-
查看和修改RocketMQ实例基本信息 - 分布式消息服务RocketMQ版
Q实例的详细信息。 表2和表3为连接实例的相关参数,其他参数,请查看页面显示。 表2 连接信息(分布式消息服务RocketMQ版4.8.0) 参数 说明 连接地址 未开启公网访问时,连接实例的地址。 SSL 实例的SSL状态。 公网访问 公网访问状态。单击“公网访问”后的,开启/关闭公网访问。
-
配置RocketMQ实例的公网访问 - 分布式消息服务RocketMQ版
配置RocketMQ实例的公网访问 您需要通过公网地址访问RocketMQ实例时,开启实例的公网访问功能,并设置弹性IP地址。当业务不再使用公网访问功能时,关闭实例的公网访问功能。 前提条件 只有处于“运行中”状态的RocketMQ实例支持修改公网访问配置。 开启公网访问 登录管理控制台。
-
使用客户端连接RocketMQ(关闭SSL) - 分布式消息服务RocketMQ版
使用客户端连接RocketMQ(关闭SSL) 本文主要介绍在命令行模式下调用TCP协议连接未开启SSL的RocketMQ实例。 在不使用SSL连接的场景下,通过内网访问和通过公网访问,仅涉及连接IP和端口不一致,其他操作步骤是一样的。内网访问的连接端口为8100,公网环境下访问的连接端口为8200。
-
RocketMQ业务迁移 - 分布式消息服务RocketMQ版
产者将新的消息发送到分布式消息服务RocketMQ版实例中。 迁移消费消息至分布式消息服务RocketMQ版实例。 待消费组中的消息消费完之后,将消费客户端的元数据连接地址改为分布式消息服务RocketMQ版实例的元数据连接地址,重启消费业务,使得消费者从分布式消息服务RocketMQ版实例中消费消息。
-
查看RocketMQ消费者连接地址 - 分布式消息服务RocketMQ版
在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务RocketMQ版”,进入分布式消息服务RocketMQ专享版页面。 单击RocketMQ实例的名称,进入实例详情页面。 在左侧导航栏,选择“实例诊断”,进入实例诊断页面。 在“消费组”中,选择待查看消费者连接地址的消费组名称,单击“开始诊断”。
-
使用客户端连接RocketMQ(开启SSL) - 分布式消息服务RocketMQ版
访问的连接端口为8100,公网环境下访问的连接端口为8200。 文中仅介绍公网环境下的连接示例,在内网连接时,替换为相应的连接地址即可。 前提条件 已创建RocketMQ实例,并记录实例详情中的“连接地址”(内网访问)/“公网连接地址”(公网访问)。 已配置安全组。 已创建Topic。
-
连接RocketMQ网络要求 - 分布式消息服务RocketMQ版
打通VPC之间的网络。 客户端连接RocketMQ实例的方式如表1所示。 表1 连接方式说明 连接方式 实现方式 参考文档 公网连接 在RocketMQ控制台开启公网访问,配置弹性公网IP,客户端通过弹性公网IP访问RocketMQ实例。 配置RocketMQ实例的公网访问 内网连接
-
快速连接RocketMQ并生产消费消息 - 分布式消息服务RocketMQ版
在相同的区域。 共享VPC是基于资源访问管理(Resource Access Manager,简称RAM)服务的机制,VPC的所有者可以将VPC内的子网共享给一个或者多个账号使用。通过共享VPC功能,可以简化网络配置,帮助您统一配置和运维多个账号下的资源,有助于提升资源的管控效率
-
连接实例失败,报错RemotingTooMuchRequestException: sendDefaultImpl call timeout - 分布式消息服务RocketMQ版
timeout”。 可能原因 用户在安全组中未放通业务节点的端口。 解决方法 在RocketMQ实例控制台的详情页中,获取“网络 > 需要放通的地址”中的端口号。 单击安全组名称,进入安全组配置页面。 在“入方向规则”中,放通1中的端口号。 父主题: 连接问题
-
配置RocketMQ网络连接 - 分布式消息服务RocketMQ版
配置RocketMQ网络连接 连接RocketMQ网络要求 配置RocketMQ实例的公网访问 父主题: 连接实例
-
使用控制台连接RocketMQ - 分布式消息服务RocketMQ版
在管理控制台左上角单击,选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务RocketMQ版”,进入分布式消息服务RocketMQ专享版页面。 单击RocketMQ实例的名称,进入实例详情页面。 在左侧导航栏,单击“Topic管理”,进入“Topic管理”页面。
-
连接实例 - 分布式消息服务RocketMQ版
连接实例 配置RocketMQ网络连接 配置RocketMQ访问控制 使用客户端连接RocketMQ(关闭SSL) 使用客户端连接RocketMQ(开启SSL) 使用控制台连接RocketMQ
-
与其他云服务的关系 - 分布式消息服务RocketMQ版
弹性公网IP提供独立的公网IP资源,包括公网IP地址与公网出口带宽服务。RocketMQ实例绑定弹性公网IP后,可以通过公网访问RocketMQ实例。 标签管理服务(Tag Management Service) 标签管理服务是一种快速便捷将标签集中管理的可视化服务,提供跨区域、跨服务的集中标签管理和资源分类功能。
-
连接问题 - 分布式消息服务RocketMQ版
连接问题 RocketMQ是否支持自建Broker连接云上nameserver? 连接实例失败,报错RemotingTooMuchRequestException: sendDefaultImpl call timeout
-
RocketMQ是否支持自建Broker连接云上nameserver? - 分布式消息服务RocketMQ版
RocketMQ是否支持自建Broker连接云上nameserver? 不支持。自建Broker连接到云上RocketMQ的nameserver,会影响管理面功能,导致查询不到Topic等问题。 父主题: 连接问题
-
测试5.x版本RocketMQ实例性能 - 分布式消息服务RocketMQ版
consumer.sh -n "${连接地址}" -t ${Topic名称} -g ${消费组名称} 连接地址:购买RocketMQ实例后,获取实例的连接地址。 Topic名称:创建Topic时设置的Topic名称。 消费组名称:创建消费组时设置的消费组名称。 测试结果 表4 测试结果
-
配置RocketMQ ACL用户 - 分布式消息服务RocketMQ版
说明 名称 自定义用户名称,用于识别不同的用户。 用户名创建成功后,不可修改。 IP白名单 如果请求的来源IP为IP白名单中的地址,不需要校验用户密钥是否正确,且具有所有Topic和消费组的发布+订阅权限。 IP白名单可以配置为具体的IP地址,也可以配置为网段。如:192.168.1
-
状态码 - 分布式消息服务RocketMQ版
表明请求超出了客户端访问频率的限制或者服务端接收到多于它能处理的请求。建议客户端读取相应的Retry-After首部,然后等待该首部指出的时间后再重试。 500 InternalServerError 表明服务端能被请求访问到,但是不能理解用户的请求。 501 Not Implemented 服务器不支持请求的功能,无法完成请求。
-
测试4.8.0版本RocketMQ实例性能 - 分布式消息服务RocketMQ版
consumer.sh -n "${连接地址}" -t ${Topic名称} -g ${消费组名称} 连接地址:购买RocketMQ实例后,获取实例的连接地址。 Topic名称:创建Topic时设置的Topic名称。 消费组名称:创建消费组时设置的消费组名称。 测试结果 表4 测试结果