-
RocketMQ实例兼容开源RocketMQ哪个版本? - 分布式消息服务RocketMQ版
RocketMQ实例兼容开源RocketMQ哪个版本? RocketMQ实例兼容开源RocketMQ 4.8.0和5.x,客户端推荐使用4.9.5及更新的版本。 父主题: 实例问题
-
实例可靠性是怎么保障的? - 分布式消息服务RocketMQ版
实例可靠性是怎么保障的? 通过以下两方面保障实例的可靠性: RocketMQ实例采用一主两备的方式存储数据 RocketMQ实例支持跨AZ部署 父主题: 实例问题
-
为什么不能选择2个可用区? - 分布式消息服务RocketMQ版
为什么不能选择2个可用区? 如果您需要提高RocketMQ集群实例的可靠性,在创建实例时,建议选择3个或以上的可用区,不支持选择2个可用区。原因如下:使用2个可用区的实例,如果其中一个可用区故障,可能会导致实例不可用。 父主题: 实例问题
-
RocketMQ副本存储形式是怎样的?可以修改吗? - 分布式消息服务RocketMQ版
RocketMQ副本存储形式是怎样的?可以修改吗? RocketMQ消息是一主两从3个副本的存储形式,且不支持修改。 父主题: 消息问题
-
云监控无法展示Topic监控数据? - 分布式消息服务RocketMQ版
云监控无法展示Topic监控数据? 当Topic名称中包含“%”或“|”时,在云监控中会将“%”或“|”转换为“_”显示,例如Topic名称为“test%01”,在云监控中Topic名称显示为“test_01”。 父主题: 监控告警问题
-
RocketMQ的消息保留时间是多少?可以修改吗? - 分布式消息服务RocketMQ版
RocketMQ的消息保留时间是多少?可以修改吗? RocketMQ的消息保留时间默认为48小时,支持修改,最大保留时间为720小时。修改消息保留时间的步骤,请参见修改消息老化时间。 父主题: 消息问题
-
RocketMQ支持的最大消息大小是多少?可以修改吗? - 分布式消息服务RocketMQ版
RocketMQ支持的最大消息大小是多少?可以修改吗? RocketMQ支持的最大消息大小是4M,且不支持修改。 父主题: 消息问题
-
连接实例失败,报错RemotingTooMuchRequestException: sendDefaultImpl call timeout - 分布式消息服务RocketMQ版
连接实例失败,报错RemotingTooMuchRequestException: sendDefaultImpl call timeout 问题现象 连接RocketMQ实例失败,报错“RemotingTooMuchRequestException: sendDefaultImpl
-
RocketMQ是否支持自建Broker连接云上nameserver? - 分布式消息服务RocketMQ版
RocketMQ是否支持自建Broker连接云上nameserver? 不支持。自建Broker连接到云上RocketMQ的nameserver,会影响管理面功能,导致查询不到Topic等问题。 父主题: 连接问题
-
数据保护技术 - 分布式消息服务RocketMQ版
当网络发生异常或节点故障时,通过Raft协议自动切换主备关系,保持数据一致性。 - 数据持久化 业务系统日常运行中可能出现一些小概率的异常事件。部分可靠性要求非常高的业务系统,除了要求实例高可用,还要求数据安全、可恢复,以便在实例发生异常后能够使用备份数据进行恢复,保障业务正常运行。
-
收发普通消息 - 分布式消息服务RocketMQ版
安装librocketmq库和rocketmq-client-python,具体操作请参考rocketmq-client-python。 建议下载rocketmq-client-cpp-2.2.0,获取librocketmq库。 将librocketmq.so添加到系统动态库搜索路径。 查找librocketmq.so的路径。
-
发送定时消息 - 分布式消息服务RocketMQ版
安装librocketmq库和rocketmq-client-python,具体操作请参考rocketmq-client-python。 建议下载rocketmq-client-cpp-2.2.0,获取librocketmq库。 将librocketmq.so添加到系统动态库搜索路径。 查找librocketmq.so的路径。
-
快速连接RocketMQ并生产消费消息 - 分布式消息服务RocketMQ版
Server,以下简称ECS),JDK安装、环境变量配置。本文以Linux系统的ECS为例,Windows系统ECS的JDK安装与环境变量配置可自行在互联网查找相关帮助。 登录管理控制台,在左上角单击,选择“计算 > 弹性云服务器”,创建一个ECS实例。 具体创建操作,请参考购买弹性云服务器。如果您已有可用的ECS,可重复使用,不需要再次创建。
-
删除指定消费组 - 分布式消息服务RocketMQ版
in the local environment ak = __import__('os').getenv("CLOUD_SDK_AK") sk = __import__('os').getenv("CLOUD_SDK_SK") projectId = "{project_id}"
-
删除指定主题 - 分布式消息服务RocketMQ版
in the local environment ak = __import__('os').getenv("CLOUD_SDK_AK") sk = __import__('os').getenv("CLOUD_SDK_SK") projectId = "{project_id}"
-
连接RocketMQ网络要求 - 分布式消息服务RocketMQ版
个VPC间的网络打通,实现跨VPC访问。 对等连接 客户端连接RocketMQ实例前,需要放通如下安全组,否则会连接失败。 创建安全组后,系统默认添加入方向“允许安全组内的彼此通信”规则和出方向“放通全部流量”规则,此时使用内网通过同一个VPC访问RocketMQ实例,无需添加表2和表3的规则。
-
修改主题 - 分布式消息服务RocketMQ版
in the local environment ak = __import__('os').getenv("CLOUD_SDK_AK") sk = __import__('os').getenv("CLOUD_SDK_SK") projectId = "{project_id}"
-
收发普通消息 - 分布式消息服务RocketMQ版
/v2/primitive" "github.com/apache/rocketmq-client-go/v2/producer" "os" ) // implements a simple producer to send message. func main() { p
-
收发顺序消息 - 分布式消息服务RocketMQ版
参考如下示例代码(以下加粗内容需要替换为实例自有信息,请根据实际情况替换)。 package main import ( "context" "fmt" "os" "strconv" "github.com/apache/rocketmq-client-go/v2" "github.com
-
批量添加或删除实例标签 - 分布式消息服务RocketMQ版
in the local environment ak = __import__('os').getenv("CLOUD_SDK_AK") sk = __import__('os').getenv("CLOUD_SDK_SK") projectId = "{project_id}"