登录
首页 >  Golang >  Go教程

RabbitMQ在Debian系统安装教程

时间:2025-06-27 11:50:56 454浏览 收藏

学习Golang要努力,但是不要急!今天的这篇文章《RabbitMQ在Debian系统上的使用方法》将会介绍到等等知识点,如果你想深入学习Golang,可以关注我!我会持续更新相关文章的,希望对大家都能有所帮助!

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

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

RabbitMQ的安装

  1. 更新软件包索引
sudo apt-get update
  1. 安装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的管理插件可能是禁用的。可以执行以下命令来启用它:

  1. 激活管理插件
sudo rabbitmq-plugins enable rabbitmq_management
  1. 访问管理页面: 激活插件之后,能够通过浏览器访问 http://your_server_ip:15672,利用配置文档中的用户名和密码登录

示例:使用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系统安装教程》的介绍应该让你收获多多了吧!欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识,快来关注吧!

相关阅读
更多>
最新阅读
更多>
课程推荐
更多>