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

步骤一：准备工作

1. 注册华为账号并实名认证。

   在创建RabbitMQ实例前，请先注册华为账号并实名认证，具体步骤请参考注册华为账号并开通华为云和实名认证介绍。

   如果您已有一个华为账号并实名认证，请跳过此步骤。

2. 为账户充值。

   在创建RabbitMQ实例前，确保账户有足够金额。账户充值的具体步骤，请参考账户充值。

3. 为用户添加RabbitMQ实例的操作权限。

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

4. 创建VPC和子网。

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

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

5. 创建安全组并添加安全组规则。

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

   创建的安全组与RabbitMQ实例必须在相同的区域。

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

   表1 安全组规则

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

   说明：

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

6. 构建生产消费客户端。
   本文以Linux系统的弹性云服务器（Elastic Cloud Server，简称ECS）作为生产消费客户端。在创建RabbitMQ实例前，请先创建开启弹性公网IP的ECS、安装JDK以及配置环境变量。

   1. 登录管理控制台，在左上角单击，选择“计算 > 弹性云服务器”，创建一个ECS实例。

      创建ECS的具体步骤，请参考购买弹性云服务器。如果您已有可用的ECS，可重复使用，不需要再次创建。

   2. 使用root用户登录ECS。
   3. 安装Java JDK，并配置JAVA_HOME与PATH环境变量。
      1. 下载Java JDK。
         说明：

         ECS默认自带的JDK可能不符合要求，例如OpenJDK，需要配置为Oracle的JDK，可至Oracle官方下载页面下载Java Development Kit 1.8.111及以上版本。

      2. 解压Java JDK。

         tar -zxvf jdk-8u321-linux-x64.tar.gz

         “jdk-8u321-linux-x64.tar.gz”为JDK的版本，请根据实际情况修改。

      3. 打开“.bash_profile”文件。

         vim ~/.bash_profile
      4. 添加如下内容。

         export JAVA_HOME=/opt/java/jdk1.8.0_321 
         export PATH=$JAVA_HOME/bin:$PATH

         “/opt/java/jdk1.8.0_321”为JDK的安装路径，请根据实际情况修改。

      5. 按“Esc”，然后输入以下命令，按“Enter”，保存并退出“.bash_profile”文件。

         :wq
      6. 执行如下命令使修改生效。

         source .bash_profile
      7. 查看Java JDK是否安装成功。

         java -version
         回显信息中包含如下信息，表示Java JDK安装成功。

         java version "1.8.0_321"

步骤二：创建RabbitMQ实例

1. 进入购买RabbitMQ实例页面。
2. 在“快速购买”页签，设置实例基础配置，如图2所示，配置详情请参考表2。

   表2 设置实例基础配置

   参数	说明
   计费模式	选择“按需计费”，即先使用再付费，按照RabbitMQ实例实际使用时长计费，秒级计费，按小时结算。
   区域	不同区域的云服务产品之间内网互不相通。请就近选择靠近您业务的区域，可减少网络时延，提高访问速度。 选择“华北-北京四”。
   可用区	可用区指在同一区域下，电力、网络隔离的物理区域，可用区之间内网互通，不同可用区之间物理隔离。 选择“可用区1”。

   图2 设置实例基础配置
   

3. 设置实例规格和存储空间，如图3所示，配置详情请参考表3。

   表3 设置实例规格和存储空间

   参数	说明
   套餐规格	选择“测试规格”，该规格提供最小规格的单机实例，为您节约资源和使用成本，但由于仅为单机部署，无法支持高可用能力，适用测试或者调试业务。
   单个代理存储空间	根据实际需要选择存储RabbitMQ数据的磁盘类型和磁盘大小。 实例总存储空间 = 单个代理的存储空间 * 代理数量，RabbitMQ实例创建后，磁盘类型不支持修改。 磁盘类型选择“超高I/O”，磁盘大小设置为“100GB”。

   图3 设置实例规格和存储空间
   

4. 设置实例网络环境信息，如图4所示，配置详情请参考表4。

   表4 设置实例网络环境信息

   参数	说明
   虚拟私有云	虚拟私有云在RabbitMQ实例创建完成后，不支持修改。 选择准备工作中设置好的虚拟私有云。
   子网	子网在RabbitMQ实例创建完成后，不支持修改。 选择准备工作中设置好的子网。
   安全组	选择准备工作中设置好的安全组。

   图4 设置实例网络环境信息
   

5. 设置实例的访问方式，保持默认即可。
6. 设置实例的认证方式，如图5所示，配置详情请参考表5。

   表5 设置实例的认证方式

   参数	说明
   RabbitMQ认证方式用户名	设置连接RabbitMQ实例的用户名。 用户名需要符合以下命名规则：由英文字母开头，且只能由英文字母、数字、中划线、下划线组成，长度为4~64个字符。 输入“test”。
   密码	设置连接RabbitMQ实例的密码。 密码需要符合以下命名规则： 长度为8~32个字符。 至少包含以下字符中的3种：大写字母、小写字母、数字、特殊字符`~!@#$%^&*()-_=+\|[{}];:'",<.>? 和空格，并且不能以-开头。 不能与用户名或倒序的用户名相同。

   图5 设置实例的认证方式
   

7. 设置实例高级配置，如图6所示，配置详情请参考表6，其他参数保持默认设置。

   表6 设置实例高级配置

   参数	说明
   实例名称	实例名称支持自定义，但需要符合命名规则：长度为4~64个字符，由英文字母开头，只能由英文字母、数字、中划线、下划线组成。 输入“rabbitmq-test”。
   企业项目	该参数针对企业用户使用。企业项目是对企业不同项目间资源的分组和管理，属于逻辑隔离。 选择“default”。

   图6 设置实例高级配置
   

8. 单击“确认订单”，进入规格确认页面。
9. 确认实例信息无误且阅读并同意《华为云用户协议》后，提交请求。
10. 在实例列表页面查看实例是否创建成功。
    创建实例大约需要3到15分钟，此时实例的“状态”为“创建中”。

    • 当实例的“状态”变为“运行中”时，说明实例创建成功。
    • 当实例的“状态”变为“创建失败”，请删除创建失败的RabbitMQ实例，然后重新购买。如果重新购买仍然失败，请联系客服。

11. 实例创建成功后，单击实例名称，进入实例详情页。
12. 在“连接信息”区域，查看并记录连接地址。
    图7 连接地址
    

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

1. 进入ECS的“root”目录下，下载RabbitMQ-Tutorial.zip示例工程代码。

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

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

2. 解压RabbitMQ-Tutorial.zip压缩包。

   unzip RabbitMQ-Tutorial.zip

3. 进入RabbitMQ-Tutorial目录，该目录下包含预编译好的jar文件。

   cd RabbitMQ-Tutorial

4. 运行生产消息示例。

   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!'

5. 运行消费消息示例。

   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命令退出。

相关信息

• 了解RabbitMQ实例的相关概念，请参考RabbitMQ基本概念。
• 了解RabbitMQ实例的价格，请参考分布式消息服务RabbitMQ版价格详情。
• 登录RabbitMQ Web UI，请参考连接RabbitMQ管理地址。
• 查看RabbitMQ实例的监控指标，请参考查看RabbitMQ监控数据。