Laravel с Socket/Redis - не работает маршрут частного канала
Я вроде застрял в вещательных маршрутах. Я установил сервер сокетов с Redis и настроил его с Laravel. На общедоступном канале все работает нормально, но когда дело доходит до частного канала или канала присутствия, он каким-то образом обходит маршруты вещания Laravel. Не могу понять, как и почему.
Я прикрепил ссылку на репо, чтобы вы тоже могли ее изучить. Плюс некоторые быстрые биты также ниже.
https://github.com/bilahdsid/socket-laravel/tree/socket
TestEvent.php
class TestEvent implements ShouldBroadcast
{
use Dispatchable, InteractsWithSockets;
/**
* Create a new event instance.
*
* @return void
*/
public $data;
public function __construct()
{
$this->data = array(
'power'=> '10'
);
}
public function broadcastOn()
{
return new PrivateChannel('test-channel1');
}
public function broadcastWith()
{
return $this->data;
}
}
server.js
var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);
var Redis = require('ioredis');
var redis = new Redis();
redis.subscribe('private-test-channel1', function(err, count) {
console.log(err);
});
redis.on('connection',function (socket,channel) {
console.log(socket+''|+channel);
});
redis.on('message', function(channel, message) {
console.log('Message Recieved: ' + message);
message = JSON.parse(message);
io.emit(channel + ':' + message.event, message.data);
});
http.listen(3000, function(){
console.log('Listening on Port 3000');
});
io.on('connection', function(socket){
console.log('a user connected');
});
маршруты / веб-- для стрельбы
Route::get('/', function () {
return view('home');
});
Route::get('fire', function () {
// this fires the event
broadcast(new App\Events\TestEvent());
return "event fired";
});
маршруты / канал.php - нижняя строка не работает - главная проблема
Broadcast::channel('private-test-channel', function ($user, $id) {
echo '1111'; exit;
return (int) $user->id === (int) $id;
});
Благодарю.
0 ответов
Насколько я понимаю, вы определяете канал с именем: test-channel1
:
public function broadcastOn()
{
return new PrivateChannel('test-channel1');
}
но в routes/channels.php
:
Broadcast::channel('private-test-channel', function ($user, $id) {
Похоже на опечатку!