RabbitMQ消息队列在Debian上如何使用-Golang-PHP中文网

RabbitMQ消息队列在Debian上如何使用

星降

发布： 2025-06-07 12:32:27

原创

195人浏览过

rabbitmq消息队列在debian上如何使用

在Debian系统中应用RabbitMQ消息队列的操作流程如下：

RabbitMQ的安装

更新软件包索引：

sudo apt-get update

登录后复制

安装RabbitMQ服务端：

sudo apt-get install rabbitmq-server

登录后复制

安装完成后，RabbitMQ服务将自动运行。

服务的启动与停止

启动服务：

sudo service rabbitmq-server start

登录后复制

停止服务：

sudo service rabbitmq-server stop

登录后复制

检查服务状态：

sudo service rabbitmq-server status

登录后复制

RabbitMQ的配置

可以修改 /etc/default/rabbitmq-server 文件以调整系统限制，比如文件描述符的数量。

管理插件的激活（可选）

默认状态下，RabbitMQ的管理插件可能是禁用的。可以执行以下命令来启用它：

激活管理插件：

sudo rabbitmq-plugins enable rabbitmq_management

登录后复制

访问管理页面：激活插件之后，能够通过浏览器访问 https://www.php.cn/link/1b9ff04ef832682d4712ece27487f84e。

示例：使用RabbitMQ发送及接收信息

以下为一个简易案例，演示如何运用RabbitMQ发送和接收信息：

发送信息

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
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()

登录后复制

接收信息

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

channel.queue_declare(queue='hello')

def callback(ch, method, properties, body):
    print(" [x] Received %r" % 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()

登录后复制

上述步骤包括了在Debian系统里部署、设定、开启RabbitMQ服务以及借助Python进行基础的信息传递与接收。依据具体需求，还能深入配置RabbitMQ的高级功能，例如持久化、交换器和绑定等。

以上就是RabbitMQ消息队列在Debian上如何使用的详细内容，更多请关注php中文网其它相关文章！