python生产者消费者

❶ python设计模式之工厂模式、策略模式、生产者-消费者模式

总结设计模式：工厂模式、策略模式、生产者-消费者模式，以Python为例进行说明。

策略模式主要应用于需要根据特定条件选择方法的情况，如根据不同的算法选择调用对应的方法以实现动态切换功能。具体实现时，首先定义一个抽象策略类，包含抽象方法，然后通过继承该类创建具体策略类，并通过上下文类调用具体策略方法。此模式有利于方法的维护和动态选择。

工厂模式在Python中有三种主要类型：简单工厂模式、工厂方法模式和抽象工厂模式。简单工厂模式通过静态方法创建不同类型的对象，适用于产品类型较少且不经常变化的场景。工厂方法模式通过抽象的工厂方法将对象创建延迟到具体创建者类中，适用于子类较多且需要频繁添加新产品的场景。抽象工厂模式在有多个分类时，通过抽象工厂产生需要的对象，适用于需要创建多个相关产品类型的场景。

生产者-消费者模式则通过队列实现资源共享，生产者生成数据放入队列，消费者从队列中取出数据进行处理。使用Python的Queue模块可以避免手动处理锁等线程同步机制，实现线程安全。

集成三种模式的示例代码：定义抽象产品类，包含抽象方法计算折扣后的价格。创建具体商品类并实现抽象方法。定义抽象工厂类创建具体产品对象，创建具体工厂类。定义抽象折扣策略类和具体折扣策略类。创建生产者类生成商品对象放入队列，消费者类从队列中获取对象并应用折扣策略。

❷ pika-Python RabbitMQ使用介绍

RabbitMQ是基于AMQP协议的消息系统，运行在Erlang OTP平台上。

RabbitMQ采用消息队列模型，消息存储于Queue中。生产者(P)生成消息后，最终将消息投递至Queue。消费者(C)从Queue中获取并消费消息。

在Windows 10环境下，先安装Erlang运行环境，需下载并添加环境变量。若已安装其他版本，需卸载后重新安装和设置。命令行输入erl确认运行成功。接着安装RabbitMQ，推荐使用最新版，并添加环境变量。

安装好RabbitMQ后，作为后台服务运行。安装rabbitmq_management插件，用于可视化服务器状态和操作。在浏览器输入 http://localhost:15672 登录，使用默认账号guest/guest。

使用pip安装Python pika包，实现消息生产者与消费者的交互。

生产者操作：通过RabbitMQ管理界面创建连接、通道、选择队列并发送消息。在Queue中接收Ready的消息后，关闭连接。

消费者操作：设置回调函数处理接收到的消息，指定消费者并指定队列及回调函数。自动确认消息，监听并运行回调函数，显示“Hello World!”。

总结：完成RabbitMQ在Windows下的安装与基础配置，包括安装Erlang和RabbitMQ、设置环境变量、安装rabbitmq_management插件，以及使用pika库实现生产者和消费者的通信。