python16_day11MQRedisMemcache

Posted 2020-09-08

一、RabbitMQ

　　是一个在AMQP基础上完整的，可复用的企业消息系统。他遵循Mozilla Public License开源协议。

MQ全称为Message Queue, 消息队列（MQ）是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息（针对应用程序的数据）来通信，而无需专用连接来链接它们。消 息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通信，直接调用通常是用于诸如远程过程调用的技术。排队指的是应用程序通过 队列来通信。队列的使用除去了接收和发送应用程序同时执行的要求。

 

　　1.RabbitMQ install

1 安装配置epel源
2    $ rpm -ivh http://dl.fedoraproject.org/pub/epel/6/i386/epel-release-6-8.noarch.rpm
3  
4 安装erlang
5    $ yum -y install erlang
6  
7 安装RabbitMQ
8    $ yum -y install rabbitmq-server
　　

注意：service rabbitmq-server start/stop

　　2. Python API install　　

1 pip install pika
2 or
3 easy_install pika
4 or
5 源码
6 https://pypi.python.org/pypi/pika

　　3.基于QUEUE实现生产消费模型

 1 import Queue
 2 import threading
 3 
 4 
 5 message = Queue.Queue(10)
 6 
 7 
 8 def producer(i):
 9     while True:
10         message.put(i)
11 
12 
13 def consumer(i):
14     while True:
15         msg = message.get()
16 
17 
18 for i in range(12):
19     t = threading.Thread(target=producer, args=(i,))
20     t.start()
21 
22 for i in range(10):
23     t = threading.Thread(target=consumer, args=(i,))
24     t.start()

　　4.基于RabbitMQ

　　对于RabbitMQ来说，生产和消费不再针对内存里的一个Queue对象，而是某台服务器上的RabbitMQ Server实现的消息队列。

 1 import pika
 2  
 3 # ######################### 生产者 #########################
 4  
 5 connection = pika.BlockingConnection(pika.ConnectionParameters(
 6         host=‘localhost‘))
 7 channel = connection.channel()
 8  
 9 channel.queue_declare(queue=‘hello‘)
10  
11 channel.basic_publish(exchange=‘‘,
12                       routing_key=‘hello‘,
13                       body=‘Hello World!‘)
14 print(" [x] Sent ‘Hello World!‘")
15 connection.close()
16 
17 
18  
19 # ########################## 消费者 ##########################
20 import pika
21 connection = pika.BlockingConnection(pika.ConnectionParameters(
22         host=‘localhost‘))
23 channel = connection.channel()
24  
25 channel.queue_declare(queue=‘hello‘)
26  
27 def callback(ch, method, properties, body):
28     print(" [x] Received %r" % body)
29  
30 channel.basic_consume(callback,
31                       queue=‘hello‘,
32                       no_ack=True)
33  
34 print(‘ [*] Waiting for messages. To exit press CTRL+C‘)
35 channel.start_consuming()