快速搭建您的第一个分布式消息服务
-
华为云分布式消息服务(Distributed Message Service,简称DMS)是一项基于高可用分布式集群技术的消息中间件服务,提供了可靠且可扩展的托管消息队列,用于收发消息和存储消息。
-
华为云控制台提供一键式创建队列、创建消费组、生产消息,消费消息等操作,帮助用户省去运维烦恼。
-
本指南以Kafka队列为例,指导您快速上手分布式消息服务。
Step2 创建Kafka队列
步骤
① 控制台选择“应用服务 > 分布式消息服务 DMS”。单击右上角“创建队列”。
② 填写队列名称,选择队列类型为“Kafka队列”,选择队列模式。单击“确定”,创建队列。
说明
① 确认当前区域为您应用服务部署的区域,如果不一致,请单击控制台左上角的区域图标进行切换。
1
创建队列
2
配置队列信息
单击图片可查看原图
Step3 创建消费组
步骤
① 队列创建完成后,单击队列名称,进入队列详情页。
② 单击“创建消费组”,填写消费组名称,完成消费组创建。
说明
① 队列详情页的上方显示了Kafka Topic,下方显示了消费组ID。在生产与消费消息时使用这几项识别Kafka队列以及消费组。
② 一个队列默认可以创建3个消费组,队列和消费组的模式帮助服务架构解耦。
1
创建消费组
2
查看队列详情
单击图片可查看原图
Step4 获取IAM认证信息
步骤
① 单击控制台右上角的用户名,选择“我的凭证”。
② 在“我的凭证”页中获取项目ID以及访问密钥(AK/SK),用于Kafka队列Demo示例工程配置。
说明
① 分布式消息服务使用华为云IAM服务进行身份识别,保证队列和消息的安全。
②AK/SK密钥对如果已申请,可以使用原有AK/SK。
1
选择我的凭证
2
获取项目ID和访问秘钥
单击图片可查看原图
Step6 编译和管理队列消息
步骤
① 编译工程,也可设置为Build Automatically。
② 运行DMSKafkaProducerDemo类,生产消息。
③ 运行DMSKafkaconsumerDemo类,从消费组消费消息。
说明
① 在控制台可以查看队列和消费组的消息数变化。
② Demo工程可以正常生产和消费消息,则说明队列、消费组以及本地环境配置均正确。开发者可以参考Demo进行开发和对接分布式消息服务。
1
编译工程
2
生产消息
3
消费消息
单击图片可查看原图