分布式消息服务RABBITMQ版-快速连接RabbitMQ并生产消费消息:步骤三：连接实例生产消费消息

时间：2024-11-22 14:49:24

步骤三：连接实例生产消费消息

进入E CS 的“root”目录下，下载RabbitMQ-Tutorial.zip示例工程代码。
```
wget https://dms-demo.obs.cn-north-1.myhuaweicloud.com/RabbitMQ-Tutorial.zip
```
“/root”为示例工程代码存放路径，请根据实际情况修改。
解压RabbitMQ-Tutorial.zip压缩包。
```
unzip RabbitMQ-Tutorial.zip
```
进入RabbitMQ-Tutorial目录，该目录下包含预编译好的jar文件。
```
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命令退出。