简介

aio-pika 是一个 Python 异步 RabbitMQ 客户端。5.0.0 以前 aio-pika 基于 pika 进行封装，5.0.0 及以后使用 aiormq 进行封装。

• https://github.com/mosquito/aio-pika
• https://pypi.org/project/aio-pika/

pip install aio-pika

官方文档

https://docs.aio-pika.com/

• Quick Start：https://docs.aio-pika.com/quick-start.html

  • 基本生产者与消费者
    • https://docs.aio-pika.com/quick-start.html#simple-consumer
    • https://docs.aio-pika.com/quick-start.html#simple-publisher
  • connection pool 与 channel pool 使用：https://docs.aio-pika.com/quick-start.html#connection-pooling
  • https://docs.aio-pika.com/quick-start.html#external-credentials-example

• API 一览：https://docs.aio-pika.com/apidoc.html

  • https://docs.aio-pika.com/apidoc.html#aio_pika.DeliveryMode
  • https://docs.aio-pika.com/apidoc.html#aio_pika.ExchangeType
  • https://docs.aio-pika.com/apidoc.html#aio_pika.IncomingMessage
  • https://docs.aio-pika.com/apidoc.html#aio_pika.connect_robust

如何使用

1. 参考文档创建连接池，连接池作为单例对象由 web 框架创建
2. web 服务启动时，首先调用 MQ 架构初始化方法（该方法根据需要自定义）先确保队列、交换机等已经创建，随后再让接口提供服务
3. 接口中方法使用连接池单例对象获取连接，连接发送消息，注意使用上下文获取和回收连接
4. 消费者创建单个连接即可，无需使用连接池，然后通过连接进行消费