1.把信息用LPUSH操作加到redis中某個list的頭部2.寫個cron定時執行php讀取這個list。使用redis的RPOP操作從list尾部取走信息此外,redis有個BRPOP的操作,當list里沒有未處理信息時,會把腳本阻塞住,有新的信息時才會繼續執行。請問php怎么利用這個特性,要注意什么,另外這種長時間的連接對性能有沒有什么影響?ps.這樣的隊列系統設計合理嗎?
2 回答

侃侃無極
TA貢獻2051條經驗 獲得超10個贊
首先你在shell下執行php,完全沒有最長實行時間這一說,你完全可以把一個php腳本作為進程不停的監聽。
但是,你用LIST做隊列系統完全沒必要,一個是BRPOP的block是有最長時間限制的,你不能一直hold在那里。而更好的選擇是利用redis的PUB/SUB機制來做
下面是一個簡單監聽進程,它監聽了channel-1,你在shell下執行它不要關掉
<?php$redis->subscribe(array('channel-1'), function ($redis, $chan, $msg) { // do something echo $msg; });
然后在其它的程序里向channel-1發送你需要發送的消息
<?php$redis->publish('channel-1', 'hello, world!');
如果你需要用LIST來操作,完全可以不要用BRPOP,直接在循環中RPOP就行
<?phpwhile (true) { $msg = $redis->rPop('list-1'); if (false !== $msg) { // 這里處理消息 } // 這里可以sleep sleep(60); }

慕婉清6462132
TA貢獻1804條經驗 獲得超2個贊
BRPOPLPUSH source destination timeout
BRPOPLPUSH 是 RPOPLPUSH 的阻塞版本,當給定列表 source 不為空時, BRPOPLPUSH 的表現和 RPOPLPUSH 一樣。
當列表 source 為空時, BRPOPLPUSH 命令將阻塞連接,直到等待超時,或有另一個客戶端對 source 執行 LPUSH 或 RPUSH 命令為止。
超時參數 timeout 接受一個以秒為單位的數字作為值。超時參數設為 0 表示阻塞時間可以無限期延長(block indefinitely) 。
完全能夠用LIST構建一個隊列,用BRPOPLPUSH不會有超時問題
- 2 回答
- 0 關注
- 133 瀏覽
添加回答
舉報
0/150
提交
取消