什么是消息队列
我们可以把消息队列比作是一个存放消息的容器,当我们需要使用消息的时候可以取出消息供自己使用。消息队列是分布式系统中重要的组件,使用消息队列主要是为了通过异步处理提高系统性能和削峰、降低系统耦合性。
通信原理
在内存中建立队列模型,进程通过队列存取消息实现通信
实现方法
from multiprocessing import Queue
q = Queue(maxsize = 0)
功能 : 创建消息队列
参数 : 最多存放多少个消息
q.put(data,[block,timeout])
功能: 向队列存入消息
参数:
data 要存入的内容
block False为非阻塞
timeout 超时时间
data = q.get([block,timeout])
功能: 从队列中取出消息
参数:block False 为非阻塞
timeout 超时时间
q.full() 判断队列是否为满
q.empty() 判断队列是否为空
q.qsize() 获取队列中消息个数
q.close() 关闭队列