更新时间:2022-02-21 GMT+08:00

运行示例工程

  1. 登录弹性云服务器。
  2. 安装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及以上版本

  3. 下载DMS TCP Demo示例工程

    $ wget https://dms-demo.obs.cn-north-1.myhuaweicloud.com/DmsTcpDemoClient.zip

  4. 解压DmsTcpDemoClient.zip压缩包。

    $ unzip DmsTcpDemoClient.zip

  5. 进入DmsTcpDemoClient/dist目录,该目录下包含预编译好的二进制文件和执行脚本。

    $ cd DmsTcpDemoClient/dist

  6. 编辑配置文件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=**************

  7. 使用队列ID和消费组ID作为命令行参数,运行示例脚本,测试生产消息与消费消息。

    $ bash dms_tcp_demo.sh 5964181e-b67e-4d35-9281-a58c352abda6 g-c861aa48-a082-48ff-bc9d-ff36fe7aed38

    命令执行完后,会发送10条消息到队列中,然后从队列中消费消息,并返回消费结果。

  8. 可以登录,查看指定消息队列的消息数,验证示例脚本执行结果。