5

これは私のアプリの構成です

app.js

//SERVER
var server = app.listen(3000, function(){
    console.log("Express server listening on port %d in %s mode", app.get('port'),
    app.settings.env);
});
//SOCKET.IO
var io = require('./socket.io').listen(server)

/socketio

var socketio = require('socket.io')

module.exports.listen = function(app)
{
    io = socketio.listen(app);
    io.configure('development',function()
    {
            //io.set('transports', ['websocket', 'xhr-polling']);
            //io.enable('log');
    });
    io.configure('production',function()
    {
        io.enable('browser client minification');  // send minified client
        io.enable('browser client etag');          // apply etag caching logic based on version number
        io.set('log level', 1);                    // reduce logging
        io.set('transports', [                     // enable all transports (optional if you want flashsocket)
            'websocket'
          , 'flashsocket'
          , 'htmlfile'
          , 'xhr-polling'
          , 'jsonp-polling'
        ]);
    });
    io.sockets.on('connection', function (socket)
    {
        console.log("new connection: "+socket.id);
        socket.on('disconnect',function(){console.log("device "+socket.id+" disconnected");});

        socket.emit('news', { hello: 'world' });
        socket.on('reloadAccounts',function(data)
        {
            var accounts=['account1','account2']
            socket.emit('news',accounts)
        });
    });
    return io
}

/ルート

    exports.newAccount=function(fields,callback)//localhost:3000/newAccountForm
    {
//... bla bla bla config db connection bla bla bla
            db.collection('accounts').insert(fields,function(err,result)
            {
                if(err)
                {
                    console.warn(err);
                    db.close();
                    return callback(err,null);
                }else{
                    if(result)
                    {
                        db.close();
                        return callback(null,result);
                                socket.emit('new account created',result) // i want to emit a new event when any user create an account

                    }else{
                        db.close();
                        return callback('no se consigue resultado',null);
                    }
                }
            })
        });
    }

ルートファイルからsocket.ioでイベントを発行する方法は?

4

1 に答える 1

2

最初に、新しい情報を送信するソケットを決定する必要があります。それらすべて (アプリに接続しているすべての人) の場合は、io.sockets.emit を使用するだけで簡単です。

ファイルの の後にどこかに./socket.io追加します。次に、routes ファイルで、次のように発行できます。exports.sockets = io.sockets;io = socketio.listen(app);

var socketio = require('./socket.io');
socketio.sockets.emit('new account created', result);

送信先のソケット ID がわかっている場合は、次のようにできます。

var socketio = require('./socket.io');
socketio.sockets.sockets[socketId].emit('new account created', result);

Express セッション ID でソケットを選択することもできます。

最初に、承認時にセッション ID をソケットにアタッチする必要があります。

io.set('authorization', function (data, accept) {
    // check if there's a cookie header
    if (data.headers.cookie) {
        // if there is, parse the cookie
        data.cookie = cookie.parse(data.headers.cookie);
        // note that you will need to use the same key to grad the
        // session id, as you specified in the Express setup.
        data.sessionID = data.cookie['express.sid'];
    } else {
       // if there isn't, turn down the connection with a message
       // and leave the function.
       return accept('No cookie transmitted.', false);
    }
    // accept the incoming connection
    accept(null, true);
});

次に、セッション ID を持つソケットを選択できます。

var socketio = require('./socket.io');
var sockets = socketio.sockets.forEach(function (socket) {
    if (socket.handshake.sessionID === req.sesssionID)
        socket.emit('new account created', result);
});

また、セッション ストアにクエリを実行し、上記の方法を使用して、クエリに一致した sessionId を持つソケットにイベントを発行することもできます。

于 2014-02-04T11:48:44.897 に答える