检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
客户端和RocketMQ实例之间网络已互通,具体网络要求参见连接RocketMQ网络要求页面。 已配置安全组。 已创建Topic。 客户端所在服务器已安装Java Development Kit 1.8.111或以上版本,并完成环境变量配置。
当网络发生异常或节点故障时,通过Raft协议自动切换主备关系,保持数据一致性。 - 数据持久化 业务系统日常运行中可能出现一些小概率的异常事件。
static final Logger log = LoggerFactory.getLogger(AsyncProducerExample.class); private AsyncProducerExample() { } public static
static final Logger log = LoggerFactory.getLogger(ProducerDelayMessageExample.class); private ProducerDelayMessageExample() { }
节点每秒网络访问流入流量 单位:Byte/s >0 RocketMQ实例节点 1分钟 broker_total_bytes_out_rate 网络出流量 节点每秒网络访问流出流量 单位:Byte/s >0 RocketMQ实例节点 1分钟 broker_cpu_core_load
org.slf4j.LoggerFactory; import java.io.IOException; import java.nio.charset.StandardCharsets; public class ProducerFifoMessageExample { private
org.slf4j.LoggerFactory; import java.io.IOException; import java.nio.charset.StandardCharsets; public class ProducerTransactionMessageExample { private
应用示例 批量创建Topic
历史API API V1 API V2
生命周期管理 查询所有实例列表 创建实例 查询指定实例 删除指定的实例 修改实例信息 批量删除实例 查询代理列表 父主题: API V2(推荐)
标签管理 批量添加或删除实例标签 查询实例标签 查询项目标签 父主题: API V2(推荐)
实例管理 查询实例节点 重启指定实例 父主题: API V2(推荐)
实例管理类接口 创建实例 查询实例 查询实例列表 修改实例 删除实例 父主题: API V1
Java(gRPC协议) 收发普通消息 收发顺序消息 收发事务消息 发送定时消息
配置RocketMQ访问控制 开启RocketMQ ACL访问 配置RocketMQ ACL用户 父主题: 连接实例
消息问题 RocketMQ的消息保留时间是多少?可以修改吗? RocketMQ支持的最大消息大小是多少?可以修改吗? RocketMQ副本存储形式是怎样的?可以修改吗? 消息创建时间在哪设置?
实例问题 RocketMQ实例兼容开源RocketMQ哪个版本? 实例可靠性是怎么保障的? 为什么RocketMQ 4.8.0版本不能选择2个可用区? RocketMQ实例的SSL配置是否支持修改? 磁盘类型对RocketMQ实例性能有什么影响?
计费模式 计费模式概述 包年/包月 按需计费
续费 续费概述 手动续费 自动续费
图解Kafka、RabbitMQ和RocketMQ的差异