收发普通消息 收发顺序消息 收发事务消息 发送定时消息 Go（TCP协议） 收发普通消息 收发顺序消息 收发事务消息 发送定时消息 使用ACL权限访问 Go（gRPC协议） 收发普通消息 收发顺序消息 收发事务消息 发送定时消息 Python（TCP协议） 收发普通消息 收发顺序消息

查看更多 →

st_01”。 消息类型 选择消息的类型，支持的消息类型：普通、顺序、定时和事务。 普通消息：没有特殊功能的消息，区别于定时消息、顺序消息和事务消息。 定时消息：生产者生产消息到分布式消息服务RocketMQ版后，消息不会立即被消费，而是延迟到特定时间后才会发送给消费者进行消费。

查看更多 →

异步下载 开发过程中，您有任何问题可以在github上提交issue，或者在华为云 对象存储服务 论坛中发帖求助。接口参考文档详细介绍了每个接口的参数和使用方法。 您可以通过ObsClient.BeginGetObject和ObsClient.EndGetObject，进行异步下载对象。

查看更多 →

收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证，通过两阶段的方式提供对事务消息的支持，事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息，然后执行本地事务。如果执行成功，则发送事务提交，否则发送事务回

查看更多 →

Rocketmq部署 安装配置JDK、上传并解压 RocketMq配置 配置JVM启动参数 启动RocketMq 部署rocketmq-console控制台 父主题： 实施步骤

查看更多 →

启动RocketMq 创建rocketmq-namesrv # vim /etc/systemd/system/rocketmq-namesrv.service [Unit] Description=rocketmq-namesrv Documentation=http://mirror

查看更多 →

在后面添加 #设置rocketmq的环境变量 export ROCKETMQ_HOME=/usr/local/rocketmq export PATH=$JAVA_HOME/bin:$ROCKETMQ_HOME/bin:$PATH 按esc+!wq保存 使rocketmq的配置生效 source

查看更多 →

禁止：表示用户既不可以往Topic发送消息，也不能消费Topic中的消息。 发布：表示用户只可以往Topic发送消息，不能消费Topic中的消息。 订阅：表示用户不可以往Topic发送消息，但可以消费Topic中的消息。 发布+订阅：表示用户既可以往Topic发送消息，也可以消费Topic中的消息。 如果

查看更多 →

RocketMQ的消息保留时间是多少？可以修改吗？ RocketMQ的消息保留时间默认为48小时，支持修改，最大保留时间为720小时。修改消息保留时间的步骤，请参见修改消息老化时间。 父主题： 消息问题

查看更多 →

RocketMQ支持的最大消息大小是多少？可以修改吗？ RocketMQ支持的最大消息大小是4M，且不支持修改。 父主题： 消息问题

查看更多 →

收发顺序消息 顺序消息是分布式消息服务RocketMQ版提供的一种严格按照顺序来发布和消费的消息类型。 顺序消息分为全局顺序消息和分区顺序消息： 全局顺序消息：对于指定的一个Topic，将队列数量设置为1，这个队列内所有消息按照严格的先入先出FIFO（First In First

查看更多 →

设置SMN主题策略，允许DRS发送消息通知 该章节指导用户通过手动设置SMN主题策略的方式，授权DRS服务发送消息通知。 操作步骤 登录管理控制台。 单击管理控制台左上角的，选择区域和项目。 单击“服务列表”，选择“管理与监管 > 消息通知服务”。 进入消息通知服务页面。 在左侧导航栏，选择“主题管理

查看更多 →

消费方式，针对不同生产顺序消息类型，选择消费方式会导致不同结果，请严格按照需求选择消费方式。1、生产顺序为：设置消息组，保证消息顺序发送。消费方式为：顺序消费，实际消息处理结果：按照消息组粒度，严格保证消息顺序。 同一消息组内的消息的消费顺序和发送顺序完全一致。2、生产顺序为：设置消息组，保证消

查看更多 →

Flume正常连接Kafka后发送消息失败 问题现象 使用 MRS 版本安装集群，主要安装ZooKeeper、Flume、Kafka。 在使用Flume向Kafka发送数据功能时，发现Flume发送数据到Kafka失败。 可能原因 Kafka服务异常。 Flume连接Kafka地址错误，导致发送失败。 F

查看更多 →

RocketMq配置 节点1主192.168.0.190节点配置broker-master # vim /opt/rocketmq-4.4.0/conf/broker-master.conf brokerClusterName=SyncCluster brokerName=broker-01

查看更多 →

消费方式，针对不同生产顺序消息类型，选择消费方式会导致不同结果，请严格按照需求选择消费方式。1、生产顺序为：设置消息组，保证消息顺序发送。消费方式为：顺序消费，实际消息处理结果：按照消息组粒度，严格保证消息顺序。 同一消息组内的消息的消费顺序和发送顺序完全一致。2、生产顺序为：设置消息组，保证消

查看更多 →

消费方式，针对不同生产顺序消息类型，选择消费方式会导致不同结果，请严格按照需求选择消费方式。1、生产顺序为：设置消息组，保证消息顺序发送。消费方式为：顺序消费，实际消息处理结果：按照消息组粒度，严格保证消息顺序。 同一消息组内的消息的消费顺序和发送顺序完全一致。2、生产顺序为：设置消息组，保证消

查看更多 →

消费方式，针对不同生产顺序消息类型，选择消费方式会导致不同结果，请严格按照需求选择消费方式。1、生产顺序为：设置消息组，保证消息顺序发送。消费方式为：顺序消费，实际消息处理结果：按照消息组粒度，严格保证消息顺序。 同一消息组内的消息的消费顺序和发送顺序完全一致。2、生产顺序为：设置消息组，保证消

查看更多 →

收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证，通过两阶段的方式提供对事务消息的支持，事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息，然后执行本地事务。如果执行成功，则发送事务提交，否则发送事务回

查看更多 →

配置消息堆积数监控 方案概述 在消息处理过程中，如果客户端的消费速度跟不上服务端的发送速度，未处理的消息会越来越多，这部分消息就被称为堆积消息。消息没有被及时消费就会产生消息堆积，从而会造成消息消费延迟。 如果您想要在消费组的消息堆积数超过阈值时，通过短信/邮件及时收到通知信息，

查看更多 →

ACL访问 公网访问 rocketmq-01 rocketmq.b2.large.4 超高I/O 300GB 关闭 关闭 rocketmq-02 rocketmq.b2.large.8 超高I/O 300GB 关闭 关闭 rocketmq-03 rocketmq.b2.large.12

查看更多 →