首页 » PHP教程 » php阿里云mq技巧_十分钟玩转Aliware MQ阿里云消息队列Demo实践

php阿里云mq技巧_十分钟玩转Aliware MQ阿里云消息队列Demo实践

访客 2024-12-16 0

扫一扫用手机浏览

文章目录 [+]

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

安装 IDE

php阿里云mq技巧_十分钟玩转Aliware MQ阿里云消息队列Demo实践

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

php阿里云mq技巧_十分钟玩转Aliware MQ阿里云消息队列Demo实践
(图片来自网络侵删)

在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

标签:

相关文章

淘宝反爬虫php技巧_PHP爬虫编写

PHP(外文名:PHP: Hypertext Preprocessor,中文名:“超文本预处理器”)是一种通用开源脚本措辞。语法接...

PHP教程 2024-12-18 阅读0 评论0