phpredis隊列類,php redis 隊列處理

本文目錄一覽：

• 1、php redis 隊列～呢？
• 2、請教PHP+Redis實現任務隊列的思路
• 3、php 用 redis做隊列 運行過程是什麼樣的

php redis 隊列～呢？

用php調用redis裡面的 lists 相關的命令就好，實現隊列就用 lpush和rpop，分別代表隊首出列，和隊尾入列。

請教PHP+Redis實現任務隊列的思路

// 創建請求ID標誌, uniqid 無法保證唯一, 自己去搜索生成唯一的方法

$uuid = uniqid();

$tsk_name = “mytask”;

$time_out = 30000; // 超時策略: 30秒

$time_start = time();

$redis-rPush($tsk_name, $uuid); // 右(後)插入隊列

// 堵塞等待隊列中第一個和$uuid匹配的(到我了)

while($uuid != $redis-lGet($tsk_name, 0)){

if((time()-$time_start) $time_out) {

break; // 超時跳出(某些原因隊列異常了, 可能永遠取不到)

}

usleep(10); // sleep 10ms, 再次嘗試

}

// 這裡執行任務的處理代碼….

// $response 已拼裝好要返回的內容

// 處理完成後(資料庫等已入庫更新), 需要:

if($redis-lGet($tsk_name, 0) == $uuid){ // 再次確認第一個是本請求

$redis-lPop($tsk_name); // 完成任務了, 從隊列中移除

}else{

// 出現這種情況, 是因為超時了, 或前面的$uuid沒有被消費

// 若不清除, 後續的請求, 都將無法正常進入隊列執行

// 取隊列中的所有$uuid

$queues = $redis-lRange($tsk_name, 0, -1);

foreach($queues as $i=$uid){

if($uid==$uuid){

php 用 redis做隊列 運行過程是什麼樣的

Reids是一個比較高級的開源key-value存儲系統，採用ANSI C實現。其與memcached類似，但是支持持久化數據存儲入隊操作

複製代碼 代碼如下:

?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”;

}

}

?

出隊操作

複製代碼 代碼如下:

?php

$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);

}?

如何使用Redis 做隊列操作

Reids是一個比較高級的開源key-value存儲系統，採用ANSI C實現。其與memcached類似，但是支持持久化數據存儲，同時value支持多種類型：字元串 （同memcached中的value），列表 ，集合 (Set)，有序集合 (OrderSet)和Hash 。所有的值類型均支持原子操作，如列表中追加彈出元素，集合中插入移除元素等。Rdids的數據大部分位於內存中，其讀寫效率非常高，其提供AOF（追加 式操作記錄文件）和DUMP（定期數據備份）兩種持久化方式。Redis支持自定義的VM（虛擬內存）機制，當數據容量超過內存時，可以將部分Value 存儲到文件中。同時Redis支持Master-Slave機制，可以進行數據複製。

可以把Redis的list結構當隊列來用.

從上面Redis的場景和作用來說，對於我們現在的開發活動，究竟能把Redis引入在那些場景，而不是把這麼好的東東演變成「為了使用Redis，而Redis」的慘烈局面呢？當然，具體問題具體分析，這個真的很重要哈。

緩存？分散式緩存？

隊列？分散式隊列？

某些系統應用（例如，電信、銀行和大型互聯網應用等）都會使用到，當然，現在大行其道的memcache就是很好的證明；但從某一方面來說，memcache是否能把兩張囊括其中，而且能做到更好（沒有實際的應用過，所以只是拋出）。但從Redis身上，我就能感覺到，Redis，就能把隊列和緩存兩張都囊括其中，而且都不會產生並發環境下的困擾，因為Redis中的操作都是原子操作來著。

至於評論兩者的孰好孰壞就免了，存在就是理由，選擇適合的就是最好的。

下面開始玩玩Redis中的隊列（分散式）設計YY吧，請大蝦們多多指點。

狀況場景：

現在的項目，都是部署在多個伺服器，或者多個IP上，而且前台經由F5分發，所以用戶的請求究竟落在那一台的伺服器上，是無法確定的。對於項目中，有一秒殺設計，剛開始沒有考慮到這種部署，同時也是使用最容易處理的方式，直接給資料庫表鎖行記錄（Oracle上的）。可以說，對於不同的應用部署，而只有一台資料庫伺服器來說，很「輕鬆」的就解決了這個並發的問題。所以現在考慮一下，是不是挪到應用上，避免資料庫伺服器也摻雜到業務上。

比如，現在有2台應用伺服器，1台資料庫伺服器。想法是，把Redis部署在資料庫伺服器上，兩台伺服器在操作並發緩存或者隊列時，先從Redis伺服器上，取得在兩台應用伺服器的代理對象，再做入列出列的操作。

看代碼實現（PHP）

入隊列操作文件 list_push.php

複製代碼 代碼如下:

?php

$redis = getRedisInstance();//從Redis伺服器拿到redis實例$redis-connect(‘Redis伺服器IP’, 6379);

while (true) {

$redis-lPush(‘list1’, ‘A_’.date(‘Y-m-d H:i:s’));sleep(rand()%3);

}

?

執行# php list_push.php

出隊列操作 list_pop.php文件

複製代碼 代碼如下:

?php

$redis = getRedisInstance();//從Redis伺服器拿到redis實例$redis-pconnect(‘Redis伺服器IP’, 6379);

while(true) {

try {

var_export( $redis-blPop(‘list1’, 10) );} catch(Exception $e) {

//echo $e;

}

}

實現方法(Python)

1.入隊列（write.py）

複製代碼 代碼如下:

#!/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)

2.出隊列（read.py）

複製代碼 代碼如下:

#!/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)