欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

深入解析PHP的Laravel框架中的event事件操作

 更新時間:2016年03月21日 17:27:42   作者:一堆好人卡  
這篇文章主要介紹了PHP的Laravel框架中的event事件操作,其中重點講解了Laravel 5.1之中新加入了事件廣播的功能,需要的朋友可以參考下

 有時候當我們單純的看 Laravel 手冊的時候會有一些疑惑,比如說系統服務下的授權和事件,這些功能服務的應用場景是什么,其實如果沒有經歷過一定的開發(fā)經驗有這些疑惑是很正常的事情,但是當我們在工作中多加思考會發(fā)現有時候這些服務其實我們一直都見過。下面就事件、事件監(jiān)聽舉一個很簡單的例子你就會發(fā)現。

​ 這個例子是關于文章的瀏覽數的實現,當用戶查看文章的時候文章的瀏覽數會增加1,用戶查看文章就是一個事件,有了事件,就需要一個事件監(jiān)聽器,對監(jiān)聽的事件發(fā)生后執(zhí)行相應的操作(文章瀏覽數加1),其實這種監(jiān)聽機制在 Laravel 中是通過觀察者模式實現的.

注冊事件以及監(jiān)聽器
首先我們需要在 app/Providers/目錄下的EventServiceProvider.php中注冊事件監(jiān)聽器映射關系,如下:

protected $listen = [
    'App\Events\BlogView' => [
      'App\Listeners\BlogViewListener',
    ],
  ];

然后項目根目錄下執(zhí)行如下命令

php artisan event:generate

該命令完成后,會分別自動在 app/Events和app/Listensers目錄下生成 BlogView.php和BlogViewListener.php文件。

定義事件

<?php

namespace App\Events;

use App\Events\Event;
use App\Post;
use Illuminate\Queue\SerializesModels;
use Illuminate\Contracts\Broadcasting\ShouldBroadcast;

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 [];
  }
}

其實看到這些你會發(fā)現該事件類只是注入了一個 Post實例罷了,并沒有包含多余的邏輯。

定義監(jiān)聽器
事件監(jiān)聽器在handle方法中接收事件實例,event:generate命令將會自動在handle方法中導入合適的事件類和類型提示事件。在handle方法內,你可以執(zhí)行任何需要的邏輯以響應事件,我們的代碼實現如下:

<?php

namespace App\Listeners;

use App\Events\BlogView;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Session\Store;

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());
  }

}

注釋中也已經說明了一些邏輯。

觸發(fā)事件
事件和事件監(jiān)聽完成后,我們要做的就是實現整個監(jiān)聽,即觸發(fā)用戶打開文章事件在此我們使用和 Event提供的 fire方法,如下:

<?php

namespace App\Http\Controllers;

use Illuminate\Http\Request;
use App\Post;
use Illuminate\Support\Facades\Event;
use App\Http\Requests;
use App\Events\BlogView;
use App\Http\Controllers\Controller;

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);
  }

}

現在打開頁面發(fā)現數據庫中的`view_cache已經正常加1了,這樣整個就完成了。

事件廣播
簡介:
Laravel 5.1 之中新加入了事件廣播的功能,作用是把服務器中觸發(fā)的事件通過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類實現一個Illuminate\Contracts\Broadcasting\ShouldBroadcast接口,并且實現一個方法broadcastOn。broadcastOn返回一個數組,包含了事件發(fā)送到的channel(頻道)。如下:

namespace App\Events;

use App\Events\Event;
use Illuminate\Queue\SerializesModels;
use Illuminate\Contracts\Broadcasting\ShouldBroadcast;

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發(fā)送一個事件,事件名稱為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);

服務器觸發(fā)事件:
直接在router中定義個事件觸發(fā)即可。如下:

Route::get('/event', function(){
  Event::fire(new \App\Events\SomeEvent(3));
  return "hello world";
});

測試:

  • 啟動redis
  • 啟動websocket
  • 打開帶有客戶端代碼的頁面,可以看到websocket已經連接成功。
  • 觸發(fā)事件,打開另一個頁面 localhost/event。

這時就可以發(fā)現,第一個頁面的console中打印出了Object{user_id: 3},說明廣播成功。

相關文章

  • 解決PHP4.0 和 PHP5.0類構造函數的兼容問題

    解決PHP4.0 和 PHP5.0類構造函數的兼容問題

    以下是對解決PHP4.0和PHP5.0類構造函數兼容問題的方法進行了詳細的分析介紹,需要的朋友可以過來參考一下
    2013-08-08
  • PHP 實現base64編碼文件上傳出現問題詳解

    PHP 實現base64編碼文件上傳出現問題詳解

    這篇文章主要介紹了PHP 實現base64編碼文件上傳出現問題詳解,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2020-09-09
  • PHP基于雙向鏈表與排序操作實現的會員排名功能示例

    PHP基于雙向鏈表與排序操作實現的會員排名功能示例

    這篇文章主要介紹了PHP基于雙向鏈表與排序操作實現的會員排名功能,結合實例形式分析了php雙向鏈表的功能、定義及基于雙向鏈表的排序操作相關實現技巧,需要的朋友可以參考下
    2017-12-12
  • php導入大量數據到mysql性能優(yōu)化技巧

    php導入大量數據到mysql性能優(yōu)化技巧

    這篇文章主要介紹了php導入大量數據到mysql性能優(yōu)化技巧,通過針對SQL語句的優(yōu)化實現了mysql性能的提高,非常具有實用價值,需要的朋友可以參考下
    2014-12-12
  • PHP實現打包下載文件的方法示例

    PHP實現打包下載文件的方法示例

    這篇文章主要介紹了PHP實現打包下載文件的方法,涉及php基于curl的文件獲取、遍歷、zip壓縮及下載等相關操作技巧,需要的朋友可以參考下
    2017-10-10
  • PHP Mysql編程之高級技巧

    PHP Mysql編程之高級技巧

    盡管PHP為我們提供了很多函數,但有些東西處理起來還是不很方便。譬如PHP提供的日期時間函數就很有限。Mysql為我們提供了不少此類的函數。是否可以利用Mysql函數來處理PHP程序呢?
    2008-08-08
  • Laravel操作redis和緩存操作詳解

    Laravel操作redis和緩存操作詳解

    這篇文章主要為大家詳細介紹了Laravel操作redis和緩存操作的相關知識,文中的示例代碼講解詳細,具有一定的學習和借鑒價值,感興趣的小伙伴可以跟隨小編一起學習游戲
    2023-02-02
  • PHP實現動態(tài)柱狀圖改進版

    PHP實現動態(tài)柱狀圖改進版

    這篇文章主要介紹了PHP實現動態(tài)柱狀圖改進版,是在前面所述實現柱狀圖的基礎上進行的改進,具有一定參考借鑒價值,需要的朋友可以參考下
    2015-03-03
  • php中sprintf與printf函數用法區(qū)別解析

    php中sprintf與printf函數用法區(qū)別解析

    這篇文章主要介紹了php中sprintf與printf函數用法區(qū)別解析,需要的朋友可以參考下
    2014-02-02
  • php實現文件與16進制相互轉換的方法示例

    php實現文件與16進制相互轉換的方法示例

    這篇文章主要介紹了php實現文件與16進制相互轉換的方法,文中給出了詳細的示例代碼,需要的朋友可以參考借鑒,下面來一起看看吧。
    2017-02-02

最新評論