分类： PHP

需求

订单完成支付后通知服务器已到账，通知失败则重试，最多3次，第二次5秒后，第三次10秒后

实现方案一

生成任务类

php artisan make:job PaymentNotify

命令将会在app/Jobs目录下生成一个新的类,编辑：

< ?php

namespace App\Jobs;

use App\Exceptions\SignException;
use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;

class PaymentNotify implements ShouldQueue
{
    use InteractsWithQueue, Queueable, SerializesModels;

    protected $data;

    /**
     * Create a new job instance.
     *
     * @param $data
     */

    public function __construct($data)
    {
        $this->data = $data;
    }

    /**
     * Execute the job.
     *
     * @throws \Exception
     */
    public function handle()
    {
        if ($this->attempts() == 1) {
            //处理订单通知
            info('notify'.$this->attempts());
            if(true){//测试强制通知失败
                $this->release(5);//手动释放任务回队列，带延时执行时间
            }
        }

        if ($this->attempts() == 2) {
            //处理订单通知
            info('notify'.$this->attempts());
            if(true){
                $this->release(10);
            }
        }

        if ($this->attempts() == 3) {
            //处理订单通知
            info('notify'.$this->attempts());
            if(true){
                throw new SignException('fails');//抛出异常，任务失败，自动入库
            }

        }
    }

}

添加测试路由并访问：

Route::get('/pay/notify', function(){
    dispatch((new \App\Jobs\PaymentNotify(['order'=>time().mt_rand(1000,9999)]))->onQueue('PaymentNotify'));
    return 'ok';
});

监听队列

php artisan queue:work  --queue=PaymentNotify --tries=3  --sleep=0

可查看使用说明

$php artisan queue:work --help
Usage:
  queue:work [options] [--] [<connection>]

Arguments:
  connection               The name of connection

Options:
      --queue[=QUEUE]      The queue to listen on
      --daemon             Run the worker in daemon mode (Deprecated)
      --once               Only process the next job on the queue
      --delay[=DELAY]      Amount of time to delay failed jobs [default: "0"]
      --force              Force the worker to run even in maintenance mode
      --memory[=MEMORY]    The memory limit in megabytes [default: "128"]
      --sleep[=SLEEP]      Number of seconds to sleep when no job is available [default: "3"]
      --timeout[=TIMEOUT]  The number of seconds a child process can run [default: "60"]
      --tries[=TRIES]      Number of times to attempt a job before logging it failed [default: "0"]
  -h, --help               Display this help message
  -q, --quiet              Do not output any message
  -V, --version            Display this application version
      --ansi               Force ANSI output
      --no-ansi            Disable ANSI output
  -n, --no-interaction     Do not ask any interactive question
      --env[=ENV]          The environment the command should run under
  -v|vv|vvv, --verbose     Increase the verbosity of messages: 1 for normal output, 2 for more verbose output and 3 for debug

命令意思是：使用默认队列连接的PaymentNotify队列，失败最多尝试执行3次，轮询新任务之前的等待时间为0（即有任务随时检测执行，不会在无任务时默认等待3秒）

任务执行情况

[2017-03-07 16:22:44] local.INFO: notify1  
[2017-03-07 16:22:49] local.INFO: notify2  
[2017-03-07 16:22:59] local.INFO: notify3

符合预期

方案二

另一种思路是订单完成后直接生成3个队列，

$order = time().mt_rand(1000,9999);

dispatch((new \App\Jobs\PaymentNotify(['order'=>$order]))->onQueue('PaymentNotify'));

dispatch((new \App\Jobs\PaymentNotify(['order'=>$order]))->onQueue('PaymentNotify')->delay(5));

dispatch((new \App\Jobs\PaymentNotify(['order'=>$order]))->onQueue('PaymentNotify')->delay(10));

后两个队列带延时执行参数，设置最多执行次数为1，执行队列时检测已经通知成功则跳过执行

总结

方案一：在处理队列时需判断重试次数，分类处理，业务需求变化需改动多；
方案二：在redis中相同队列存在多条，业务需求变化处理逻辑相对改动少；
各有利弊。

