PHP+Redis 實例【一】點贊 + 熱度 下篇

這篇主要講如何將數據保存回Mysql，但是里面還會涉及到如何將錯誤信息以及提示信息保存到文件里，方便以后的運維，再有就是如何使用PHP寫進程BAT。

Redis數據刷回數據庫前的知識准備

　　首先針對上篇提到的關於redis刷回數據庫的安全性的設計模式，因為我們使用的是list來做數據索引，所以在我們將list數據提取出來的時候，一旦redis在這時候出現異常，就會導致剛提取出來的數據丟失！有些小伙伴就說，丟失就丟失唄，才一點數據。但是我們做程序，就應該以嚴謹為基礎，所以下面就來說下Redis List這位大佬給我們提供了什么幫助。

• 　　Redis List -》RpopLpush（）函數
•        使用方法：RPOPLPUSH source destination
•        說明：命令RPOPLPUSH在一個原子時間內，執行以下兩個動作：①命令RPOPLPUSH在一個原子時間內，執行以下兩個動作；②將source彈出的元素插入到列表destination，作為destination列表的的頭元素。
•        設計模式：

  　　Redis的列表經常被用作隊列(queue)，用於在不同程序之間有序地交換消息(message)。一個程序(稱之為生產者，producer)通過LPUSH命令將消息放入隊列中，而另一個程序(稱之為消費者，consumer)通過RPOP命令取出隊列中等待時間最長的消息。

  不幸的是，在這個過程中，一個消費者可能在獲得一個消息之后崩潰，而未執行完成的消息也因此丟失。

  使用RPOPLPUSH命令可以解決這個問題，因為它在返回一個消息之余，還將該消息添加到另一個列表當中，另外的這個列表可以用作消息的備份表：假如一切正常，當消費者完成該消息的處理之后，可以用LREM命令將該消息從備份表刪除。

Redis數據刷回數據庫

方面文字太多？沒關系。下面先來一段代碼！我們的主體部分：

index.php：

 

<?php
require_once(__DIR__."/Mysql.class.php");
require_once(__DIR__."/Redis.class.php");
require_once(__DIR__."/Output_Log.class.php");


$rel = true;        //無限循環的變量
$num = 0;            //用來沒數據時的判斷依據
date_default_timezone_set("Asia/Shanghai"); 
$now = date("Y-m-d H:i:s");        //當前時間
//file log
$txt = dirname(__DIR__)."/Script_Log/clickgood_log.txt";
$output = new OutputLog();
$test = $output->open($txt,"a+");

while($rel)
{
    $redis = new RedisCtrl();

    //開始干活
    if($num==0){
        //這里就是將信息輸出到文件里記錄，下面很多地方都是一樣的。
        $text = "start ".$name."\n";
        echo $text;
        $output->write($test,$text);
    }

    //獲取備份隊列的長度
    $copylistlength = $redis->llen("comment:uploadcopylist"); 

    //我這里展示的是第一數據回滾到mysql，小伙伴想批量回滾的，自己改裝下就可以用了。
    //自己動手豐衣足食！
    if($copylistlength>1)
    {
        //由於是單一數據回滾，所以我要判斷它是否超過我設定的值，小伙伴們最好也自己定一個閾值。
        //report error
        echo $now." ->false\n";
        $rel = false;
        return;
    }
    else if($copylistlength==1)
    {
        //這里判斷防止上次redis出現錯誤，導致數據沒有及時回到mysql
        $data = $redis->rpop("comment:uploadcopylist");
        $rel = $redis->UpdateClickGoodDataToMysql($data);
        $text = $rel."\n";
        echo $text;
        $output->write($test,$text);
    }
    else
    {
        //獲取主要隊列的長度
        $listlength = $redis->llen("comment:uploadlist");
        if ($listlength>0) {
            //使用之前說到的設計模式
            $data = $redis->rpoplpush("comment:uploadlist","comment:uploadcopylist");

            $rel = $redis->UpdateClickGoodDataToMysql($data);
            $text = $rel."\n";
            echo $text;
            $output->write($test,$text);
        }else{
            // 隊列為空
            // 打印關閉信息，這里的寫法算是維持進程窗口不關閉，需要手動關閉
            // 如果想讓它執行完自動關閉的，
            // 把下面改寫成$rel = false;
            if($num<=3){
                $text = $now." -> please close .\n";
                echo $text;
                $output->write($test,$text);
                $num++;
            }
            else
            {
                $output->close($test);
            }
        }
    }

}

 

 

