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发送一个事件，事件名称为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 \App\Events\SomeEvent(3)); return "hello world"; });
测试：
启动redis
启动websocket
打开带有客户端代码的页面，可以看到websocket已经连接成功。
触发事件,打开另一个页面 localhost/event。
这时就可以发现，第一个页面的console中打印出了Object{user_id: 3}，说明广播成功。
您可能感兴趣的文章: