問題描述

這幾天做銀行對帳介面時，踩了一個坑，具體需求大致描述一下。

銀行每天凌晨後，會開始準備昨天的交易流水資料，需要我們這邊請求拿到。

因為他們給的是一個base64加密的zip壓縮流，解開以後可以得到txt檔案，裡面就是我們需要的資料了。

業務程式寫好以後，隨手丟了一個定時任務就去睡覺了。

哪知道第二天上班的時候，檢查。發現並沒有拿到資料，查詢一下日誌的時候發現，凌晨服務端請求的時候，銀行介面返回了：系統錯誤資訊。

諮詢銀行那邊後，銀行那邊相關人員建議我們多請求幾次，但是在多次請求中，我發現銀行那邊是有頻率限制的，最後得知，此介面只能半個小時才能請求一次。這就比較尷尬了，因為我不知道銀行那邊什麼時候能返回資料給我。

於是這個問題怎麼解決呢？理想的情況是，服務端請求資料，銀行那邊沒有返回。然後程式等半個小時後，再請求一次，這樣一直到銀行那邊返回正確的資料中止。

問題分析

這個功能換作別的語言也許不難，但是通過php實現的話，那就比較麻煩了。通常的話，我們可以搭配linux下的cron來實現，比如我們可以在凌晨到6:00之間做一個定時任務，每半個小時掃描一次php指令碼，如果發現銀行那邊的狀態依舊為失敗的話，我們就執行一次php指令碼去請求資料。直到請求到正確的資料，然後把狀態更新為成功。

這不失為一種方法，但太傻了。比如說銀行那邊比較正常，凌晨，也就是第一次請求的時候，就已經返回了正確的資料，那麼我們的cron指令碼還傻傻的每個半個小時執行一次，好蠢！~

或者我們可以嘗試使用linux下的at命令，但感覺還是不夠優雅。

解決問題

於是決定給laravel擴充套件一個swoole外掛來解決此問題，swoole的定時任務很完美的解決了我們目前的問題。

首先我們需要把swoole擴充套件安裝好，具體過程略。
裝好以後，我們寫一個swoole簡易的服務端測試指令碼，注意，此指令碼是放在app/Console/Commands/下的，筆者是放在了app/Console/Commands/Swoole/swoole.php下，具體程式碼為

<?php

namespace App\Console\Commands\Swoole;

use Illuminate\Console\Command;

class swoole extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'swoole {action}';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = "Let's use swoole !";

    private $serv;

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    /**
     * Execute the console command.
     *
     * @return mixed
     */
    public function handle()
    {
        $arg = $this->argument('action');
        switch ($arg) {
            case 'start':
                $this->info('swoole server started');
                $this->start();
                break;
            case 'stop':
                $this->info('stoped');
                $this->stop();
                break;
            case 'restart':
                $this->info('restarted');
                break;
        }
    }

    private function start()
    {
        $this->serv = new \swoole_server("127.0.0.1", 9501);
        $this->serv->set(array(
            'worker_num' => 8,
            'daemonize' => false,
            'max_request' => 10000,
            'dispatch_mode' => 2,
            'task_worker_num' => 8,
            'task_ipc_mode' => 3,
            'log_file' => storage_path('logs/taskqueue.log'),
        ));

        $this->serv->on('Receive', array($this, 'onReceive'));
        $this->serv->on('Task', array($this, 'onTask'));
        $this->serv->on('Finish', array($this, 'onFinish'));
        $this->serv->start();

    }

    public function onReceive(\swoole_server $serv, $fd, $from_id, $data)
    {
        $serv->task($data);
    }

    public function onTask($serv, $task_id, $from_id, $data)
    {
        $timeon = (3) * 1000;
        if ($timeon > 0) {
            $serv->after($timeon, function () {
                //業務邏輯處
                exec('php /path/to/root/artisan Test:Command');
            });
        }
        return date('Y-m-d H:i:s') . "第一次執行";
    }

    public function onFinish($serv, $task_id, $data)
    {

        echo "Task finish\n";
    }

    private function stop()
    {
        exec('/usr/bin/killall php');
    }

}
 

這是服務端，我們主要用到了after方法，模擬的話，是三秒一執行。實際應該是三十分鐘

然後我們隨便寫一個客戶端連線類

<?php
/**
 * Created by PhpStorm.
 * User: nosay
 * Date: 4/13/18
 * Time: 9:27 PM
 */

namespace App\Extension\php\Swoole;


class swoole{

    private $data;
    private $client;

    public function __construct($data){
        $this->data = $data;
        $this->client = new \swoole_client(SWOOLE_SOCK_TCP);
    }

    public function connect(){


        if( !$this->client->connect("127.0.0.1", 9501 , 1) ) {
            echo "Error";
        }


        $this->client->send($this->data);
    }



}

於是我們在銀行指令碼中就可以去執行了

<?php

namespace App\Console\Commands\Test;

use App\Extension\php\Swoole\swoole;
use Illuminate\Console\Command;

class TestCommand extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'Test:Command';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Command Test';

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    /**
     * Execute the console command.
     *
     * @return mixed
     */
    public function handle()
    {
        //這裡是業務邏輯
        //如果銀行那邊返回的為false的話，那麼我們把他交給swoole的定時指令碼
        $status = false;

        if(!$status)
        {
            $swoole = new swoole("hehe");
            $swoole->connect();
        }



    }
}

以上內容希望幫助到大家，很多PHPer在進階的時候總會遇到一些問題和瓶頸，業務程式碼寫多了沒有方向感，不知道該從那裡入手去提升，對此我整理了一些資料，包括但不限於：分散式架構、高可擴充套件、高效能、高併發、伺服器效能調優、TP6，laravel，YII2，Redis，Swoole、Swoft、Kafka、Mysql優化、shell指令碼、Docker、微服務、Nginx等多個知識點高階進階乾貨需要的可以免費分享給大家，需要的可以加入我的PHP官方群免費獲取，點選此處

或者戳下面連結

PHP進階學習思維導圖、面試；文件、視訊資源免費獲取​kdocs.cn

部分資料截圖如下