更新时间:2024-09-20 GMT+08:00

RocketMQ业务使用流程

分布式消息服务RocketMQ版(以下简称RocketMQ)是一个低延迟、弹性高可靠、高吞吐、动态扩展、便捷多样的消息中间件服务。用户购买RocketMQ实例后,生产者客户端连接RocketMQ实例进行消息生产,生产的消息被存储在RocketMQ实例的Topic中,消费者客户端通过订阅Topic消费消息。

使用RocketMQ实例生产消费消息的流程如下图所示。

图1 RocketMQ业务使用流程
  1. 创建用户并授权使用DMS for RocketMQ

    创建IAM用户,并授予DMS for RocketMQ的权限,以达到用户之间权限的隔离。

  2. 购买RocketMQ实例

    RocketMQ实例采用物理隔离的方式部署,租户独占RocketMQ实例。

  3. 创建RocketMQ Topic

    创建用于存储消息的Topic,供生产者生产消息以及消费者订阅消息。

  4. 连接实例

    客户端使用内网/公网通过连接RocketMQ实例生产消费消息。