本 Demo 紧张目的在于帮助初次打仗 Aliware MQ 的工程师,一步一步搭建 MQ 测试工程。Demo 程序以 Java 为例,包括普通、事务、定时的测试代码,以及干系 Spring 的配置示例。
安装 IDE
本文以 IDEA 为例。您可以利用 IDEA 或者 Eclipse。

在https://www.jetbrains.com/idea/ 下载 IDEA。请下载 Ultimate 版本。
实行 IDEA 安装包,安装 IDEA。
选择 License server 激活办法,填入 License server address(填入合法地址),例如 http://idea.iteblog.com/key.php (仅做参考)。
单击 Discover server。
单击最下方激活按钮,激活成功。
安装 Git
请按以下步骤操作:
在 Git 官网下载安装包,双击进行安装。
访问官网 https://github.com/ 注册 GitHub 账号。
天生 GitHub 秘钥,在本机命令行里输入 ssh-keygen -t rsa -C \"大众xxxx@163.com\"大众(您注册 GitHub 的邮箱),利用默认值回车2次。
实行以下命令:
cd ~/.ssh/
cat id_rsa.pub
把 cat 的内容,即 GitHub 公钥整体复制下来。
登录 GitHub 官网,单击 Settings,在左侧菜单选择 SSH and GPG keys。
单击页面右上角 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,请先下载安装。
双击 IDEA 图标打开 IDEA。
选择 Import Project,选择 MQ Demo 文件夹。
选择 Import 类型。
默认单击 Next,直到导入完成。Demo 工程须要加载依赖的 Jar 包,因此导入过程须要等待2-3分钟。
申请 MQ 资源(全免费)
请在 MQ 掌握台创建 Topic、发布组 Producer ID(PID)、订阅组 Consumer ID (CID)。公网测试 Region 免 Topic 占用费,前2000万次调用免费。
进入 Aliware MQ 产品首页:https://www.aliyun.com/product/ons/
单击免费开通,进入管理掌握台。
选择公网测试 域(默认),单击右侧发布 Topic,输入 Topic 名称(只管即便个性化避免重复),单击确定。
创建发布组 PID。在 Topic 管理列表中单击申请发布。
创建订阅组 CID。在 Topic 管理列表中单击申请订阅。
详细信息请参考申请 MQ 资源。
配置 MQ Demo
须要配置3个文件:MqConfig 类,producer.xml,consumer.xml。
配置 MqConfig 类。
AK SK 获取:请登录阿里云账号,点击 AccessKeys。AK 即 Access Key ID,SK 即 Access Key Secret。
解释:主账号创建 Topic 后,如果在 MQ 掌握台的 Topic 管理列表里对子账号进行了授权,那么也可以利用 RAM 子账号的 AK SK。
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\"大众;
配置 producer.xml。
配置 consumer.xml。
运行 Demo
以 Main 办法启动收发
运行 SimpleMQProducer 类发送。
登录 MQ 掌握台,在左侧菜单栏选择查询>Topic 查询,选择 Topic 名称进行查询。可以瞥见已经发送至 Topic。
运行 SimpleMQConsumer 类吸收。可以看到被吸收打印的日志。由于有初始化,以是需等待几秒,在生产环境中不会常常初始化。
在订阅管理>消费者状态中可以看到,启动的消费端已经在线,并且订阅关系同等。
以 Spring 办法启动收发
运行 MQProducer4Spring 类发送。
运行 MQConsumer4Spring 类吸收。
查当作果跟上面过程类似。
发送事务
运行 SimpleTransactionProducer 类发送。
解释:LocalTransactionCheckerImpl 类为本地事务 check 接口类。用于校验事务。详情请参考发送分布式事务。
发送定时(延时)
运行 MQTimerProducer 类发送。延时3秒后投递。
解释:MQ 也可以指定一个精确的投递韶光,最长定时韶光为40天。详细请参考发送定时。
HTTP、MQTT 物联接入
HTTP 接入请参考 MQ HTTP 接入。
MQTT 接入请参考 MQTT 接入。
原文点此查看:https://yq.aliyun.com/articles/61965