十分钟快速玩转 Aliware MQ-阿里云消息队列Demo工程实践

摘要: 本 Demo 主要目的在于帮助初次接触 Aliware MQ 的工程师,一步一步搭建 MQ 测试工程。Demo 程序以 Java 为例,包括普通消息、事务消息、定时消息的测试代码,以及相关 Spring 的配置示例。

环境准备

本 Demo 主要目的在于帮助初次接触 Aliware MQ 的工程师,一步一步搭建 MQ 测试工程。Demo 程序以 Java 为例,包括普通消息、事务消息、定时消息的测试代码,以及相关 Spring 的配置示例。

安装 IDE

本文以 IDEA 为例。您可以使用 IDEA 或者 Eclipse。

  1. https://www.jetbrains.com/idea/ 下载 IDEA。请下载 Ultimate 版本。
  2. 执行 IDEA 安装包,安装 IDEA。
  3. 选择 License server 激活方式,填入 License server address(填入合法地址),例如 http://idea.iteblog.com/key.php (仅做参考)。
  4. 单击 Discover server。
  5. 单击最下方激活按钮,激活成功。

安装 Git

请按以下步骤操作:

  1. Git 官网 下载安装包,双击进行安装。
  2. 访问官网 https://github.com/ 注册 GitHub 账号。
  3. 生成 GitHub 秘钥,在本机命令行里输入 ssh-keygen -t rsa -C “xxxx@163.com”(您注册 GitHub 的邮箱),使用默认值回车2次。
  4. 执行以下命令:

    cd ~/.ssh/ 
    cat id_rsa.pub
  5. 把 cat 的内容,即 GitHub 公钥整体复制下来。

  6. 登录 GitHub 官网,单击 Settings,在左侧菜单选择 SSH and GPG keys。
  7. 单击页面右上角 New SSH key,输入相关信息后单击 Add SSH key 保存。

    • Title: 可以自定义填写
    • Key: 将刚才复制的 GitHub 公钥粘贴在此处

下载 MQ Demo 工程

通过 Git 下载 MQ Demo 工程到本地。执行以下命令:
cd xxxxx(此处为保存工程的本地路径)
git clone git@github.com:lollipopjin/Aliware-MQ-demo.git
下载完成后即可看到本地新增了 Aliware-MQ-demo 文件夹,此文件夹里面为 Demo工程。

Demo 工程配置

Demo 工程设置包含以下几个步骤。

MQ Demo工程文件导入 IDEA

注意:如果本地未安装 JDK,请先下载安装。

  1. 双击 IDEA 图标打开 IDEA。
  2. 选择 Import Project,选择 MQ Demo 文件夹。
  3. 选择 Import 类型。
  4. 默认单击 Next,直到导入完成。Demo 工程需要加载依赖的 Jar 包,因此导入过程需要等待2-3分钟。

申请 MQ 资源(全免费)

请在 MQ 控制台创建 Topic、发布组 Producer ID(PID)、订阅组 Consumer ID (CID)。公网测试 Region 免 Topic 占用费,前2000万次调用免费。

  1. 进入 Aliware MQ 产品首页:https://www.aliyun.com/product/ons/
  2. 单击免费开通,进入管理控制台。
  3. 选择公网测试 域(默认),单击右侧发布 Topic,输入 Topic 名称(尽量个性化避免重复),单击确定
  4. 创建发布组 PID。在 Topic 管理列表中单击申请发布
  5. 创建订阅组 CID。在 Topic 管理列表中单击申请订阅

    详细信息请参考申请 MQ 资源

配置 MQ Demo

需要配置3个文件:MqConfig 类,producer.xml,consumer.xml。

  1. 配置 MqConfig 类。

    • public static final String TOPIC = “刚才创建的Topic”;
    • public static final String PRODUCER_ID = “刚才创建的PID”;
    • public static final String CONSUMER_ID = “刚才创建的CID”;
    • public static final String ACCESS_KEY = “您的阿里云账号的AK”;
    • public static final String SECRET_KEY = “您的阿里云账号的SK”;
      AK SK 获取:请登录阿里云账号,点击 AccessKeys。AK 即 Access Key ID,SK 即 Access Key Secret。

说明:主账号创建 Topic 后,如果在 MQ 控制台的 Topic 管理列表里对子账号进行了授权,那么也可以使用 RAM 子账号的 AK SK。

  1. 配置 producer.xml。

  2. 配置 consumer.xml。

运行 Demo

以 Main 方式启动收发消息

  1. 运行 SimpleMQProducer 类发送消息。
  2. 登录 MQ 控制台,在左侧菜单栏选择消息查询>Topic 查询,选择 Topic 名称进行查询。可以看见消息已经发送至 Topic。
  3. 运行 SimpleMQConsumer 类接收消息。可以看到消息被接收打印的日志。因为有初始化,所以需等待几秒,在生产环境中不会经常初始化。

    订阅管理>消费者状态中可以看到,启动的消费端已经在线,并且订阅关系一致。

以 Spring 方式启动收发消息

  1. 运行 MQProducer4Spring 类发送消息。
  2. 运行 MQConsumer4Spring 类接收消息。
    查看结果跟上面过程类似。

发送事务消息

运行 SimpleTransactionProducer 类发送消息。

说明:LocalTransactionCheckerImpl 类为本地事务 check 接口类。用于校验事务。详情请参考发送分布式事务消息。

发送定时(延时)消息

运行 MQTimerProducer 类发送消息。延时3秒后投递。

说明:MQ 也可以指定一个精确的投递时间,最长定时时间为40天。具体请参考发送定时消息。

HTTP、MQTT 物联接入

  1. HTTP 接入请参考 MQ HTTP 接入
  2. MQTT 接入请参考 MQTT 接入

企业级互联网架构Aliware,让您的业务能力云化:https://www.aliyun.com/aliware