MemcacheQ安装与使用（二）

使用memcacheq做异步队列，做个简单的生产者-消费者模型。生产者将数据写入mq中，消费者异步去队列中去取数据，进而进一步的消费处理数据。

Python
01
#!/usr/bin/env python
02
#-*- coding:utf8 -*-
03
 
04
import sys
05
import time
06
import random
07
 
08
import memcache
09
 
10
mc = memcache.Client(["%s:%s"%("127.0.0.1", "22202")])
11
queue_name = "q1"
12
def putter():
13
    count = 0
14
    while True:
15
        data = "hello%d"%(count)
16
        mc.set(queue_name, data)
17
        print "put ", data
18
        count += 1
19
        time.sleep(random.randint(1, 10))
20
 
21
def process_data(data):
22
    print "processing data :", data
23
 
24
def getter():
25
    while True:
26
        data = mc.get(queue_name)
27
        if data:
28
            process_data(data)
29
        else:
30
            print "no message, sleep for a while ..."
31
            time.sleep(30)
32
 
33
if __name__ == "__main__":
34
    if len(sys.argv) != 2:
35
        print "Wrong arg numbers"
36
    else:
37
        cmd = sys.argv[1]
38
        if cmd == "put": putter()
39
        elif cmd == "get": getter()
40
        else: print "wrong cmd"

在使用时，开两个终端模拟两个进程，在一个终端中运行

1	python mqdemo.py put

来模拟生产者；另一个终端中运行

1	python mqdemo.py get

模拟消费者。