正在生成
详细信息:
检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
使用客户端连接RocketMQ(关闭SSL) 本文主要介绍在Linux系统的命令行模式下,调用TCP协议连接未开启SSL的RocketMQ实例。 前提条件 已创建RocketMQ实例,并记录实例详情中的“连接地址”(内网访问)/“公网连接地址”(公网访问)。内网访问的连接端口为8
收集连接信息 获取实例连接信息 实例连接地址和端口 实例创建后,从RocketMQ实例控制台的“基本信息”页面获取,在客户端配置时,可将地址都配上。 使用TCP协议通过内网连接RocketMQ实例时,获取“连接地址”。 使用gRPC协议通过内网连接RocketMQ实例时,获取“grpc连接地址”。
仅2021年8月21号后购买的实例,支持设置此参数。 表3 连接信息(分布式消息服务RocketMQ版5.x) 参数 说明 连接地址 未开启公网访问,并且使用TCP协议连接实例时,连接实例的地址。 grpc连接地址 未开启公网访问,并且使用gRPC协议连接实例时,连接实例的地址。 公网访问 公网访问状态
公网访问开启后,RocketMQ实例4.8.0版本页面显示“公网连接地址”。RocketMQ实例5.x版本页面显示“公网连接地址”(使用TCP协议)和“grpc公网连接地址”(使用gRPC协议)。 图2 公网连接地址(RocketMQ实例4.8.0版本) 图3 公网连接地址(RocketMQ实例5.x版本)
连接RocketMQ网络要求 客户端可以通过公网连接RocketMQ实例,也可以通过内网连接RocketMQ实例。使用内网连接时,注意以下几点: 如果客户端和RocketMQ实例部署在同一个VPC内,网络默认互通。 如果客户端和RocketMQ实例部署在不同VPC中,由于VPC之
配置RocketMQ网络连接 连接RocketMQ网络要求 配置RocketMQ实例的公网访问 父主题: 连接实例
使用控制台连接RocketMQ 本章节介绍RocketMQ实例如何在控制台生产消息。此功能通过将指定消息发送给RocketMQ实例,验证业务逻辑是否正常。 前提条件 已存在“运行中”的RocketMQ实例。 已创建Topic。 使用控制台连接RocketMQ生产消息 登录管理控制台。
cketMQ实例成功后,需要手动创建Topic,然后才能进行生产消息和消费消息。 前提条件 已购买RocketMQ实例。 创建Topic 登录管理控制台。 在管理控制台左上角单击,选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击,选择“应用中间件 > 分
连接问题 RocketMQ是否支持自建Broker连接云上nameserver? 连接实例失败,报错RemotingTooMuchRequestException: sendDefaultImpl call timeout
网连接地址”(公网访问)。内网访问的连接端口为8100,公网环境下访问的连接端口为8200。 客户端和RocketMQ实例之间网络已互通,具体网络要求参见连接RocketMQ网络要求页面。 已配置安全组。 已创建Topic。 客户端所在服务器已安装Java Development
扩容实例代理个数。具体操作,请参考变更实例规格。 将已有Topic扩展到新代理上。具体操作,请参考修改RocketMQ Topic配置。 配置RocketMQ监控告警 登录管理控制台。 在管理控制台左上角单击,选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击,选择“应用中间件 > 分
连接实例失败,报错RemotingTooMuchRequestException: sendDefaultImpl call timeout 问题现象 连接RocketMQ实例失败,报错“RemotingTooMuchRequestException: sendDefaultImpl
RocketMQ是否支持自建Broker连接云上nameserver? 不支持。自建Broker连接到云上RocketMQ的nameserver,会影响管理面功能,导致查询不到Topic等问题。 父主题: 连接问题
/** * 执行本地事务,并确定本地事务结果。 * 1. 如果本地事务提交成功,则提交消息事务。 * 2. 如果本地事务提交失败,则回滚消息事务。 * 3. 如果本地事务未知异常,则不处理,等待事务消息回查。
连接实例 配置RocketMQ网络连接 配置RocketMQ访问控制 使用客户端连接RocketMQ(关闭SSL) 使用客户端连接RocketMQ(开启SSL) 使用控制台连接RocketMQ
etMQ所需的连接信息。 客户端连接RocketMQ实例5.x版本收发事务消息前,需要确保Topic的消息类型为“事务”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为5.0.5。 使用Maven方式引入依赖。 <dependency>
消费并发度 客户端的消费并发度由单客户端线程数和客户端数量决定。单客户端线程数是指单个客户端所包含的线程数量,客户端数量是指消费组所包含的客户端(消费者)数量。对于普通消息、定时/延时消息、事务消息及顺序消息的消费并发度计算方法如下: 消息类型 消费并发度 普通消息 单客户端线程数 *
etMQ所需的连接信息。 客户端连接RocketMQ实例5.x版本收发事务消息前,需要确保Topic的消息类型为“事务”。 发送事务消息 参考如下示例代码(以下加粗内容需要替换为实例自有信息,请根据实际情况替换)。 import time from rocketmq.client
etMQ所需的连接信息。 客户端连接RocketMQ实例5.x版本收发事务消息前,需要确保Topic的消息类型为“事务”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4.9.8。 通过以下任意一种方式引入依赖: 使用Maven方式引入依赖。
etMQ所需的连接信息。 客户端连接RocketMQ实例5.x版本收发事务消息前,需要确保Topic的消息类型为“事务”。 准备环境 执行以下命令,检查是否已安装Go。 go version 返回如下回显时,说明Go已经安装。 go version go1.16.5 linux/amd64