python操作RabbitMQ

Posted 2020-10-02

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