前言:这次整理写一篇关于rabbitMQ的博客,相比上一篇redis,感觉rabbitMQ难度是提高不少。这篇博客会插入一些英文讲解,不过不难理解的。rabbitMQ的下载与安装,请参考redis&rabbitMQ安装。
rabbitMQ是消息队列;想想之前的我们学过队列queue:threading queue(线程queue,多个线程之间进行数据交互)、进程Queue(父进程与子进程进行交互或者同属于同一父进程下的多个子进程进行交互);如果两个独立的程序,那么之间是不能通过queue进行交互的,这时候我们就需要一个中间代理即rabbitMQ.
一、简单的rabbitMQ队列通信
由上图可知,数据是先发给exchange交换器,exchage再发给相应队列。pika模块是python对rabbitMQ的API接口。接收端有一个回调函数,一接收到数据就调用该函数。一条消息被一个消费者接收后,该消息就从队列删除。OK,了解上面的知识后,先来看看一个简单的rabbitMQ列队通信。
send端:
网友评论