JSON url을 NODE.JS로 구문 분석하고 SOCKET.IO로 최신 상태로 유지

Question

저는 node.js와 socket.io에 매우 익숙하며 외부 URL에서 JSON 배열을 읽는 방법을 알아 내려고합니다. 그것을 분석하고 메인 페이지에 표시하십시오. 그런 다음 socket.io를 사용하여 연결이 열린 상태를 유지하고 변경이 발생하면 JSON 객체를 최신 상태로 유지합니다.

이것은 지금까지 node.js.에 대한 것입니다.

var http = require("http"); 
var fs = require('fs'); 
var options = 'http://api.trakt.tv/user/watching.json/APIKEY/USERNAME'; 

var server = http.createServer(function(request, response){ 
    console.log('Connection'); 

http.get(options, function(res){ 
var data = ''; 

res.on('data', function (chunk){ 
    data += chunk; 
}); 

res.on('end',function(){ 
    var obj = JSON.parse(data); 
    console.log(obj); 
}) 

}); 
    response.end(); 
}); 

server.listen(8888); 

내가 로컬 호스트에 연결 : 8888 나는 "연결"을 선택한 다음 콘솔이 JSON 객체의 내용을 기록으로 콘솔 쇼를 참조하십시오. 이것은 내가 관리 할 수있는 한도 내입니다. 나는 여기, 지금은 문제를 이해하고, 감사하고

TIA 마크

Answer 1

좋아 도움 JSON 객체가 표시되는 것을 얻는 방법에 대한 포인터와 내 인덱스 페이지에 스타일과 최신으로 유지하는 것이 내 대답. 그것은 당신이 원하는 것을하기위한 진정한 "올바른 길"이 없기 때문에 약간의 충고가 될 것입니다. 그렇다면 우리는 WebSocket (또는 이전 브라우저에서 웹 소켓을 에뮬레이트 할 수있는 socket.io)을 사용하고자 할 것입니다.

현재 풀 코드는 괜찮을 지 모르겠지만 타임 아웃시 실행되도록 코드를 조정하여 최신 JSON을 너무 자주 가져오고 싶을 것입니다. /이 API에서 읽기 캐시를 듣고, 캐시를 작성하고 연결된 클라이언트에서 캐시를 공급 : 또한, 우리는이 별도의 다양한 움직이는 부분을 유지하려는

var http = require("http"); 
var fs = require('fs'); 
var url = 'http://api.trakt.tv/user/watching.json/APIKEY/USERNAME'; 
var cacheFile = '/path/to/cachefile'; 
var connectedSockets = []; 

function fetchJson() { 
    http.get(url, function(res) { 
     body = ''; 

     res.on('data', function(data) { 
      body += data; 
     }); 

     res.on('end', function() { 
      fs.writeFileSync(cacheFile, body); 
      setTimeout(fetchJson, 1000); // Fetch it again in a second 
     }); 
    }) 
} 

fetchJson(); // Start fetching to our JSON cache 

// Start watching our cache file 
fs.watch(cacheFile, function(event, filename) { 
    if(event == 'change') { 
     fs.readFile(cacheFile, function(data) { 
      connectedSockets.forEach(function(socket) { 
       socket.emit('data', JSON.parse(data)); 
      }); 
     }); 
    } 
}); 

// Now setup our socket server 
var io = require('socket.io').listen(8888); 
io.sockets.on('connection', function(socket) { 
    connectedSockets.push(socket); 
}); 

그렇게하지 여기서 disconnected 핸들을 사용하면 (connectedSockets 목록에서 연결이 끊어진 소켓이나 err'ed 소켓을 제거하고자 할 것입니다.), 실제로 실행하지는 않았지만, 어디로 향해야 할지를 알려줄 것입니다. 내가 대답을 해고하기 전에

var socket = io.connect('http://localhost:8888'); 
socket.on('data', function (data) { 
    // Data will contain your JSON object, do your DOM manip here 
});