检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
云监控(Cloud Eye) 云监控是一个开放性的监控平台,提供资源的实时监控、告警、通知等服务。
收集连接信息 约束与限制 仅RocketMQ实例5.x版本支持gRPC协议,4.8.0版本不支持。 获取实例连接信息 实例连接地址和端口 实例创建后,从RocketMQ实例控制台的“基本信息”页面获取,在客户端配置时,可将地址都配上。 使用TCP协议通过内网连接RocketMQ实例时
Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK
wget https://archive.apache.org/dist/rocketmq/4.9.8/rocketmq-all-4.9.8-bin-release.zip 解压软件包。
配置RocketMQ实例的公网访问 您需要通过公网地址访问RocketMQ实例时,开启实例的公网访问功能,并设置弹性IP地址。当业务不再使用公网访问功能时,关闭实例的公网访问功能。 约束与限制 RocketMQ实例只支持绑定IPv4弹性IP地址。 前提条件 只有处于“运行中”状态的
Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK
|SUB" } ], "group_perms" : [ { "name" : "group1", "perm" : "PUB|SUB" } ] } 响应示例 状态码: 200 修改成功。
成长地图 | 华为云 分布式消息服务RocketMQ版 分布式消息服务RocketMQ版(Distributed Message Service for RocketMQ)是一个低延迟、弹性高可靠、高吞吐、动态扩展、便捷多样的消息中间件服务。
查看和修改RocketMQ实例基本信息 本节介绍如何在控制台查看RocketMQ实例的详细信息,以及修改RocketMQ实例的基本信息。 创建RocketMQ实例成功后,您可以根据自己的业务情况对RocketMQ实例的部分配置信息进行调整,包括实例名称、描述、安全组等。 前提条件
Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK
使用客户端连接RocketMQ(关闭SSL) 本文主要介绍在Linux系统的命令行模式下,调用TCP协议连接未开启SSL的RocketMQ实例。 创建实例时或者在实例基本信息中,将“SSL”配置为“PLAINTEXT”或“PERMISSIVE”(通过明文传输),即为未开启SSL。
None 服务介绍 分布式消息服务RocketMQ版 04:19 介绍什么是分布式消息服务 分布式消息服务介绍 特性讲解 分布式消息服务RocketMQ版 介绍订阅关系一致性功能 03:01 订阅关系一致性 操作指导 分布式消息服务RocketMQ版 介绍怎样购买RocketMQ实例
[ { "success" : true, "trace_type" : "Pub", "timestamp" : 1634822858013, "group_name" : "ProducerGroupName", "cost_time" : 47, "request_id
|SUB" } ], "group_perms" : [ { "name" : "group1", "perm" : "PUB|SUB" } ] } 响应示例 状态码: 200 创建成功。
Python(TCP协议) 收发普通消息 收发顺序消息 收发事务消息 发送定时消息 使用ACL权限访问
收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证,通过两阶段的方式提供对事务消息的支持,事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息,然后执行本地事务。如果执行成功,则发送事务提交,否则发送事务回滚
{ "access_key" : "test_01", "admin" : false, "default_group_perm" : "DENY", "default_topic_perm" : "SUB", "group_perms" : [ ], "secret_key
修改RocketMQ Topic配置 RocketMQ实例为4.8.0版本时您可以根据业务需要修改Topic的权限配置、关联代理配置和描述信息,为5.x版本时仅支持修改描述信息。 前提条件 已购买RocketMQ实例。 已创建Topic。 修改Topic信息 登录管理控制台。 在管理控制台左上角单击
{ "users" : [ { "access_key" : "test_01", "admin" : false, "default_group_perm" : "DENY", "default_topic_perm" : "SUB",
取值范围: pub(发布) sub(订阅) all(发布+订阅) message_type 否 String 消息类型(仅RocketMQ实例5.x版本需要填写此参数)。