私は非常に基本的なノード アプリケーションをセットアップしています。計画では、誰でもサイトにアクセスして文字を押すと、カウンターがインクリメントされます。世界中の人々がカウンターを増やしているので、誰もがそのカウンターが上がるのを見ることができます。最初に設定した方法を除いて、ノードサーバーは各クライアントに毎秒20回接続しているため、非常に無駄です。
そのため、ノードサーバーがメッセージを送信するためにカウンターが増加している必要があるという条件を追加しました。しかし、私がそうすると、メッセージが実際にすべてのクライアントに到達することはなく、メッセージがクライアントに到達する方法は、明らかにランダムな順序で混乱します。
これは私の最初のノードアプリであり、まだコツをつかんでいます。誰かがこれで正しい方向に向けることができますか? おそらく、increment_time 関数に問題があります。
サーバー部分:
var http=require('http');
var io=require('socket.io');
var fs=require('fs');
var sockFile=fs.readFileSync('text');
server=http.createServer();
//2. get request, via port, http://localhost:8000
server.on('request', function(req, res){
console.log('request received');
res.writeHead(200, {'content-type':'text/html'});
res.end(sockFile);
});
//have server and socket listen to port 8000.
server.listen(8000);
var socket=io.listen(server);
//the lower the number the less chatty the debug becomes.
socket.set('log level', 1);
//initiate the counter.
counter=0;
counterp=0;
//3. on client connect.
//http://<address>/apps/press_k
socket.on('connection', function(socket){
console.log("Client connected.");
//increment counter on clients command.
socket.on('s_increment_counter',function(data){
counter++;
console.log('New counter:'+counter);
});
//send the counter to all clients if it has increased.
increment_time_continuously();
function increment_time(){
//this is the condition that is to limit how often node sends to the clients,
//but setting it on means the counter will be delivered in some erratic way
//to the clients.
//if(counter===counterp) {return;}
//send current counter to all clients.
console.log("passed the equals, now broadcast.");
//this part is clearly only sending to one of them.
socket.emit('c_display_counter', counter);
//client.broadcast.emit('c_display_counter', counter)
//client.send('Welcome client');
counterp=counter;
}
function increment_time_continuously(){setInterval(increment_time,50);}
});
関連するクライアント部分:
//client_to_server:
//-tell server to increment counter.
function s_increment_counter(){
socket.emit('s_increment_counter',{counter:0});
}
//server_to_client:
//-when server tells to display counter, display counter.
socket.on('c_display_counter',function(counter){
//counter=data["counter"];
k_counter_text.attr({"text":counter});
});