文档首页> > 快速入门

快速搭建您的第一个分布式消息服务

更新时间: 2018-11-09 17:40
  • 华为云分布式消息服务(Distributed Message Service,简称DMS)是一项基于高可用分布式集群技术的消息中间件服务,提供了可靠且可扩展的托管消息队列,用于收发消息和存储消息。

  • 华为云控制台提供一键式创建队列、创建消费组、生产消息,消费消息等操作,帮助用户省去运维烦恼。

  • 本指南以Kafka队列为例,指导您快速上手分布式消息服务。

Step1 准备环境

步骤

① 登录 华为云控制台 。选择“计算 > 弹性云服务器”,创建一台弹性云服务器(ECS),建议选择windows服务器。
② 下载和安装开发工具: Eclipse 3.6.0以上版本, JDK 1.8.111以上版本。

说明

① ECS需要绑定一个弹性IP,具备外网访问权限,用于安装Eclipse和JDK。
② 如果用户已有ECS,可重复使用,无需多次创建。

1

购买弹性云服务器

购买弹性云服务器

2

配置镜像

配置镜像

3

配置弹性IP

配置弹性IP

单击图片可查看原图

Step2 创建Kafka队列

步骤

① 控制台选择“应用服务 > 分布式消息服务 DMS”。单击右上角“创建队列”。
② 填写队列名称,选择队列类型为“Kafka队列”,选择队列模式。单击“确定”,创建队列。

说明

① 确认当前区域为您应用服务部署的区域,如果不一致,请单击控制台左上角的区域图标进行切换。

1

创建队列

创建队列

2

配置队列信息

配置队列信息

单击图片可查看原图

Step3 创建消费组

步骤

① 队列创建完成后,单击队列名称,进入队列详情页。
② 单击“创建消费组”,填写消费组名称,完成消费组创建。

说明

① 队列详情页的上方显示了Kafka Topic,下方显示了消费组ID。在生产与消费消息时使用这几项识别Kafka队列以及消费组。
② 一个队列默认可以创建3个消费组,队列和消费组的模式帮助服务架构解耦。。

1

创建消费组

创建消费组

单击图片可查看原图

Step4 获取IAM认证信息

步骤

① 单击控制台右上角的用户名,进入“账号中心”,在“基本信息”中单击“管理我的凭证”。
② 在“我的凭证”页中获取项目ID以及访问密钥(AK/SK),用于Kafka队列Demo示例工程配置。

说明

① 分布式消息服务使用华为云IAM服务进行身份识别,保证队列和消息的安全。
②AK/SK密钥对如果已申请,可以使用原有AK/SK。

1

单击用户名

单击用户名

2

管理我的凭证

管理我的凭证

3

获取项目ID和访问秘钥

获取项目ID和访问秘钥

单击图片可查看原图

Step5 搭建工程环境

步骤

① 登录ECS,下载 emo 示例包 (含SDK)。
② 导入工程,选择“Exiting Projects Into Workspace”方式导入。
③ 将获取到的队列Topic、消费组ID、项目ID以及AK/SK等信息替换到配置文件中。具体配置请参见 运行示例工程

说明

① 工程包含了DMS Kafka的SDK文件以及demo示例代码。
② 需要对弹性云服务器添加域名服务器地址,帮助解析DMS Kafka的Endpoint地址。

1

导入工程

导入工程

2

配置DNS Server IP

配置DNS Server IP

单击图片可查看原图

Step6 编译和管理队列消息

步骤

① 编译工程,也可设置为Build Automatically。
② 运行DMSKafkaProducerDemo类,生产消息。
③ 运行DMSKafkaconsumerDemo类,从消费组消费消息。

说明

① 在控制台可以查看队列和消费组的消息数变化。
② Demo工程可以正常生产和消费消息,则说明队列、消费组以及本地环境配置均正确。开发者可以参考Demo进行开发和对接分布式消息服务。

1

编译工程

编译工程

2

生产消息

生产消息

3

消费消息

消费消息

单击图片可查看原图

相关操作指导

视频小图标 Created with Sketch.

创建队列和消费组

视频小图标 Created with Sketch.

DMS Kafka队列

文档是否有解决您的问题?

提交成功!

非常感谢您的反馈,我们会继续努力做到更好!

反馈提交失败,请稍后再试!

在文档使用中是否遇到以下问题







请至少选择或填写一项反馈信息

字符长度不能超过100

反馈内容不能为空!

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

跳转到云社区
点我,12·12惊喜等着你哦~