Skip to content
消息中间件演示
Branch: master
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
.vscode
.DS_Store
.gitignore
LICENSE
README.md
consumer.py
docker-compose.yml
dockerfile
producer.py
requirements.txt

README.md

消息中间件演示(Rabbitmq)

本例子演示使用redis实现分发随机数求平方和的功能

  • 生产消费模式: 生产者向sourceQ队列发送数据,消费者从sourceQ队列取数据,消费者计算完成平方后将结果放入队列resultQ,生产者接收resultQ队列中的结果更新累加结果并打印在标准输出中.
  • 广播模式: 生产者在收到KeyboardInterrupt错误时向频道exitCh发出消息,消费者订阅频道exitCh,当收到消息时退出.

这个实现使用aio-pika配合asyncio实现.

使用

  1. docker-compose up -d启动redis
  2. pip install -r requirements.txt安装依赖,建议使用虚拟环境
  3. 执行producer.pyconsumer.py
You can’t perform that action at this time.