知识准备
RabbitMQ
rabbitmq是一个在amqp基础上完整的,可复用的企业消息系统。
MQ
MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。 
消息队列使用发布订-阅模式工作。消息发送者是消息源,在对消息进行处理后将消息发送至分布式消息队列,消息接受者从分布式消息队列获取该消息后继续进行处理。可以看到,消息发送者和消息接受者之间没有直接耦合,消息发送者将消息发送至分布式消息队列即结束对消息的处理,而消息接受者只需要从分布式消息队列获取消息后进行处理,不需要知道该消息从何而来。
通过消息队列通信,让A,B两个服务指间保持低耦合,实现业务的灵活拓展。
pika
pika是RabbitMQ团队编写的官方Python AMQP库。
安装启动
$ brew install rabbitmq$ usr/local/sbin/rabbitmq-server
安装pika
pip install pika
操作实例
Hello World
sender
# coding: utf-8import pika
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
channel.basic_publish(exchange='',
routing_key='hello',
body='Hello, World!')print 'send msg: Hello World!'connection.close()receiver
# coding: utf-8import pika
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')def callback(ch, method, properties, body):
print 'receive msg: %s' % body
channel.basic_consume(callback,
queue='hello',
no_ack=False)print 'waiting for msg...'channel.start_consuming()运行结果:
方科网络ERP图文店II版为仿代码站独立研发的网络版ERP销售程序。本本版本为方科网络ERP图文店版的简化版,去除了部分不同用的功能,使得系统更加精炼实用。考虑到图文店的特殊情况,本系统并未制作出入库功能,而是将销售作为重头,使用本系统,可以有效解决大型图文店员工多,换班数量多,订单混杂不清的情况。下单、取件、结算分别记录操作人员,真正做到订单全程跟踪!无限用户级别,不同的用户级别可以设置不同的价
立即学习“Python免费学习笔记(深入)”;
# sender.py 运行2次send msg: Hello World!# receiverwaiting for msg... receive msg: Hello, World! receive msg: Hello, World!
消费者处理消息后,并没有退出,仍然可以处理后续的消息。










