node.js - 我如何使用 yii2 和 redis 进行订阅？

Question

我想在 yii2 Controller 中使用一个方法来订阅 channel ，这样我就可以作为订阅的客户端接收实时更新。我正在使用 Redis 发布/订阅。

public function actionSubscribe(){
        Yii::$app->redis->executeCommand('SUBSCRIBE',
        ['notification'], 
        function($redis, $channel, $message){
                print('I just did it!!!!!!');               
        });
        return true;
}

我也在使用 nodeJs，下面是我的服务器端 nodeJs 代码。请问我做错了什么？

我从代码中提取了拒绝工作的这一部分。

        socket.on("message", function(channel, message) {
        console.log("New message: " + message + ". In channel: " + channel);
        socket.emit(channel, message);
    });

完整代码如下

var app = require('express')();
var server = require('http').Server(app);
var io = require('socket.io')(server);
var redis = require('redis');

server.listen(8890);

 io.on('connection', function (socket) {

    console.log("new client connected");

    var redisClient = redis.createClient();
    //RedisClient deliberately pegged because I want Yii2 php to do the 
    //subscription to the notification channel; not nodeJs.
    //redisClient.subscribe('notification');

    socket.on("message", function(channel, message) {
        console.log("New message: " + message + ". In channel: " + channel);
        socket.emit(channel, message);
    });

    socket.on('disconnect', function() {
       // redisClient.quit();
    });

}) ;

Answer 1

考虑到上面的代码，如果您将其创建为

，我认为您应该在以下代码部分使用 redisClient

**redisClient**.on("message", function(channel, message) {
        console.log("New message: " + message + ". In channel: " + channel);
        socket.emit(channel, message);
    });

这样actionSubscribe()使用redisClient来接收消息