laravel-5 - 使用 laravel、Socket 和 Redis 动态更改 channel

Question

!!! 服务器-套接字如何动态更改 channel

例如，当我使用/fire/1 广播时，我只想发送到/room/1。

目前它发送到/room/1、/room/2、/room/3 等。因为这里默认情况下，服务器上的所有内容都订阅了“test-channel”。我就是想不通。

var server = require('http').Server();

var io = require('socket.io')(server);

var Redis = require('ioredis');
var redis = new Redis();


io.on('connection', function(socket){
    console.log('New User Conected here');

 redis.subscribe('test-channel');

redis.on('message', function(subscribed ,channel, message) {
    console.log(channel);
    message = JSON.parse(message);

    socket.emit(channel + ':' + message.event, message.data);
});

socket.on('joinRoom', function(room ){

    console.log('Join in  this Room '+ room);
    socket.join(room);

    });

});
server.listen(3000);

    event | php


    public function broadcastOn()
    {

         return ['test-channel']; // static

    }

Answer 1

向您的广播事件添加一个属性，然后将其传递给构造函数。

class Message implements ShouldBroadcast{
    use SerializesModels;

    protected $channel;

    public function __construct($channel){
        $this->channel = $channel;
    }

    public function broadcastOn(){
       return [$this->channel];
    }
}

然后当你触发事件时，将 channel 传入:event(new Message($channel));