Redis.class.php:　　redis操作類

 

 

 

<?php
class RedisCtrl
{
    //init redis
    static $redisIp = "127.0.0.1";
    static $redisPort =6379;
    static $redisPass ="";
    public $redis = null;

    //Redis
    public function __construct()
    {
        $this->redis = new Redis();
        $this->redis->connect(self::$redisIp,self::$redisPort);
        $this->redis->auth(self::$redisPass);
    }

    public function llen($key)
    {
        $rel = $this->redis->llen($key);
        return $rel;
    }

    public function rpop($key)
    {
        $rel = $this->redis->rpop($key);
        return $rel;
    }

    public function rpoplpush($source,$destination)
    {
        $rel = $this->redis->rpoplpush($source,$destination);
        return $rel;
    }

    public function UpdateClickGoodDataToMysql($data)
    {
        //get id and time from redis list
        $result = json_decode($data,true);
        $id = $result['id'];
        $time = $result['time'];
        $arr = array();

        //like
        $like = $this->redis->zscore("comment:like",$id);
        $like = $like?$like:0;
        //hate
        $hate = $this->redis->zscore("comment:hate",$id);
        $hate = $hate?$hate:0;

        $sql = "update comment_info set like_count=".$like.", hate_count=".$hate." where id=".$id;
        $arr[] = $sql;
        //update sql
        $mysql = new MysqlCtrl();
        $mysql->saveMySQL($arr);

        //更新完，將set集合里需要更新的id去掉
        $this->redis->srem("comment:uploadset",$id);
        //更新完畢，將備份隊列里的數據去掉
        $this->redis->lrem("comment:uploadcopylist",$data);

        return $sql."\n";
    }
}

 

 

 

Mysql.class.php　　mysql類

<?php
//封裝函數
class MysqlCtrl
{
    //初始化參數
    //數據庫參數配置
    static $dbms = "mysql";
    static $host = Your host;
    static $user = Your user;
    static $pass =  Your pass;
    static $database = Your database;
    //睡眠時間
    static $sleep = 1;

    public $dsn = null;
    public $dbh = null;

    public function __construct()
    {
        $this->dsn = self::$dbms.":host=".self::$host.";dbname=".self::$database;
        //return $dsn;
        try {
              $this->dbh = new PDO($this->dsn, self::$user, self::$pass);
              echo "Connected\n";
        } catch (Exception $e) {
            echo $this->dsn;
              die("Unable to connect: " . $e->getMessage());
        }
    }
    
    //保存數據到數據庫
    //PDO
    public function saveMySQL($arr)
    {

        try {  
              $this->dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

              $this->dbh->beginTransaction();

              $count = count($arr);
              for ($i=0; $i < $count; $i++) { 
                  $this->dbh->exec($arr[$i]);
              }
        
              $this->dbh->commit();
          
        } catch (Exception $e) {
              $this->dbh->rollBack();
              echo "Failed: " . $e->getMessage()."\n";
              $json = json_encode($arr);
              echo "False-SQL: ".$json."\n";
              exit();
        }
    }
}

 

Output_Log.class.php　　輸出信息到文件的類

<?php
class OutputLog
{
    public function open($name,$r)
    {
        $text = fopen($name, $r);
        return $text;
    }

    public function write($name,$title)
    {
        $rel = fwrite($name, $title);
        return $rel;
    }

    public function close($name)
    {
        fclose($name);
    }
}

 

clickgood_log.txt　　這里是保存輸出的信息，里面是空白的。

hellO world

上面這些就是整套數據保存到mysql的操作，這是本人源碼copy過來的，所以細分程度比較高，但是可擴展性也很高。有什么錯誤的地方希望小伙伴們能提出，謝謝。

最后就是我們的進程調用了，其實很簡單

創建一個txt文件，然后改名為clickgood.bat，記得把txt后綴文件名改為bat

clickgood.bat：

 D:\Software\wamp64\bin\php\php7.0.10\php.exe index.php 

關於上面的bat注意兩點，一前面那個php.exe，按照你自己的路徑去找，我使用wampserver測試環境，基本就是上面的路徑。第二點，后面的index.php和clickgood.bat同一目錄下。

好了！終於可以收尾了！、

歡迎大家交流，上面只是本人自己的做法，希望大家能夠指出錯誤的地方！或者提供更好的做法。