python操作RabbitMQ

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了python操作RabbitMQ相关的知识,希望对你有一定的参考价值。

RabbitMQ介绍

RabbitMQ是一个由erlang开发的AMQP(Advanced Message Queue)的开源实现的产品,RabbitMQ是一个消息代理,从“生产者”接收消息并传递消息至“消费者”,期间可根据规则路由、缓存、持久化消息。“生产者”也即message发送者以下简称P,相对应的“消费者”乃message接受者以下简称C,message通过queue由P到C,queue存在于RabbitMQ,可存储尽可能多的message,多个P可向同一queue发送message,多个C可从同一个queue接收message

  • 内部架构:

     技术分享

  • 说明

    • Message (消息):RabbitMQ 转发的二进制对象,包括Headers(头)、Properties (属性)和 Data (数据),其中数据部分不是必要的。Producer(生产者): 消息的生产者,负责产生消息并把消息发到交换机
    • Exhange的应用。

      • Consumer (消费者):使用队列 Queue 从 Exchange 中获取消息的应用。
      • Exchange (交换机):负责接收生产者的消息并把它转到到合适的队列
      • Queue (队列):一个存储Exchange 发来的消息的缓冲,并将消息主动发送给Consumer,或者 Consumer 主动来获取消息。见 1.4 部分的描述。

      • Binding (绑定):队列 和 交换机 之间的关系。Exchange 根据消息的属性和 Binding 的属性来转发消息。绑定的一个重要属性是 binding_key。

      • Connection (连接)和 Channel (通道):生产者和消费者需要和 RabbitMQ 建立 TCP 连接。一些应用需要多个connection,为了节省TCP 连接,可以使用 Channel,它可以被认为是一种轻型的共享 TCP 连接的连接。连接需要用户认证,并且支持 TLS (SSL)。连接需要显式关闭。

 参考:RabbitMQ百度百科

RabbitMQ安装

centos7安装:

http://www.rabbitmq.com/install-rpm.html
yum -y install rabbitmq-server
systemctl start rabbitmq-server

windows安装:

http://www.rabbitmq.com/install-windows.html

安装python rabbitMQ module:

pip3 install pika
or
easy_install pika
or
源码
 
https://pypi.python.org/pypi/pika

 



以上是关于python操作RabbitMQ的主要内容,如果未能解决你的问题,请参考以下文章

python 操作RabbitMQ

Python操作rabbitmq系列

python操作RabbitMQ

python操作RabbitMQ

学习笔记:python3,代码片段(2017)

Python操作rabbitMQ