摘要：諸如此類，隊列的應用范圍是如此之廣。方案抽象到更高一層，開發一套通用異步處理隊列適用于任何復雜的業務邏輯那么，作為架構師，使用隊列的做法，將抽象層和業務層分離，可具有良好的擴展性和可維護性。

一、隊列使用場景：為什么需要隊列
在web開發中，我們經常會遇到需要處理批量任務的時候，這些批量任務可能是用戶提交的，也可能是當系統被某個事件觸發時需要進行批量處理的，面對這樣的任務，如果是用戶提交的批量任務，初級程序員只能讓用戶觸發提交動作后，等待服務器處理完畢，并且將結果返回到瀏覽器，期間用戶不能關掉瀏覽器窗口，如果數據比較大，或者處理速度比較慢，那用戶體驗將會因此受到直接影響。但是當我們使用某訊或者某浪的郵箱時，點擊群發郵件之后，只需等待很短的時間，瀏覽器提示提交成功，正在發送之類的信息時，用戶就可以關掉瀏覽器，稍后，收件地址欄里的郵箱將陸續收到該群發郵件，再比如群發定時郵件，以及當商城系統中有客戶下單，客戶，客服，倉庫等相關人員收到訂單郵件信息。諸如此類，隊列的應用范圍是如此之廣。

二 :普通工程師的解決方案和架構師的解決方案
方案1：建表存郵件，消息等，用定時程序取出發送。

方案2：抽象到更高一層，開發一套通用異步處理隊列適用于任何復雜的業務邏輯
那么，作為架構師，使用隊列的做法，將抽象層和業務層分離，可具有良好的擴展性和可維護性。相比較而言就高明了許多，下面就我們介紹一下自定義隊列的實現思路和方法。

三 :隊列總體設計

1：需要隊列程序，提供加入隊列接口和取隊列接口等
2：需要存儲隊列，文件或者數據庫
3：需要定時程序取出隊列并執行
4：其它擴展功能：優先級，日志，定時等

代碼的目錄結構如下，每個文件的作用用//注釋來標明
|--addTask.php //添加任務到隊列的例子
|--cronMission.php //定時任務調度程序,例如linux中受crontab直接調用的文件，業務邏輯工程師可以在這個文件中靈活定義自己的隊列任務，從而不用每個隊列任務都需要上服務器修改crontab，從而在安全性，便捷性方面有很大提高
|--db.php //數據庫操作
|--db.sql //建立隊列需要用到的基本表結構
|--doQueue.php //執行隊列任務
|--Queue.class.php //隊列核心業務在這里定義，包括將任務加入隊列，讀隊列，更改隊列任務狀態
|--sendMsg.php //隊列要實現具體任務的業務接口，比如現有系統的發送消息的接口，這里例子中因為將此隊列程序和現有系統系統集成，用寫入日志來演示

四 :隊列具體實現一：建任務存儲表
1：
先來個最基本的：

CREATE TABLE`queue` (
 id int(11) NOT NULL auto_increment primarykey,
 taskphp varchar(128) NOT NULL default "",
 param text not null default "",
 status tinyint not null default 0,
 ctime timestamp NOT NULL default CURRENT_TIMESTAMP,
 KEY (ctime)
) ENGINE=InnoDBDEFAULT CHARSET=utf8;

字段解釋：
taskphp：處理業務的接口文件
param：處理業務的接口文件需要接收的參數
status：任務處理狀態，0為未處理，處理完畢更改為1

五 、隊列具體實現二：定義調用接口

寫核心類Queue.class.php， 實現基本接口：
1：加入隊列接口
l //$param1 為執行任務的程序，$param2 為程序參數，可以為序列化的數據
l $cqueue->add($param1,$param2);
2: 讀取隊列接口
l $tasks = $cqueue->getQueueTask($limit = 1000);
3：更新任務狀態
l $cqueue->updateTaskStatus($id);
4：a2s是自定義的一個數組轉換字符串方法，這里不要使用json_encode，容易出現問題，同樣，從數據庫中取出轉換為數組的時候，使用s2a方法
l $re = $cqueue->add("sendMsg.php", Queue::a2s($arr));

 4,//發信息的人的UID
     *      "uids" => array(6,234,34,67,7888,2355), //接收信息的人的UID
     *      "content" => "xxxxx",//信息內容
     *  );
     * $cqueue = new Queue();
     * $cqueue->add("/app/send_msg.php", serialize($arr));
     *
     */
    public function add($taskphp,$param)
    {
        $taskphp = mysql_real_escape_string($taskphp);
        //$param = mysql_real_escape_string($param);
        $param = $param;
        $sql = "insert into queue (taskphp, param) values("".$taskphp."", "".$param."")";
        $re = execute($sql);
        if ($re)
        {
            $pid = mysql_insert_id();
            return $pid;
        }
        else
        {
            return false;
        }
    }


    /**
     * 讀取任務隊列
     * 
     * @param string $limit 一次取多少條
     */
     public function getQueueTask($limit = 1000)
     {
        $limit = (int)$limit;
        $sql = "select id, taskphp, param from queue  where status = 0 order by id asc";
        $re = query($sql);
        return $re;
     }

    /**
     * 更新任務狀態
     * 
     * @param string $limit 一次取多少條
     */
     public function updateTaskByID($id)
     {
        $id = (int)$id;
        $mtime = time();
        $sql = "update queue  set status =1, mtime = ".$mtime." where id = ".$id;
        $re = execute($sql);
        return $re;
     }


     public static function a2s($arr)
    {
        $str = "";
        foreach ($arr as $key => $value)
        {
            if (is_array($value))
            {
                foreach ($value as $value2)
                {
                    $str .= urlencode($key) . "[]=" . urlencode($value2) . "&";
                }
            }
            else
            {
                $str .= urlencode($key) . "=" . urlencode($value) . "&";
            }
        }
        return $str;
    }

    public static function s2a($str)
    {
        $arr = array();
        parse_str($str, $arr);
        return $arr;
    }

}

?>

接下來就是部署調度了， 這個呢也不是就配置crontab那么簡單，要可維護性，可擴展性好，能多進程并發執行，能監控隊列運行狀態等等，太長了，這個下一篇講。

本內容來自本人講的公開課：http://www.ucai.cn/train?f=17