背景:現在的數據已經寫到了redis隊列里面，完成了入棧的操作，后期打算從redis獲取數據，完成出棧的操作，出棧后然后做一系列的邏輯處理

????? 環境: VMware虛擬機? 內存:1G?? 硬盤:60G? php環境:PHP Version 5.6.31? php框架:TP

????? 測試:事先在redis里面插入了70W條數據，分別模擬php單進程和多進程(3個多進程)

????? php單進程代碼:

public function slist() {
??????? $this->repay->start();
??????? $list_len? = $this->redis->llen('hongniu');
??????? Log::write('單進程一共有:'.$list_len."條");

??????? if ($list_len == 0) return;
??????? while (true) {
??????????? //$result???? = $this->redis->rpop('hongniu');
??????????? $result???? = $this->redis->lpop('hongniu');
??????????? if(empty($result)) {break;}
??????????? $repayment_data= unserialize($result);
??????????? if(is_array($repayment_data) && !empty($repayment_data)) {
???????????? //Log::write('多進程寫日志的結果是1:'.json_encode($repayment_data));
???????????? Log::write('單進程寫日志的結果是:'.json_encode($repayment_data));
??????????? }
??????? }
??????? $this->repay->stop();
??????? $spent_time = $this->repay->spent($echo=true, '單進程導出redis數據腳本');
??????? $this->repay->clear();
??? }

??? php多進程代碼:

public function blist1() {
??????? $this->repay->start();
??????? $list_len? = $this->redis->llen('hongniu');
??????? Log::write('多進程一一共有:'.$list_len."條");
??? ?
??????? if ($list_len == 0) return;
?????? ?
??????? while (true) {
??????????? //$result???? = $this->redis->rpop('hongniu');
??????????? $result???? = $this->redis->lpop('hongniu');
??????????? if(empty($result)) {break;}
??????????? $repayment_data= unserialize($result);
??????????? if(is_array($repayment_data) && !empty($repayment_data)) {
???????????? //Log::write('多進程寫日志的結果是1:'.json_encode($repayment_data));
????????????? Log::write('多進程寫日志的結果是1:'.json_encode($repayment_data), Log::INFO, Log::FILE, LOG_PATH.'blist1_'.date('Ymd').'.log');
??????????? }
??????? }
??????? $this->repay->stop();
??????? $spent_time = $this->repay->spent($echo=true, '多進程導出redis數據腳本1');
??????? $this->repay->clear();
??? } ?
??? public function blist2() {

??????? $this->repay->start();
??????? $list_len? = $this->redis->llen('hongniu');
??????? Log::write('多進程二一共有:'.$list_len."條");
??????? if ($list_len == 0) return;
?????? ?
??????? while (true) {
??????????? //$result???? = $this->redis->rpop('hongniu');
??????????? $result???? = $this->redis->lpop('hongniu');
??????????? if(empty($result)) {break;}
??????????? $repayment_data= unserialize($result);
??????????? if(is_array($repayment_data) && !empty($repayment_data)) {
???????????? //Log::write('多進程寫日志的結果是1:'.json_encode($repayment_data));
????????????? Log::write('多進程寫日志的結果是2:'.json_encode($repayment_data), Log::INFO, Log::FILE, LOG_PATH.'blist2_'.date('Ymd').'.log');
??????????? }
??????? }
??????? $this->repay->stop();
??????? $spent_time = $this->repay->spent($echo=true, '多進程導出redis數據腳本2');
??????? $this->repay->clear();
??? } ?
??? public function blist3() {
??????? $this->repay->start();
??????? $list_len? = $this->redis->llen('hongniu');
??????? Log::write('多進程三一共有:'.$list_len."條");
??????? if ($list_len == 0) return;
?????? ?
??????? while (true) {
??????????? //$result???? = $this->redis->rpop('hongniu');
??????????? $result???? = $this->redis->lpop('hongniu');
??????????? if(empty($result)) {break;}
??????????? $repayment_data= unserialize($result);
??????????? if(is_array($repayment_data) && !empty($repayment_data)) {
???????????? //Log::write('多進程寫日志的結果是1:'.json_encode($repayment_data));
????????????? Log::write('多進程寫日志的結果是3:'.json_encode($repayment_data), Log::INFO, Log::FILE, LOG_PATH.'blist3_'.date('Ymd').'.log');
??????????? }
??????? }
??????? $this->repay->stop();
??????? $spent_time = $this->repay->spent($echo=true, '多進程導出redis數據腳本3');
??????? $this->repay->clear();
??? }?

shell文件(batch.sh)代碼:

#!/bin/sh
for((i=3;i>=1;i--))
do
{
?curl http://192.168.32.128/index.php/Business/blist$i
}&
done

測試結果如下所示:

單進程結果執行結果以及耗時如下所示:

多進程執行結果以及耗時如下所示:

總結：因為redis是單進程單線程的，在只有一個redis實例的情況下，不管開啟多少個進程，讀取速度不會變快!

總結

以上是生活随笔為你收集整理的shell模拟php多进程从redis获取数据的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。