内容介绍：

一、如何使用云消息队列RabbitMQ版

二、RabbitMQ开源客户端生产和消费消息测试

 

本次分享的主题是快速学会使用云消息队列RabbitMQ版的实践。

 

一、如何使用云消息队列RabbitMQ版

1. 进入

（1）点击链接，勾选同意。

（2）开始实操，系统会自动创建实验所需要的云产品资源。

（3）资源创建完成后，通过菜单栏左侧的云产品资源，可以看到系统创建的消息队列-rabbitmq的资源。

2.创建阿里云AccessKey，AccessKey Secret

（1）回到操作手册，点击下一页。

（2）前往AK管理界面，点击继续使用AK，点击创建AK。

（3）可以看到新创建的AK和SK，选择下载CSX文件，或复制AK，SK的方式并行操作。

3.静态用户名和密码的创建

（1）点击下一页，通过云产品资源列表的消息队列区域，点击管理，进入rabbitmq的云产品控制台台，点击静态用户名密码，点击创建用户名密码。

（2）将新创建的AS，SK复制到云产品控制台。注意删除多余的空格，点击确定。

（3）看到创建成功，查看新创建的静态用户名和密码。

4.Vhost创建

（1）回到操作手册，进入Vhost列表。

（2）点击创建Vhost，设置新创建的Vhost的名字为yunQi-Vhost。（3）点击确定，Vhost创建成功。

5.EXchange的创建

（1）进入EXchange列表，看到已经有默认的EXchange。

（2）将新建EXchange的名字设为yunQi-EXchange。类型为direct。

（3）点击确定，EXchange创建成功。

6.队列的创建

（1）进入Queue列表，点击创建。新创建的队列名设为yunQi-Queue，其他选项保持默认。

（1）点击确定，新创建yunQi-Queue成功。

7.添加绑定关系

 

（1）回到EXchange列表，选择刚创建的yunQi-EXchange。

（2）单击添加绑定，绑定目标选择新添加的yunQi-Queue的路由。Routing Key设置为yunQi-routing-key。

（3）点击确定，绑定成功。

 

二、RabbitMQ开源客户端生产和消费消息测试

 

打开IntelliJ IDEA，需要通过Git从远程拉仓库拿取RabbitMQ开源客户端demo。首先需要安装Git，安装Git的操作在操作手册中有，安装完成之后，点击IntelliJ IDEA的Get flow VCS，从远程仓库拉取对应的demo代码,URL从操作手册上可以复制。然后点击Clone。

成功从远程仓库拉取到对应的RabbitMQ开源客户端的demo代码，选择amqp-java-demo。打开demo。这是pom工程，如果文件是红色标记，需要先右键点击Add as Maven Project，把工程标记为Maven工程。

然后重新打开工程，进入Config类，进行RabbitMQ开源客户端的参数配置的替换，有三个配置参数需要进行相应的替换，首先是阿里云RabbitMQ实例的公网接入点，需要找到云产品控制台的实例详情，看到对应实例的公网接入点。复制地址，然后在代码中进行替换，还需要进行静态用户名和密码的替换，使用前面操作得到的静态用户名和密码，在云产品控制台进行复制粘贴，然后在代码中替换。

Config类对应的参数替换完成之后，可以进行RabbitMQ客户端的消息发送和消息消费的测试，首先进行RabbitMQ消息发送的测试，进入ProducerTest这个类，看到消息发送测试使用的Vhost、 EXchange、Queue、Routing Key都与之前的操作一一对应。

可以直接启动ProducerTest的main方法运行。在控制台看到消息发送成功，使用RabbitMQ的channel.basic Publish方法进行消息发送测试，demo中会持续一个小时发送3600条消息。每发送一条，间隔一秒。完成消息发送测试之后进行消息消费测试。进入Consume Test类，运行类中的main方法。在控制台看到前面发送的消息已经消费成功。代码主要是使用RabbitMQ的channel.basic Consume 方法，创建消费者对指定的队列进行监听消费。

回到云产品控制台操作手册，使用控制台的Dashboard面板对RabbitMQ实例指标进行查看。首次进入Dashboard面板需要对服务关联角色进行授权，并且开通ARMS服务。进入Dashboard面板。RabbitMQ实例每一个Queue的指标，例如新建的yunQi-Queue队列对应的消息堆积数以及消息发送和消息消费的指标情况。

还可以直接点击队列，或者通过Queue列表进入指定队列，查看指定队列下Dashboard监控的消息收发的变化趋势，将时间选择最近五分钟，就可以看到最近五分钟指定的yunQi-Queue队列下消息收发的变化趋势。

回到操作手册进行消息轨迹查看。在左侧菜单栏点击消息轨迹，在消息轨迹界面可以通过Message ID或者是按Queue查询指定消息的消息轨迹。如果通过Message ID进行查询，进行消息收发测试时，在控制台打印指定消息的Message ID，复制其中一个Message ID，然后在消息轨迹界面中输入Message ID，点击查询，可以查到特定的Message ID对应的消息。

然后点击轨迹详情，可以查看消息的生产和投递轨迹。

同样可以根据Queue查询指定Queue下的所有消息的消息轨迹，例如使用yunQi-Queue查询最近一个小时的消息，查到yunQi-Queue队列下最近一个小时的所有消息。同样也可以通过轨迹详情查看指定消息的情况。

最后进行实验资源的回收。进入AK管理界面进行AKSK的回收，将先前创建的AKSK禁用，保险起见可以选择直接删除实验中所使用的AKSK。

回收AKSK之后进行实例的回收，可以选择付费保留实例，或者不保留实例资源直接结束实验。如果不选择付费保留资源，实验结束之后默认不保留资源，直接结束实验。