三、連接RabbitMQ實例

• 在創建RabbitMQ實例后，您需要手動連接至RabbitMQ實例管理數據或將應用服務器連接至數據庫進行業務部署。

白名單設置

• 我們需要把我們云服務器的IP設置添加如白名單，這樣才能正常的進行應用服務器和RabbitMQ直接的正常通信以及使用在線管理界面查看。

1、在云數據庫管理面板中的RabbitMQ的白名單中進行添加

2、在白名單添加面板中填入名稱信息、相應的規則、對應關聯的實例。添加后記得啟用規則。

• 這里的規則指的是對需要連接IP信息進行添加，默認攔截所有IP。

初始化設置RabbitMQ登錄用戶

• RabbitMQ實例默認創建后需要手動重置用戶密碼信息。在實例列表中找到對應實例，在詳情頁面中進行實例密碼重置

建立Vhost

• 在Vhost管理面板中添加一個新的Vhost進行使用。

• 
  

測試實例

1、登錄我們的應用服務器（以Linux為例），測試網絡端口情況(如:telnet、tcping)。

2、安裝python3及相應擴展。

• 本次測試使用python進行操作示范。

yum install python3 -y

安裝好了后安裝擴展，命令如下：

pip3 install pika

3、編寫創建生產者python代碼，注意使用到RabbitMQ用戶名和密碼，連接IP地址和Vhost名稱。保存為producer.py

import pika
# -*- coding: utf-8 -*-
# 設置 RabbitMQ 服務器的用戶名和密碼
credentials = pika.PlainCredentials('用戶名', '密碼')

# 連接到 RabbitMQ 服務器
connection = pika.BlockingConnection(pika.ConnectionParameters('連接IP地址', virtual_host='Vhost名字', credentials=credentials))

channel = connection.channel()

# 聲明一個隊列
channel.queue_declare(queue='hello')

# 發送消息
channel.basic_publish(exchange='',
                      routing_key='hello',
                      body='Hello World!')

print(" [x] Sent 'Hello World!'")
connection.close()

4、編寫消費者者python代碼，注意使用到RabbitMQ用戶名和密碼，連接IP地址和Vhost名稱。保存為consumer.py

import pika
# -*- coding: utf-8 -*-
# 設置 RabbitMQ 服務器的用戶名和密碼
credentials = pika.PlainCredentials('用戶名', '密碼')

# 連接到 RabbitMQ 服務器
connection = pika.BlockingConnection(pika.ConnectionParameters('連接IP地址', virtual_host='Vhost名字', credentials=credentials))
channel = connection.channel()

# 聲明同樣的隊列
channel.queue_declare(queue='hello')

# 定義回調函數，處理接收到的消息
def callback(ch, method, properties, body):
    print(f" [x] Received {body}")

# 指定消費者，監聽隊列
channel.basic_consume(queue='hello',
                      on_message_callback=callback,
                      auto_ack=True)

print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

6、開始運行

• 我們可以打開2個終端，一個運行producer.py，一個運行consumer.py。

python3 producer.py
python3 consumer.py