三、連接RabbitMQ實例

• 在創(chuàng)建RabbitMQ實例后，您需要手動連接至RabbitMQ實例管理數(shù)據(jù)或?qū)?yīng)用服務(wù)器連接至數(shù)據(jù)庫進行業(yè)務(wù)部署。

白名單設(shè)置

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

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

2、在白名單添加面板中填入名稱信息、相應(yīng)的規(guī)則、對應(yīng)關(guān)聯(lián)的實例。添加后記得啟用規(guī)則。

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

初始化設(shè)置RabbitMQ登錄用戶

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

建立Vhost

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

• 
  

測試實例

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

2、安裝python3及相應(yīng)擴展。

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

yum install python3 -y

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

pip3 install pika

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

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

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

channel = connection.channel()

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

# 發(fā)送消息
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 -*-
# 設(shè)置 RabbitMQ 服務(wù)器的用戶名和密碼
credentials = pika.PlainCredentials('用戶名', '密碼')

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

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

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

# 指定消費者，監(jiān)聽隊列
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