Socket IO получает данные с URL - PullRequest
Новая
       29

Socket IO получает данные с URL

0 голосов
/ 28 апреля 2011

Привет,

Я пытаюсь транслировать сообщения пользователям на основе данных, полученных с URL-адреса. Данные, возвращаемые из URL, будут json. Я очень новичок в node.js и socket.io, и у меня установлены node.js и socket.io. Я просто не уверен на 100% в том, как получить данные, которые мне нужны для передачи клиентам через URL. Что еще мне нужно?

Файл моего сервера server.js 

var http = require('http'),  
io = require('socket.io'), 
// Do I need another require here?    

server = http.createServer(function(req, res){ 
 // your normal server code 
 res.writeHead(200, {'Content-Type': 'text/html'}); 
 //res.end('<h1>Hello world</h1>'); 
});
server.listen(8080);

// socket.io 
var socket = io.listen(server); 
socket.on('connection', function(client){ 

  //I'm not sure where/how to get data from a URL
  function getMessages() {

    var request = messageClient.request("GET", "json.php", {"host": "myurl.com"});

    // Is this how I send the data to the client?
    socket.broadcast(request);

    //request.end();
  }

  setInterval(getMessages, 1000);

  client.on('message', function(){ … }) 
  client.on('disconnect', function(){ … }) 

});

Мой клиент 

// Load jQuery too
<script src="http://pathtojquery.js"></script> 
<script src="http://{node_server_url}/socket.io/socket.io.js"></script> 
<script> 
 var socket = new io.Socket({node_server_url}); 
 socket.connect();
 socket.on('connect', function(){ … }) 
 socket.on('message', function(data){
   // Use jquery to handle the json data here and display message to the clients
   // I can handle this part as long as 'data' is json

 }) 
 socket.on('disconnect', function(){ … }) 
</script>

1 Ответ

1 голос
/ 28 апреля 2011 
function getMessages() {
    http.get({ host: 'myurl.com', port: 80, path: 'json.php' }, function(response) {
        var data = "";
        response.on('data', function(chunk) {
            data += chunk;
        });
        response.on('end', function() {
            socket.broadcast(JSON.parse(data));
        });
    });
}

Документация модуля HTTP

...