深入解析PHP的Laravel框架中的event事件操作-华尔子博-奥夏网

注册事件以及监听器

首先我们需要在 app/Providers/目录下的EventServiceProvider.php中注册事件监听器映射关系，如下：

protected $listen = [

'AppEventsBlogView' => [

'AppListenersBlogViewListener',

],

];

然后项目根目录下执行如下命令

1	`php artisan event:generate`

该命令完成后，会分别自动在 app/Events和app/Listensers目录下生成 BlogView.php和BlogViewListener.php文件。

定义事件

<?php

namespace AppEvents;

use AppEventsEvent;

use AppPost;

use IlluminateQueueSerializesModels;

use IlluminateContractsBroadcastingShouldBroadcast;

class BlogView extends Event

{

use SerializesModels;

/**

* Create a new event instance.

*

* @return void

*/

public function __construct(Post $post)

{

$this->post = $post;

}

/**

* Get the channels the event should be broadcast on.

*

* @return array

*/

public function broadcastOn()

{

return [];

}

其实看到这些你会发现该事件类只是注入了一个 Post实例罢了，并没有包含多余的逻辑。

定义监听器

事件监听器在handle方法中接收事件实例，event:generate命令将会自动在handle方法中导入合适的事件类和类型提示事件。在handle方法内，你可以执行任何需要的逻辑以响应事件，我们的代码实现如下：

<?php

namespace AppListeners;

use AppEventsBlogView;

use IlluminateQueueInteractsWithQueue;

use IlluminateContractsQueueShouldQueue;

use IlluminateSessionStore;

class BlogViewListener

{

protected $session;

/**

* Create the event listener.

*

* @return void

*/

public function __construct(Store $session)

{

$this->session = $session;

}

/**

* Handle the event.

*

* @param BlogView $event

* @return void

*/

public function handle(BlogView $event)

{

$post = $event->post;

//先进行判断是否已经查看过

if (!$this->hasViewedBlog($post)) {

//保存到数据库

$post->view_cache = $post->view_cache + 1;

$post->save();

//看过之后将保存到 Session

$this->storeViewedBlog($post);

}

protected function hasViewedBlog($post)

{

return array_key_exists($post->id, $this->getViewedBlogs());

}

protected function getViewedBlogs()

{

return $this->session->get('viewed_Blogs', []);

}

protected function storeViewedBlog($post)

{

$key = 'viewed_Blogs.'.$post->id;

$this->session->put($key, time());

}

注释中也已经说明了一些逻辑。

触发事件

事件和事件监听完成后，我们要做的就是实现整个监听，即触发用户打开文章事件在此我们使用和 Event提供的 fire方法，如下：

<?php

namespace AppHttpControllers;

use IlluminateHttpRequest;

use AppPost;

use IlluminateSupportFacadesEvent;

use AppHttpRequests;

use AppEventsBlogView;

use AppHttpControllersController;

class BlogController extends Controller

{

public function showPost($slug)

{

$post = Post::whereSlug($slug)->firstOrFail();

Event::fire(new BlogView($post));

return view('home.blog.content')->withPost($post);

}

现在打开页面发现数据库中的`view_cache已经正常加1了，这样整个就完成了。

事件广播
简介：
Laravel 5.1 之中新加入了事件广播的功能，作用是把服务器中触发的事件通过websocket服务通知客户端，也就是浏览器，客户端js根据接受到的事件，做出相应动作。本文会用简单的代码展示一个事件广播的过程。

依赖：

redis
nodejs, socket.io
laravel 5.1

配置：

config/broadcasting.php中，如下配置’default’ => env(‘BROADCAST_DRIVER’, ‘redis’),，使用redis作为php和js的通信方式。
config/database.php中配置redis的连接。

定义一个被广播的事件：
根据Laravel文档的说明，想让事件被广播，必须让Event类实现一个IlluminateContractsBroadcastingShouldBroadcast接口，并且实现一个方法broadcastOn。broadcastOn返回一个数组，包含了事件发送到的channel(频道)。如下：

namespace AppEvents;

use AppEventsEvent;

use IlluminateQueueSerializesModels;

use IlluminateContractsBroadcastingShouldBroadcast;

class SomeEvent extends Event implements ShouldBroadcast

{

use SerializesModels;

public $user_id;

/**

* Create a new event instance.

*

* @return void

*/

public function __construct($user_id)

{

$this->user_id = $user_id;

}

/**

* Get the channels the event should be broadcast on.

*

* @return array

*/

public function broadcastOn()

{

return ['test-channel'];

}

被广播的数据：默认情况下，Event中的所有public属性都会被序列化后广播。上面的例子中就是$user_id这个属性。你也可以使用broadcastWith这个方法，明确的指出要广播什么数据。例如：

public function broadcastWith()

{

return ['user_id' => $this->user_id];

}

Redis和Websocket服务器：

需要启动一个Redis，事件广播主要依赖的就是redis的sub/pub功能，具体可以看redis文档

需要启动一个websocket服务器来和client通信，建议使用socket.io，代码如下:

var app = require('http').createServer(handler);

var io = require('socket.io')(app);

var Redis = require('ioredis');

var redis = new Redis('6379', '192.168.1.106');

app.listen(6001, function() {

console.log('Server is running!');

});

function handler(req, res) {

res.writeHead(200);

res.end('');

}

io.on('connection', function(socket) {

console.log('connected');

});

redis.psubscribe('*', function(err, count) {

console.log(count);

});

redis.on('pmessage', function(subscribed, channel, message) {

console.log(subscribed);

console.log(channel);

console.log(message);

message = JSON.parse(message);

io.emit(channel + ':' + message.event, message.data);

});

这里需要注意的是redis.on方法的定义,接收到消息后，给client发送一个事件，事件名称为channel + ‘:’ + message.event。

客户端代码：客户端我们也使用socket.io，作为测试，代码尽量简化，仅仅打印一个接受到的数据即可。如下：

var socket = io('http://localhost:6001');

socket.on('connection', function (data) {

console.log(data);

});

socket.on('test-channel:App\Events\SomeEvent', function(message){

console.log(message);

});

console.log(socket);

服务器触发事件：直接在router中定义个事件触发即可。如下：

Route::get('/event', function(){

Event::fire(new AppEventsSomeEvent(3));

return "hello world";

});

测试：

启动redis
启动websocket
打开带有客户端代码的页面，可以看到websocket已经连接成功。
触发事件,打开另一个页面 localhost/event。

这时就可以发现，第一个页面的console中打印出了Object{user_id: 3}，说明广播成功。

本文刊载的所有内容，包括文字、图片、音频、视频、软件、程序、以及网页版式设计等部门来源于互联网，版权均归原作者所有！本网站提供的内容服务于个人学习、研究或欣赏，以及其他非商业性或非盈利性用途，但同时应遵守著作权法及其他相关法律的规定，不得侵犯本网站及相关权利人的合法权利。
联系信息：邮箱aoxolcom@163.com或见网站底部。

THE END