快速连接RabbitMQ并生产消费消息

如果您需要对云上的资源进行精细管理，请使用统一身份认证服务（Identity and Access Management，简称IAM）创建IAM用户及用户组，并授权，以使得IAM用户获得RabbitMQ实例的操作权限。具体操作请参考创建用户并授权使用DMS for RabbitMQ。

在创建RabbitMQ实例前，确保已存在可用的VPC和子网。创建VPC和子网的具体步骤，请参考创建虚拟私有云和子网。

创建的VPC与RabbitMQ实例必须在相同的区域。

在创建RabbitMQ实例前，确保已存在可用的安全组。创建安全组的具体步骤，请参考创建安全组。

连接RabbitMQ实例前，请添加表1所示安全组规则，其他规则请根据实际需要添加。

表1 安全组规则

方向	协议	端口	源地址	说明
入方向	TCP	5672	0.0.0.0/0	访问RabbitMQ实例（关闭SSL加密）。

安全组创建后，系统默认添加入方向“允许安全组内的弹性云服务器彼此通信”规则和出方向“放通全部流量”规则。此时使用内网通过同一个VPC访问RabbitMQ实例，无需添加表1的规则。

wget https://dms-demo.obs.cn-north-1.myhuaweicloud.com/RabbitMQ-Tutorial.zip

“/root”为示例工程代码存放路径，请根据实际情况修改。

unzip RabbitMQ-Tutorial.zip

cd RabbitMQ-Tutorial

java -cp .:rabbitmq-tutorial.jar Send ${host} ${port} ${user} ${password}

参数说明如下：

• host：从创建实例中获取的连接地址。
• port：RabbitMQ实例的连接端口，输入5672。
• user：创建实例时，设置的用户名。
• password：创建实例时，设置的密码。

生产消息示例如下：

[root@ecs-test RabbitMQ-Tutorial]# java -cp .:rabbitmq-tutorial.jar Send 192.168.xx.40 5672 test Zxxxxxxs
 [x] Sent 'Hello World!'
[root@ecs-test RabbitMQ-Tutorial]# java -cp .:rabbitmq-tutorial.jar Send 192.168.xx.40 5672 test Zxxxxxxs
 [x] Sent 'Hello World!'

java -cp .:rabbitmq-tutorial.jar Recv ${host} ${port} ${user} ${password}

参数说明如下：

• host：从创建实例中获取的连接地址。
• port：RabbitMQ实例的连接端口，输入5672。
• user：创建实例时，设置的用户名。
• password：创建实例时，设置的密码。

消费消息示例如下：

[root@ecs-test RabbitMQ-Tutorial]# java -cp .:rabbitmq-tutorial.jar Recv 192.168.xx.40 5672 test Zxxxxxxs
 [*] Waiting for messages. To exit press CTRL+C
 [x] Received 'Hello World!'
 [x] Received 'Hello World!'

如需停止消费使用Ctrl+C命令退出。