检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
展、便捷管理和多样功能的消息队列。 即开即用:简单几步即可在云上构建自己专属的消息服务,RocketMQ实例创建完成后,使用实例提供的访问地址即可快速接入。兼容开源RocketMQ,业务代码无需改造,即可上云。 全托管服务:分布式消息服务RocketMQ版提供自动部署与完备的运维
SDK概述 本文介绍了分布式消息服务RocketMQ版提供的SDK语言版本,列举了最新版本SDK的获取地址。 在线生成SDK代码 API Explorer能根据需要动态生成SDK代码功能,降低您使用SDK的难度,推荐使用。 SDK列表 表1提供了分布式消息服务RocketMQ版支
新创建。如果重新创建仍然失败,请联系客服。 实例创建成功后,单击实例名称,进入实例基本信息页面。 记录实例的连接地址,便于生产和消费消息时使用。 图7 记录实例连接地址 步骤三:创建Topic Topic,即消息主题,消息发送与接收的基本单元。创建RocketMQ实例成功后,需要
示例代码中的参数说明如下,请参考收集连接信息获取参数值。 Topic:输入Topic名称。 Endpoint:输入grpc连接地址/grpc公网连接地址。 AccessKey:创建实例时,如果开启了ACL,需要输入用户名。 SecretKey:创建实例时,如果开启了ACL,需要输入用户密钥。
String topic = "yourNormalTopics"; // 填入grpc连接地址/grpc公网连接地址 String endpoints = "yourEndpoints"; // 填入用户名/密钥
单位:毫秒 生产地址 生产者的IP地址。 消费者状态 消费者状态如下: 消费成功 消费超时 消费异常 消费返回NULL 消费失败 消费时间 消费消息的时间。 时间格式为:YYYY/MM/DD hh:mm:ss 消费耗时 消费者消费消息的耗时。 单位:毫秒 消费地址 消费者的IP地址。 父主题:
mqadmin sendMessage -n "${连接地址}" -t ${Topic名称} -p "hello rocketmq" 参数说明如下: 连接地址:表示RocketMQ实例的“连接地址”(内网访问)/“公网连接地址”(公网访问)。 Topic名称:RocketMQ实例下创建的Topic名称。
有数据(如消息、元数据和日志等)都保存在云硬盘中。 弹性公网IP(Elastic IP) 弹性公网IP提供独立的公网IP资源,包括公网IP地址与公网出口带宽服务。RocketMQ实例绑定弹性公网IP后,可以通过公网访问RocketMQ实例。 标签管理服务(Tag Management
String topic = "yourNormalTopics"; // 填入grpc连接地址/grpc公网连接地址 String endpoints = "yourEndpoints"; // 填入用户名/密钥
RocketMQ暴露给不可信的第三方。 表1 安全组规则 实例版本 方向 协议 端口 源地址 说明 4.8.0 5.x 入方向 TCP 8100 访问DMS for RocketMQ实例的客户端地址,应避免设置为0.0.0.0/0。 使用TCP协议,通过内网访问实例的端口。 4.8.0
enable_publicip 否 Boolean 是否开启公网。 publicip_id 否 String 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 如果开启了公网访问功能(即enable_publicip为true),该字段为必选。 响应参数 无 请求示例
返回一个资源特征与地址的列表用于用户终端(例如:浏览器)选择。 301 Moved Permanently 永久移动,请求的资源已被永久的移动到新的URI,返回信息会包括新的URI。 302 Found 资源被临时移动。 303 See Other 查看其它地址。 使用GET和POST请求查看。
loadService(); String topic = "yourDelayTopic"; // 填入grpc连接地址/grpc公网连接地址 String endpoints = "yourEndpoints"; // 填入用户名/密钥
1)(n表示代理数量)。 扩容代理个数不会影响原来的代理,业务也不受影响。 已开启公网访问,且设置了弹性IP地址的实例,在扩容代理个数时,需要为新扩容的代理设置弹性IP地址。 扩容代理规格。 在“变更类型”中,选择“代理规格”,在“代理规格”中,选择扩容后的代理规格,单击“下一步”。确认扩容信息无误后,单击“提交”。
当前只支持扩容,不支持缩容。扩容存储空间有次数限制,只能扩容20次。 支持区域: 全部 扩容存储空间或代理个数 公网访问 您需要通过公网地址访问RocketMQ实例时,开启实例的公网访问功能,并设置弹性IP地址。 只有处于“运行中”状态的RocketMQ实例支持修改公网访问配置。 支持区域: 全部 设置实例公网访问
String topic = "yourTransactionTopic"; // 填入grpc连接地址/grpc公网连接地址 String endpoints = "yourEndpoints"; // 填入用户名/密码
当oper_type参数为horizontal时,该参数必填。 publicip_id 否 String 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 当oper_type参数为horizontal且开启了公网访问时,此参数必填。 响应参数 状态码: 200 表3
时/延迟消息、事务消息,不同类型的消息需要用不同的Topic来区分,无法通过Tag区分。 根据消息优先级判断:在业务中紧急程度高和紧急程度一般的消息用不同的Topic来区分,方便后续业务处理。 根据业务关联性判断:业务逻辑上不相关的消息用不同Topic来区分,业务逻辑上强关联的消
管理消费组 创建RocketMQ消费组 查看RocketMQ消费组详情 查看RocketMQ消费者连接地址 修改RocketMQ消费组配置 重置RocketMQ消费进度 删除RocketMQ消费组
已购买RabbitMQ 3.7.17/3.8.35版本实例。 步骤一:获取RabbitMQ的元数据 在浏览器中输入“http://您的RabbitMQ IP地址:15672/”,进入开源RabbitMQ控制台。 在登录页面输入用户名和密码,单击“Login”。 默认的用户名和密码即购买RabbitMQ实例时配置的用户名和密码。