CentOS消息隊列配置步驟

在CentOS上配置消息隊列系統，您可以選擇多種消息隊列中間件，如RabbitMQ、Kafka、ActiveMQ等。以下是使用RabbitMQ作為示例的配置步驟：

安裝Erlang

RabbitMQ是用Erlang編寫的，因此首先需要安裝Erlang環境。

sudo yum install -y erlang

安裝RabbitMQ

您可以使用yum直接安裝RabbitMQ，或者從源碼編譯安裝。這里推薦使用yum安裝。

sudo yum install -y rabbitmq-server

啟動RabbitMQ服務

安裝完成后，啟動RabbitMQ服務并設置開機自啟動。

sudo systemctl start rabbitmq-server
sudo systemctl enable rabbitmq-server

配置RabbitMQ

RabbitMQ的配置文件通常位于 /etc/rabbitmq/ 目錄下。您可以使用 rabbitmqctl 命令進行配置。

• 啟用管理插件：

sudo rabbitmq-plugins enable rabbitmq_management

• 訪問管理界面：默認用戶名和密碼都是 guest。打開瀏覽器并訪問 http://<your_server_ip>:15672/。

驗證安裝

您可以通過命令行工具 rabbitmqctl 來驗證RabbitMQ是否正常運行。

sudo rabbitmqctl status

創建隊列和交換機

您可以使用 rabbitmqadmin 工具或者直接通過命令行來創建隊列和交換機。

• 使用命令行創建隊列：

sudo rabbitmqadmin declare queue name=my_queue durable=true

• 使用命令行創建交換機：

sudo rabbitmqadmin declare exchange name=my_exchange type=direct durable=true

• 綁定隊列到交換機：

sudo rabbitmqadmin declare binding source=my_exchange destination=my_queue routing_key=my_routing_key

生產者和消費者

您可以編寫簡單的生產者和消費者腳本來測試消息隊列的功能。

生產者腳本 (producer.py)：

import pika
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='my_queue')
channel.basic_publish(exchange='my_exchange',
                      routing_key='my_routing_key',
                      body='Hello World!')
print(" [x] Sent 'Hello World!'")
connection.close()

消費者腳本 (consumer.py)：

import pika
channel = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel.queue_declare(queue='my_queue')
def callback(ch, method, properties, body):
    print(f" [x] Received {body}")
channel.basic_consume(queue='my_queue',
                      on_message_callback=callback,
                      auto_ack=True)
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

運行生產者和消費者腳本來測試消息隊列的功能。

python producer.py
python consumer.py

通過以上步驟，您就可以在CentOS上成功搭建RabbitMQ消息隊列系統。如果您選擇其他消息隊列中間件，如Kafka或ActiveMQ，安裝和配置步驟會有所不同，但基本思路是相似的。