本节介绍如何快速本地试用公有云消息队列服务。
操作步骤
开通消息队列服务。
说明如果已开通服务,可以忽略这一步。
如果没有账号,可使用支付宝扫描登录。
登录 消息队列产品 页面。
在 开通 SOFAMQ 消息队列体验版 页面,单击 确认开通。
若开通成功,页面会显示 恭喜,SOFAMQ 消息队列体验版开通下单成功 的提示。在该页面单击 进入控制台 按钮进入消息队列控制台。
申请并下载 Demo。
登录 本地快速试用 Demo 申请 页面。
单击 申请并下载本地试用 Demo。 单击后,后台开始构建 Demo 并下载。
将 ZIP 文件放在指定目录,例如
/home/XX/sofamq-demo
下。
启动 Agent。
进入解压后的文件夹,解压后的文件格式如下:
agent:存放 Agent 启动相关的文件。
sofamq-demo: 是消息队列的一个 Demo。
进入到 agent 目录下,执行以下命令启动 Agent。
cd agent sh start_agent.sh
启动后, 本地多了一个 Java 进程。
下载
settings.xml
并重新编译 Demo。通过 idea 打开 sofamq-demo 项目。
说明Demo 请使用 Java 1.8。
下载 settings.xml 文件,放置到
~/.m2/
目录中。您也可以将 idea 中 Maven 的 settings 设置为下载 setting.xml 文件。
获取 AccessKey。
登录 管理控制台。
在 服务账号 页面,单击 新增服务账号。
在弹出的对话框中输入服务账号的 名称 和 描述,单击 确定 完成添加。
新增的服务账号随即出现在服务账号列表中,系统会自动为服务账号分配唯一 ID。
在服务账号列表中,找到需要查看的服务账号,在目标服务账号的 操作 列中,单击 详情 可查看此账号的详细信息,包括 AccessKey 信息以及角色权限。其中:
ID:该服务账号的 AccessKey ID。
Secret:该服务账号的 AccessKey 密钥,单击查看图标按钮()可以查看 AccessKey 密钥明文。
替换 Demo 里的配置里的
com.antcloud.mw.access
和com.antcloud.mw.secret
。
登录 消息队列控制台 添加配置。
创建 Topic。
在左侧导航栏,单击 Topic 管理。
单击 创建 Topic,然后在 创建 Topic 对话框配置 Topic 信息:
Topic:Topic 名称,此处填写
TP_SOFAMQ_DEMO
。消息类型:此处选择 普通消息。
单击 确定。
创建分组。
在左侧导航栏,单击 Group 管理。
单击 创建 Group ID,然后在 创建 Group ID 对话框配置 Group ID 信息:
Group ID:此处填写
SOFAMQ_DEMO_GROUP
。协议类型:此处选择 TCP 协议类型。
单击 确定。
启动 Demo。
启动类:
com.example.sofamqdemo.SofamqDemoApplication
。编译后,直接启动即可。启动后如果没有报错,并看到以下结果说明是启动成功。
常见问题
问题现象:
出现“topic[xxx%TP_SOFAMQ_DEMO] not exist, apply first please!”报错。
解决方法:
登录消息队列控制台创建 1 个名为 TP_SOFAMQ_DEMO
的 Topic。
- 本页导读 (0)