原文作者: xingguang
原文鏈接：https://www.tiance.club/post/1297686480.html

生產者代碼示例

public function producer(){$data=[]; //組裝要推送隊列的業務邏輯數據$key='redisKey';$redis=Yii::$app->redis; $redis->lpush($key,json_encode($data)); $redis->expire($key, 60*60*24); }

消費者代碼示例

public function consumer(){$redis=Yii::$app->redis;//限制本次隊列只有一個進程在操作self::lockLimit(self::FUEL_LIST_RECORD_LOCK_KEY,2,60*30);//獲取當前隊列長度$length = $redis->llen(self::FUEL_LIST_RECORD_LOG_KEY);for($i=0;$i<$length;$i++){try{$record = $redis->rpop(self::FUEL_LIST_RECORD_LOG_KEY);if(!empty($record)){//處理業務邏輯$record_decode=json_decode($record,true);}}catch(\Throwable $e){//判斷重試次數，這里設置超過3次重試就不再重試if(!isset($record_decode['try_count']))$record_decode['try_count']=0;if(isset($record_decode['try_count']) && $record_decode['try_count']<3 ){++$record_decode['try_count'];$redis->lpush(self::FUEL_LIST_RECORD_LOG_KEY,json_encode($record_decode));$redis->expire(self::FUEL_LIST_RECORD_LOG_KEY, 60*60*24);}//打個日志記錄CoreHelper::write(json_encode(['handleRecordLogNew',$e->getMessage()], JSON_UNESCAPED_UNICODE));}}Yii::$app->redis->del(self::FUEL_LIST_RECORD_LOCK_KEY); //業務邏輯處理完畢，解鎖} 原文作者: xingguang 原文鏈接：[https://www.tiance.club/post/1297686480.html](https://www.tiance.club/post/1297686480.html)

消費者取數據處理有另一種省性能的方案即Lrange+Lrem，這個具體還沒實踐過，邏輯上能減少redis連接次數，從而提高程序執行效率，等有空實踐再補上。

原文作者: xingguang
原文鏈接：https://www.tiance.club/post/1297686480.html

總結

以上是生活随笔為你收集整理的yii2简单实现redis消息队列的全部內容，希望文章能夠幫你解決所遇到的問題。

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