针对Redis队列的理解，实例操作（转）

原文：本文出自 “峰云，就她了。” /article/4257263.html

为什么要使用消息队列

用我的话来说， 队列特点是先进先出，在任务调度时，有时候需要保证先进入的任务先执行，所以需要使用队列。

下面这段话来自VMWare的网站，个人觉得关于消息队列的作用的概括简明扼要，遂摘录至此：


【更新2012-6-28】

刚知道原来虎扑网也使用了消息队列（RabbitMQ），来看看他们的观点：


【更新2012-6-29】

博文“使用django+celery+RabbitMQ实现异步执行”中展示了一个消息队列的典型应用：



在ptyhon中，可以用下ztq，这个我没有用，对于我来说还是复杂点~

ZTQ：Z Task Queue

https://github.com/everydo/ztq

在php中的应用

入队操作

$redis = new Redis();

$redis->connect('127.0.0.1',6379);

while(True){

try{

$value = 'value_'.date('Y-m-d H:i:s');

$redis->LPUSH('key1',$value);

sleep(rand()%3);

echo $value."\n";

}catch(Exception $e){

echo $e->getMessage()."\n";

}

}

出队操作

$redis = new Redis();

$redis->pconnect('127.0.0.1',6379);

while(True){

try{

echo $redis->LPOP('key1')."\n";

}catch(Exception $e){

echo $e->getMessage()."\n";

}

sleep(rand()%3);

}

我的python应用

入队列

#!/usr/bin/env python

import time

from redis import Redis

redis = Redis(host='127.0.0.1', port=6379)

while True:

now = time.strftime("%Y/%m/%d %H:%M:%S")

redis.lpush('test_queue', now)

time.sleep(1)

#!/usr/bin/env python

import sys

from redis import Redis

redis = Redis(host='127.0.0.1', port=6379)

while True:

res = redis.rpop('test_queue')

if res == None:

pass

else:

print str(res)