通过 redis 订阅动态 laravel 频道答案

【问题标题】：Subscribe to dynamic laravel channel via redis通过 redis 订阅动态 laravel 频道
【发布时间】：2017-03-27 08:33:52
【问题描述】：

我想在 larvel 的动态频道上广播一个事件。

为了在特定频道上广播，我尝试了this tutorial，一切正常。

这是我的活动：

class ChatNewMessage implements ShouldBroadcast
{
    use InteractsWithSockets, SerializesModels;

    public $targetUsers;
    public $message;

    public function __construct ($message)
    {
        $this->targetUsers = $message->chat->users->pluck('user_id');
        /*This is an array of user that are subscribed to a chat*/

        $this->message     = $message;
    }

    public function broadcastOn ()
    {
        $userChannels = [];
        foreach ($this->targetUsers as $id) {
            $userChannels[] = 'user-channel.' . $id;
        }

        return $userChannels;
    }
}

这是通过 user_id=5 获取用户发生的事件的 js 代码：

var socketURL = 'http://127.0.0.1:3000'; 

var socket = io(socketURL);
socket.on('user-channel.5:App\\Events\\ChatNewMessage', function (event) {
       alert(event.data);
});

这是运行节点的 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('user-channel.5', function (err, count) {});
redis.psubscribe('*', function(err, count) {});

redis.on('message', function (channel, message) {
    console.log('Message Received: ' + message);
    message = JSON.parse(message);
    io.emit(channel + ':' + message.event, message.data);
});

http.listen(3000, function () {
    console.log('Listening on Port 3000');
});

redis.on("error", function (err) {
    console.log(err);
});

如您所见，我使用redis.psubscribe('*', function(err, count) {}); 订阅了所有频道，例如user-channel.1、user-channel.2、user-channel.3 等。

但这不起作用。

当然，当我在 redis 上使用静态通道名称时，例如 redis.subscribe('user-channel.5', function (err, count) {});，一切正常。

我不知道是什么问题以及如何订阅动态创建的频道。

我正在使用 laravel 5.2。

【问题讨论】：

你找到解决办法了吗？
@MohammadTasneemFaizyab，我为我的问题添加了答案。

标签： php node.js laravel redis socket.io

【解决方案1】：

最后我在下面使用，一切正常：

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.psubscribe('*', function(err, count) {});

redis.on('pmessage', function(subscribed, channel, message) {
    console.log(channel);
    message = JSON.parse(message);
    io.emit(channel + ':' + message.event, message.data);
});

http.listen(3000, function () {
    console.log('Listening on Port 3000');
});

redis.on("error", function (err) {
    console.log(err);
});

【讨论】：