共计 3150 个字符,预计需要花费 8 分钟才能阅读完成。
一、应用目标:简化代码,使需要逻辑异步执行
二、同步事件操作步骤
1、新建事件php artisan make:event UserLogin
namespace App\Events;
use Illuminate\Broadcasting\Channel;
use Illuminate\Broadcasting\InteractsWithSockets;
use Illuminate\Broadcasting\PresenceChannel;
use Illuminate\Broadcasting\PrivateChannel;
use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
use Illuminate\Foundation\Events\Dispatchable;
use Illuminate\Queue\SerializesModels;
class UserLogin
{
use Dispatchable, InteractsWithSockets, SerializesModels;
// 定义 public listener 会应用到
public $data;
/**
* Create a new event instance.
*
* @return void
*/
public function __construct($data)
{$this->data = $data;}
/**
* Get the channels the event should broadcast on.
*
* @return \Illuminate\Broadcasting\Channel|array
*/
public function broadcastOn()
{return new PrivateChannel('userLogin');
}
}
2、事件监听app/Providers/EventServiceProvider.php
namespace App\Providers;
use App\Events\UserLogin;
use Illuminate\Auth\Events\Registered;
use Illuminate\Auth\Listeners\SendEmailVerificationNotification;
use Illuminate\Foundation\Support\Providers\EventServiceProvider as ServiceProvider;
use Illuminate\Support\Facades\Event;
class EventServiceProvider extends ServiceProvider
{
/**
* The event listener mappings for the application.
*
* @var array
*/
protected $listen = [
Registered::class => [SendEmailVerificationNotification::class,],
// 用户登录胜利后事件处理
UserLogin::class => [
'App\Listeners\UserLogin\WriteLog',// 记录日志操作
'App\Listeners\UserLogin\ActiveOperate',// 沉闷操作
]
];
/**
* Register any events for your application.
*
* @return void
*/
public function boot()
{parent::boot();
//
}
}
3、生成监听者php artisan event:generate
命令执行后会生成配置的两个文件
app/Listeners/UserLogin/ActiveOperate.php
app/Listeners/UserLogin/WriteLog.php
ActiveOperate.php 代码展现
namespace App\Listeners\UserLogin;
use App\Events\UserLogin;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Queue\InteractsWithQueue;
class ActiveOperate
{
/**
* Create the event listener.
*
* @return void
*/
public function __construct()
{//}
/**
* Handle the event.
*
* @param UserLogin $event
* @return void
*/
public function handle(UserLogin $event)
{
//$event 接管事件属性办法
info('ActiveOperate'.json_encode($event->data,JSON_UNESCAPED_UNICODE));
}
}
4、建设控制器
php artisan make:controller UserloginController
在控制器中调用事件
namespace App\Http\Controllers;
use App\Events\UserLogin;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Event;
class UserController extends Controller
{public function login(Request $request){var_dump('代码操作逻辑');
$data = [
'id' => '1',
'username' => 'testname'
];
// 事件散发
event(new UserLogin($data));
}
}
拜访控制器办法,会调用注册好的事件
[2021-05-16 06:07:23] local.INFO: ActiveOperate{"id":"1","username":"testname"}
[2021-05-16 06:07:23] local.INFO: ActiveOperate{"id":"1","username":"testname"}
5、须要留神的中央
1)event 作用:起到两头桥梁作用,把 controller 中的数据传递给 listener,就是 传递命令的人
2)controller 作用:应用 event 注册事件,就是 下达命令的人
3)listener 作用:解决注册的事件,就是 理论打工人
4)执行过程还是同步执行,等到 listener 全副执行实现,控制器才会返回响应
三、异步执行事件
1、操作:listener 继承 ShouldQueue,增加实现形式和缓存 key
/**
* 工作将被发送到的队列的连贯的名称
*
* @var string|null
*/
public $connection = 'redis';
/**
* 工作将被发送到的队列的名称
*
* @var string|null
*/
public $queue = 'UserLogin:WriteLog';
增加异步后,事件不会同步执行,只执行控制器办法,事件期待后台任务解决
2、执行
1)拜访控制器办法,能够看到对应日志没有生成新的文件内容,而是存储在了 redis 中,应用 list 存储,key 中有咱们定义的局部 key,存储的数据为对象信息
2)调用 php artisan 执行队列
php artisan queue:work –queue=UserLogin:ActiveOperate
php artisan queue:work –queue=UserLogin:WriteLog
3)独自执行 queue:work 无奈执行,必须指定独自的队列名称,起因没有找到