背景:現(xiàn)在的數(shù)據(jù)已經(jīng)寫到了redis隊(duì)列里面，完成了入棧的操作，后期打算從redis獲取數(shù)據(jù)，完成出棧的操作，出棧后然后做一系列的邏輯處理

????? 環(huán)境: VMware虛擬機(jī)? 內(nèi)存:1G?? 硬盤:60G? php環(huán)境:PHP Version 5.6.31? php框架:TP

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

????? php單進(jìn)程代碼:

public function slist() {
??????? $this->repay->start();
??????? $list_len? = $this->redis->llen('hongniu');
??????? Log::write('單進(jìn)程一共有:'.$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('多進(jìn)程寫日志的結(jié)果是1:'.json_encode($repayment_data));
???????????? Log::write('單進(jìn)程寫日志的結(jié)果是:'.json_encode($repayment_data));
??????????? }
??????? }
??????? $this->repay->stop();
??????? $spent_time = $this->repay->spent($echo=true, '單進(jìn)程導(dǎo)出redis數(shù)據(jù)腳本');
??????? $this->repay->clear();
??? }

??? php多進(jìn)程代碼:

public function blist1() {
??????? $this->repay->start();
??????? $list_len? = $this->redis->llen('hongniu');
??????? Log::write('多進(jìn)程一一共有:'.$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('多進(jìn)程寫日志的結(jié)果是1:'.json_encode($repayment_data));
????????????? Log::write('多進(jìn)程寫日志的結(jié)果是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, '多進(jìn)程導(dǎo)出redis數(shù)據(jù)腳本1');
??????? $this->repay->clear();
??? } ?
??? public function blist2() {

??????? $this->repay->start();
??????? $list_len? = $this->redis->llen('hongniu');
??????? Log::write('多進(jìn)程二一共有:'.$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('多進(jìn)程寫日志的結(jié)果是1:'.json_encode($repayment_data));
????????????? Log::write('多進(jìn)程寫日志的結(jié)果是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, '多進(jìn)程導(dǎo)出redis數(shù)據(jù)腳本2');
??????? $this->repay->clear();
??? } ?
??? public function blist3() {
??????? $this->repay->start();
??????? $list_len? = $this->redis->llen('hongniu');
??????? Log::write('多進(jìn)程三一共有:'.$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('多進(jìn)程寫日志的結(jié)果是1:'.json_encode($repayment_data));
????????????? Log::write('多進(jìn)程寫日志的結(jié)果是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, '多進(jìn)程導(dǎo)出redis數(shù)據(jù)腳本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

測試結(jié)果如下所示:

單進(jìn)程結(jié)果執(zhí)行結(jié)果以及耗時(shí)如下所示:

多進(jìn)程執(zhí)行結(jié)果以及耗時(shí)如下所示:

總結(jié)：因?yàn)閞edis是單進(jìn)程單線程的，在只有一個(gè)redis實(shí)例的情況下，不管開啟多少個(gè)進(jìn)程，讀取速度不會(huì)變快!

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。