1

おそらく、関連する質問の回答を完全には理解していませんでした。私は長いポーリング、リバース ajax の概念を得ましたが、これは次のとおりです。

私の現在のセットアップは私のローカルユニットにあり、私はクライアントであり、私はサーバーです。サーバーへの接続を正常に確立でき、接続が確立されたらクライアントにメッセージを送り返すことができますが、別のシナリオが入ってきました。接続の確立後、サーバーがクライアントを継続的に更新するようにしたいだけです。簡単にするために、クライアントをサーバー時間で更新したいとします。そのため、分が変わるたびに、サーバーはクライアントに最新の時間を送信します (接続が既に確立されている場合)。

node.js と socket.io を使用しています。以下は私のコードです：

クライアント：

<!DOCTYPE html>  
<meta charset="utf-8" />  
<title>WebSocket Testing</title>  
<script src="/socket.io/socket.io.js"></script>

<script language="javascript" type="text/javascript">  
var socket = new io.connect("http://127.0.0.1:8080");
socket.on('connect', function(){

//  socket.on('news', function (data) {
//  socket.emit('my other event', { my: 'data' });


        socket.on("test",function(data){
            alert(data);
        });


    socket.onmessage =  function (event) {
        console.log(event.data);
    }

});
console.log(socket);
</script>  
<h2>WebSocket Test</h2>  
<div id="output"></div>  
</html>

サーバ：

var socketOptions = {
            transportOptions: {
                    'xhr-polling': {
                            closeTimeout: 20000000, //20 mins
                            timeout: 20000000  //20 mins
                    }
            }
    };

var app = require('http').createServer(handler)
  , url = require('url')
  , io = require('socket.io').listen(app,socketOptions)

  , fs = require('fs')

app.listen(8080);

function handler (req, res) {
    var path = url.parse(req.url).pathname;
  fs.readFile(__dirname + '/index.html',
  function (err, data) {
    if (err) {
    console.log("ERROR: "+err)
      res.writeHead(500);
      return res.end('Error loading index.html');
    }

  //  res.writeHead(200);
    //res.writeHead(200, {'Content-Type': path == 'json.js' ? 'text/javascript' : 'text/html'})
    res.writeHead(200, {'Content-Type': 'text/html'});
    console.log("THIS IS IT");
    res.end(data);
  });

}

console.log(io);

io.sockets.on('connection', function (socket) {
//  socket.send("testing lang kung nagsesend");
//  console.log("connection");
//  socket.emit('news', { hello: 'world' });
//  socket.on('my other event', function (data) {
//    console.log(data);
//  });


    socket.emit("test","Test connection message established,send and received");
});

サーバーコードはどうすればいいですか? ほとんどすべてのコード サンプルが php 形式であることがわかります。

4

1 に答える 1

1

コールバック内の関数を使用して setInterval を作成し、 が起動されてから数秒後に実行したいことを行いますconnection。あなたはこのようなものを探しています:

io.sockets.on('connection', function (socket) {
    setInterval(function(){
        // do a socket emit here to give data to client
    },1000);
}
于 2013-02-21T08:40:21.270 に答える