更新时间:2022-02-21 GMT+08:00
运行示例工程
- 登录弹性云服务器。
- 安装Java JDK或JRE,并配置JAVA_HOME与PATH环境变量,使用执行用户修改~/.bash_profile,添加如下行。
export JAVA_HOME=/opt/java/jdk1.8.0_151 export PATH=$JAVA_HOME/bin:$PATH
执行source .bash_profile命令使修改生效。
ECS虚拟机默认自带的JDK可能不符合要求,例如OpenJDK,需要配置为Oracle的JDK,可至Oracle官方下载页面下载Java Development Kit 1.8.111及以上版本。
- 下载DMS TCP Demo示例工程。
$ wget https://dms-demo.obs.cn-north-1.myhuaweicloud.com/DmsTcpDemoClient.zip
- 解压DmsTcpDemoClient.zip压缩包。
$ unzip DmsTcpDemoClient.zip
- 进入DmsTcpDemoClient/dist目录,该目录下包含预编译好的二进制文件和执行脚本。
$ cd DmsTcpDemoClient/dist
- 编辑配置文件config/dms.client.properties,设置access_key、secret_key和project_id。
$ vim config/dms.client.properties
设置内容如下(其中标红内容需要替换为实际值):
dms.server.ip=d dms.server.port=60010 dms.client.project.id=bd67aaead60940d688b872c31bdc663b dms.client.access.key=************** dms.client.secret.key=**************
- 使用队列ID和消费组ID作为命令行参数,运行示例脚本,测试生产消息与消费消息。
$ bash dms_tcp_demo.sh 5964181e-b67e-4d35-9281-a58c352abda6 g-c861aa48-a082-48ff-bc9d-ff36fe7aed38
命令执行完后,会发送10条消息到队列中,然后从队列中消费消息,并返回消费结果。
- 可以登录,查看指定消息队列的消息数,验证示例脚本执行结果。
父主题: 普通队列开发指南