添加自定义的 Guard

需要通过Auth门面的extend方法定义自己的认证guard，在App\Providers\AuthServiceProvider的boot方法中实现：

public function boot()
{
    $this->registerPolicies();

    Auth::extend('XXX', function($app, $name, array $config) {
        // 返回 Illuminate\Contracts\Auth\Guard 实例
        $guard = new XXXGuard($name,Auth::createUserProvider($config['provider']),$this->app['session.store']);
        //事件
        if (method_exists($guard, 'setDispatcher')) {
            $guard->setDispatcher($this->app['events']);
        }
        //请求
        if (method_exists($guard, 'setRequest')) {
            $guard->setRequest($this->app->refresh('request', $guard, 'setRequest'));
        }
        return $guard;
    });
}

（更多…）

function encrypt($str, $key) {

$block = mcrypt_get_block_size(‘des’, ‘ecb’);

$pad = $block – (strlen($str) % $block);

$str .= str_repeat(chr($pad), $pad);

$tt = mcrypt_encrypt(MCRYPT_DES,$key, $str,MCRYPT_MODE_ECB);

return base64_encode($tt);

}

function decrypt($str, $key) {

$str = base64_decode($str);

$str = mcrypt_decrypt(MCRYPT_DES, $key, $str, MCRYPT_MODE_ECB); 

$block = mcrypt_get_block_size(‘des’, ‘ecb’);

$pad = ord($str[($len = strlen($str)) – 1]);

return substr($str, 0, strlen($str) – $pad);

}
在使用以上DES加密解密过程中报了错，经查原来是PHP版本中$key的长度不能超过8位，之前的KEY随机生成了14位。

安装 Composer

curl -sS https://getcomposer.org/installer | php 

下载完成之后将它放在系统 PATH 中，供全局调用。

mv composer.phar /usr/local/bin/composer

安装 Larave

composer create-project laravel/laravel /home/wwwroot/laravel/

执行下面的命令来授予 storage 文件夹的读写操作权限

chgrp -R www /home/wwwroot/laravel/

chmod -R 775 /home/wwwroot/laravel/app/storage

建立网站域名指向/home/wwwroot/laravel/public(略)

输入域名若提示：

open_basedir restriction in effect. File() is not within the allowed path(s):XXX

open_basedir可将用户访问文件的活动范围限制在指定的区域，通常是当前网站根目录的路径。

在Apache的httpd.conf中VirtualHost的相应设置方法: 

php_admin_value open_basedir “/home/wwwroot/laravel:/home/wwwroot/laravel/public:/tmp/:/var/tmp/:/proc/“

重启apache解决

/**

* 导出数据为excel表格

*@param $data    一个二维数组,结构如同从数据库查出来的数组

*@param $title   excel的第一行标题,一个数组,如果为空则没有标题

*@param $filename 下载的文件名

*@examlpe

$stu = M (‘User’);

$arr = $stu -> select();

exportexcel($arr,array(‘id’,’账户’,’密码’,’昵称’),’文件名!’);

*/

function exportexcel($data=array(),$title=array(),$filename=’report’){

header(“Content-type:application/octet-stream”);

header(“Accept-Ranges:bytes”);

header(“Content-type:application/vnd.ms-excel”);

header(“Content-Disposition:attachment;filename=”.$filename.”.xls”);

header(“Pragma: no-cache”);

header(“Expires: 0”);

//导出xls 开始

if (!empty($title)){

foreach ($title as $k => $v) {

$title[$k]=iconv(“UTF-8”, “GB2312”,$v);

}

$title= implode(“\t”, $title);

echo “$title\n”;

}

if (!empty($data)){

foreach($data as $key=>$val){

foreach ($val as $ck => $cv) {

$data[$key][$ck]=iconv(“UTF-8”, “GB2312”, $cv);

}

$data[$key]=implode(“\t”, $data[$key]);

}

echo implode(“\n”,$data);

}

}