3

node.js と socket.io を使用して、リアルタイムの通知をユーザーにプッシュしています。ただし、現在、socket.ioコードで実行されたクエリ結果を送り返し、それをクライアントに送り返していますが、発生した変更についてソケットに知らせ、変更で更新するか、データベースを再クエリする必要があります新しい番号を確認し、それをクライアントに送信します。

たとえば、ユーザーが友達リクエストを受け取った場合、通知カウントが変更され、socket.io が新しい通知カウント番号をユーザーにプッシュするようにします。

app.js ファイルの socket.io コードは次のとおりです。

io.on('connection', function(socket) {
    var sessionID = socket.handshake.sessionID,
    session = new connect.middleware.session.Session({ sessionStore: sessionStore }, socket.handshake.session)
  console.log('socket: new ' + sessionID)
  socket.broadcast.emit('arpNewConn', session.passport.user)
       var intervalID = setInterval(function() {
    socket.handshake.session.reload(function() {
      socket.handshake.session.touch().save()
    })
    socket.emit('pulse', { heartbeat: new Date().toString(), timestamp: new Date().getTime() })
  }, 300 * 1000)


      socket.on('disconnect', function() {
      console.log('socket: dump ' + sessionID)
      socket.broadcast.emit('arpLostConn', session.passport.user)
      clearInterval(intervalID)
    })
      socket.emit('entrance', {message: 'Message works'});
      dbnotif.findOne(userID, function (err, user) {   
        if(err) throw err;
        notify = user.notifications;
        socket.emit('notify', {notific: notify});
      });
  });

クライアント側は次のとおりです。

div#CheckSocket

    script(src='http://localhost:3000/socket.io/socket.io.js')
    script.

        $(document).ready(function () {
            console.log('socket');
            var socket = io.connect('http://localhost:3000/');
            console.log('entered1');

            socket.on('entrance', function  (data) {
                console.log('entered');
                console.log(data.message);
            });

            socket.on('notify', function  (data) {
                console.log('noting');
                console.log(data.notific);
                if(data.notific !== 0)
                    $('.notifications').html(data.notific);
            });

            socket.on('reconnecting', function(data) {
                setStatus('reconnecting');
                console.log('entered2');
            });

            function setStatus(msg) {
                console.log('connection status: ' + msg);
                console.log('entered5');
            }

        });

ルート ファイルにフレンドを追加する例を次に示します。

exports.addContactPost = function(req, res, err) {
  async.waterfall([
        function(callback) {
            var success;
            var newFriend = new Friend ({
                userId: req.signedCookies.userid,
                friend_id: mongoose.Types.ObjectId(req.body.otherUser),
                friend_status: 1
            });
            newFriend.save(function(err){
                if(err) {
                    console.log(err);
                } else {
                    console.log("saved it");
                     success = true;
                }
            });
            callback(null, success)
        },
        function(success, callback) {
            //if(success === true) {
                var success2;
                var newFriend2 = new Friend ({
                    userId: mongoose.Types.ObjectId(req.body.otherUser),
                    friend_id: req.signedCookies.userid,
                    friend_status: 2
                });
                newFriend2.save(function(err){
                    if(err) {
                        res.send("request not received");
                    } else {
                        success2 = true;
                    }
                });
                callback(null, success2);
            //} else {
            //  res.send("error with request sent");
            //}

        },

        function(success2, callback) {
            console.log('callback3');
            //if(success2 === true) { 
                var success3;
                Notification.findOneAndUpdate({userId: mongoose.Types.ObjectId(req.body.otherUser)}, {
                        $inc: {notifications: 1}
                    }, function(err, notify) {
                        if(err) { 
                            res.send(err); 
                        } else {
                            console.log(notify);
                            if(notify.added_notifications === true) {
                            // enable mail and include general u have got a new request... do not include name because not storing it

                            }
                        }
                        success3 = true;
                        callback(null, success3);

        }],

    function(err, results) {
            res.json({response: true});
            console.log("Add successful");


    });
};

注: dbnotif は mongoose によって呼び出されるモデルであり、userID はファイルで使用できるグローバル変数です。

4

1 に答える 1

4

私は彼がこの質問をオフラインで解決するのを手伝いましたが、最終的に EventEmitter をプロキシとして使用することになりました。

// main.js

var EventEmitter = require('events').EventEmitter;
var emitter = new EventEmitter();

次に、ミドルウェアとして各リクエストに追加します。

// elsewhere in main.js

app.use(function(req, res, next) { 
  req.emitter = emitter;
  next();
});

次に、外部ルートファイルで：

// routes.js

exports.addContactPost = function(req, res, err) {
  req.emitter.emit( 'some-key', whatever, data, you, want );
};
于 2013-09-06T22:32:30.543 に答える