소켓 io를 사용하여 업데이트를 얻으려면

Question

데이터베이스에서 실시간 업데이트를 받으려면 socket.io에서 사용하고 있습니다. 여기 내 코드입니다 :

var q = "SELECT * FROM notifications"; 
db.query(q, function(err, rows, fields) { 
    if(rows[0]) { 
    io.sockets.emit('newNotifications', rows[0]); 
    } 
}); 

의 작업,하지만 난 WHERE userid = "+myuserid+" 이 어떻게 할 수있는 질문을 추가 할? 나는이 코드로 이것을 시도했다 :

socket.on('connect', function() { 
socket.send({"myuserid":"1"}); 
console.log('connected'); 
}); 

감사합니다.

Answer 1

기본적으로 특정 사용자 소켓을 특정 소켓에 연결해야합니다. 어떻게하는지는 authentication을 어떻게 처리하는지에 달려 있습니다.

소켓에 사용자 ID가 연결되면 개별 알림을 받기위한 몇 가지 옵션이 있습니다. 가장 직접적인 것은 위에서 원하는대로 할 수있는 것입니다. 결과를 제한하는 조건으로 쿼리를 만듭니다. 소켓별로이 작업을 수행해야하므로 다음과 같은 것이 필요할 것이다. 그들이 분리하면

data.watchForNotification = function(userId, fn) { 
    // Please sanitize this and make sure you're not vulnerable to sql injection attacks 
    var q = "SELECT ... WHERE UserId = " + userId; 
    data.watchedUsers[userId] = setInterval(function() { 
    db.query(q, function(err, rows, fields) { 
     if(rows.[0]) { 
     fn(rows[0]); 
     } 
    }); 
    }, 10000); 
} 

data.stopWatching(userId) { 
    if(data.watchedUsers[userId]) { 
    clearInterval(data.watchedUsers[userId]); 
    delete data.watchedUsers[userId]; 
    } 
} 

io.on('connection', function(socket) { 
    // authenticate and set socket.userId 

    data.watchForNotifications(socket.userId, function(notification) { 
    socket.emit('notification', notification); 
    }); 

    socket.on('disconnect', function() { 
    data.stopWatching(socket.userId); 
    }); 
}); 

이 뜻을 설정 새로운 알림 10 초마다 확인하고 그들이 와서 연결된 소켓에 사람들을 보내드립니다 간격. 또한 해당 사용자의 데이터베이스 쿼리를 중지합니다. 여기에는 의사 코드와 추상화 작업이 많이 있지만, 어디를 가고 싶은지를 알려면 충분합니다.