Как лучше в expres.js передать объект?

Question

[Александр Литвинов]

День добрый! Необходимо проверять подписку subscribe на redis в разных частях приложения. Как лучше это реализовать? Стоит ли использовать Dependency Injection?
Код выглядит так

var redis = require("redis");
    var server = require('http').Server(app);
    var io = require('socket.io')(server);
    server.listen(3001);

    io.on('connection', function (socket) {
        const subscribe = redis.createClient();

        subscribe.subscribe('cool ch');
        subscribe.on("message", function (channel, message) {
            socket.emit('cool ch', message);
        });

        socket.on('message', function (msg) {
        });

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

    });

А примерно так выглядит код в другой части приложения.

subscribe.on("subscribe", function (channel, count) {
           redisClient.publish('cool ch', "I am sending a message.");
 });

Но для того что бы он работал, нужно как-то передать объект subscribe

Answer 1

[Алексей Павлов]

У вас много разных этих subscribe? На каждого клиента создаётся отдельный?
Может, лучше оттуда передать объект subscribe в инициализацию io?
Или не передавать, а на месте создать новый subscribe. Это же Redis - подсоединяйся к каналу и слушай.

Comments

[Александр Литвинов]

Да, на каждого клиента создается отдельный. Как можно передать в инициализацию io? Может глупый вопрос, только разбираюсь с нодой. Создавать новые объекты не хотелось бы.

[Алексей Павлов]

второй участок кода - это из express? То есть запрос приходит по http? Вот в обработчике этого запроса (первого от клиента) и создавать соединение у socket.io.
Обычно делается так - вновь присоединившемуся клиенту сразу создаётся специальный объект, и помещается в массив (или в ассоциативный массив - в объект). У этого объекта создаётся все необходимые свойства, в том числе и слушатель редиса.
Либо второй вариант - глобально цепляться к редису отдельным слушателем (как у вас сейчас), слушать сообщения из канала, а в сообщении указывать, какому клиенту сообщение адресовано. И уже по имени клиента извлечь объект этого клиента из массива и сделать с сообщением что надо.

[Александр Литвинов]

@lexxpavlov Спасибо! Ваш ответ мне помог. В итоге пришел к выводу, что redis в моем случае не сильно нужен. В итоге пришел к такому модулю

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

server.listen(3001);

module.exports = {

    emit: function (channel, message) {
        io.on('connection', function (socket) {
            socket.emit(channel, message);
        });
    },

    listen: function (callback) {
        io.on('connection', function (socket) {
            socket.on('message', function (msg) {
                callback(msg);
            });
        });

    }

};

а использую так

var io = require("../modules/io");
 io.emit('test', 'test test test');

Можете, что-нибудь сказать по этому коду? Любые замечания.

[Алексей Павлов]

Я как раз думал спросить, а нужен ли вам Redis :)
Не нравится код

emit: function (channel, message) {
        io.on('connection', function (socket) {
            socket.emit(channel, message);
        });
    },

получается, что при каждом вызове вашего метода emit будет навешан новый обработчик на сокет. А вам нужно вызывать именно внутренний emit. Если я правильно понял то, что вы хотите сделать.
То же самое и с listen.
А, нет, listen вы будете вызывать один раз и сразу передадите внутрь колбэк.
А вот для emit подразумевается несколько разных вызовов, ведь так? Для каждого вызова emit вы планируете отправлять сообщение?
Вы должны сохранять объект socket в свойства юзера:

var users = {};
io.on('connection', function (socket) {
    var user = new User(socket);
    users[user.id] = user;
});

А у объекта класса User сделать метод emit(ch, msg), который будет использовать сохранённый объект socket.

[Александр Литвинов]

@lexxpavlov Да, все верно. Насчет listen пока точно не придумал. Но скорее всего один раз буду вызывать. Понял свою ошибку. Пользователей у меня нет, скорее просто сессии. Если сохранять объект в свойстве юзера, как застраховаться от преждевременного вызова emit? Например: я вызываю где-то emit, а объект пользователя еще не создан или соединение еще не установилось

[Алексей Павлов]

а как вы вызовете emit, если ещё не создали объект?
Смотрите:
1) пользователь зашёл на сайт - ему выдалась обычная страничка по http.
2) На странице указан код соединения по socket.io. При первом соединении по сокету (io.on('connection')) socket.io создаёт для него отдельный объект socket, который нужно где-то сохранить.
3) создаётся объект User (хранилище состояния пользователя, он же может считаться сессией), в него и сохраняется объект связи с ним - socket.
4) И уже после этого ему можно посылать сообщение через emit и через broadcast.
А до пункта 2 нет возможности ничего отправить пользователю.

[Александр Литвинов]

@lexxpavlov Извиняюсь за столько вопросов) Думаю мне надо дальше самому немного вникнуть. Спасибо за ответы! Они мне сильно помогли

[Алексей Павлов]

@Sander_Li пожалуйста :)
Ещё один трюк, к которому я не сразу пришёл. Если вы создали модуль, то не обязательно везде тащить ссылку на него. Можно в любом месте сделать require("./module") и нода даст на него ссылку. При первом обращении модуль создастся и проинициализируется, а при каждом следующем require будет даваться ссылка на тот же инстанс модуля. Очень удобно.

[Александр Литвинов]

@lexxpavlov Да, спасибо :) Читал об этом, осталось собрать все воедино в голове