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) {

Похоже на опечатку!

Другие вопросы по тегам