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，安装和配置步骤会有所不同，但基本思路是相似的。

0 赞

0 踩