yii 2 redisメッセージキューの簡単な実装

原文作者: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