PHP實(shí)例
protected $listen = [
    'App\Events\BlogView' => [
      'App\Listeners\BlogViewListener',
    ],
  ];

PHP實(shí)例
php artisan event:generate

PHP實(shí)例
<?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 [];
  }
}

PHP實(shí)例
<?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;
     //先進(jìn)行判斷是否已經(jīng)查看過(guò)
    if (!$this->hasViewedBlog($post)) {
       //保留到數(shù)據(jù)庫(kù)
      $post->view_cache = $post->view_cache + 1;
      $post->save();
       //看過(guò)之后將保留到 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());
  }
}

PHP實(shí)例
<?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);
  }
}

PHP實(shí)例
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'];
  }
}

PHP實(shí)例
public function broadcastWith()
{
  return ['user_id' => $this->user_id];
}

PHP實(shí)例
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);
});

PHP實(shí)例
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);

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