Skip to main content
Commonmark migration
ソース リンク

前提・実現したいこと

###前提・実現したいこと
socketsocket.ioとNode.jsを用いて、あるディレクトリにファイルが追加された時
その内容をイベントとしてクライアントに送るシステムを構築しています。

発生している問題・エラーメッセージ

###発生している問題・エラーメッセージ
下記下記該当のソースコードにあるようなコードを記述しているのですが
クライアントの接続を切断してもsocket.idが廃棄されず、今まで接続していたクライアント全てに飛ばしているような
挙動を示します。
例)3回ブラウザを更新すると、4回分のイベントが発行されているような挙動
どのように修正すれば、切断時にsocket.idが廃棄され、現在接続しているクライアントのみに
イベントを飛ばすようになるのでしょうか。

###該当のソースコード
JavaScript
//lib
var express = require('express')
var app = express();
var chokidar = require('chokidar');
var fs = require('fs');
var server = require ('http').Server(app);
var io = require('socket.io')(server);
var filepath = require('path');

該当のソースコード

JavaScript
//lib
var express = require('express')
var app = express();
var chokidar = require('chokidar');
var fs = require('fs');
var server = require ('http').Server(app);
var io = require('socket.io')(server);
var filepath = require('path');

let clients = {};

var watcher = chikidar.watch('./***/',{
    ignored:/[\/\\]\./,
    persistent:true,
    alwaysStat:true,
    }
});

app.get('/',req,res)=>{
   res.SendFile(__dirname + './***.html');
});
    
io.on('connection',(socket)=>{
    clients[socket.id]= socket;
    console.log(socket.id+'connected')
    watcher.on('add',function(path){
///fsでファイルを読む処理をしています。
    io.json.to(socket.id).emit(~~~);
});// watcher
socket.on('命令1',function(data){
    console.log(socket.id)
    console.log('命令1が来た')
///fsでファイルを消しています。
});
socket.on('disconnect',(reason)=>{
     delete clients;
     console.log(socket.id+'disconnected')
});
});

出力

###出力
例え例えば3回更新した時はこのように出力されます。

追記

###追記
上記上記コードを以下の様に変更したところ

出力1,2どちらも接続されている分しか出ませんでした。
例)2ブラウザで接続した際は、出力は2と出力
しかし、イベントを発火させた際、命令1が来たといった出力は変わらず今まで接続されていた
分出力されてしまいます。
###マルチポスト

マルチポスト

teratail

###前提・実現したいこと
socket.ioとNode.jsを用いて、あるディレクトリにファイルが追加された時
その内容をイベントとしてクライアントに送るシステムを構築しています。

###発生している問題・エラーメッセージ
下記該当のソースコードにあるようなコードを記述しているのですが
クライアントの接続を切断してもsocket.idが廃棄されず、今まで接続していたクライアント全てに飛ばしているような
挙動を示します。
例)3回ブラウザを更新すると、4回分のイベントが発行されているような挙動
どのように修正すれば、切断時にsocket.idが廃棄され、現在接続しているクライアントのみに
イベントを飛ばすようになるのでしょうか。

###該当のソースコード
JavaScript
//lib
var express = require('express')
var app = express();
var chokidar = require('chokidar');
var fs = require('fs');
var server = require ('http').Server(app);
var io = require('socket.io')(server);
var filepath = require('path');

let clients = {};

var watcher = chikidar.watch('./***/',{
    ignored:/[\/\\]\./,
    persistent:true,
    alwaysStat:true,
    }
});

app.get('/',req,res)=>{
   res.SendFile(__dirname + './***.html');
});
    
io.on('connection',(socket)=>{
    clients[socket.id]= socket;
    console.log(socket.id+'connected')
    watcher.on('add',function(path){
///fsでファイルを読む処理をしています。
    io.json.to(socket.id).emit(~~~);
});// watcher
socket.on('命令1',function(data){
    console.log(socket.id)
    console.log('命令1が来た')
///fsでファイルを消しています。
});
socket.on('disconnect',(reason)=>{
     delete clients;
     console.log(socket.id+'disconnected')
});
});

###出力
例えば3回更新した時はこのように出力されます。

###追記
上記コードを以下の様に変更したところ

出力1,2どちらも接続されている分しか出ませんでした。
例)2ブラウザで接続した際は、出力は2と出力
しかし、イベントを発火させた際、命令1が来たといった出力は変わらず今まで接続されていた
分出力されてしまいます。
###マルチポスト
teratail

前提・実現したいこと

socket.ioとNode.jsを用いて、あるディレクトリにファイルが追加された時
その内容をイベントとしてクライアントに送るシステムを構築しています。

発生している問題・エラーメッセージ

下記該当のソースコードにあるようなコードを記述しているのですが
クライアントの接続を切断してもsocket.idが廃棄されず、今まで接続していたクライアント全てに飛ばしているような
挙動を示します。
例)3回ブラウザを更新すると、4回分のイベントが発行されているような挙動
どのように修正すれば、切断時にsocket.idが廃棄され、現在接続しているクライアントのみに
イベントを飛ばすようになるのでしょうか。

該当のソースコード

JavaScript
//lib
var express = require('express')
var app = express();
var chokidar = require('chokidar');
var fs = require('fs');
var server = require ('http').Server(app);
var io = require('socket.io')(server);
var filepath = require('path');

let clients = {};

var watcher = chikidar.watch('./***/',{
    ignored:/[\/\\]\./,
    persistent:true,
    alwaysStat:true,
    }
});

app.get('/',req,res)=>{
   res.SendFile(__dirname + './***.html');
});
    
io.on('connection',(socket)=>{
    clients[socket.id]= socket;
    console.log(socket.id+'connected')
    watcher.on('add',function(path){
///fsでファイルを読む処理をしています。
    io.json.to(socket.id).emit(~~~);
});// watcher
socket.on('命令1',function(data){
    console.log(socket.id)
    console.log('命令1が来た')
///fsでファイルを消しています。
});
socket.on('disconnect',(reason)=>{
     delete clients;
     console.log(socket.id+'disconnected')
});
});

出力

例えば3回更新した時はこのように出力されます。

追記

上記コードを以下の様に変更したところ

出力1,2どちらも接続されている分しか出ませんでした。
例)2ブラウザで接続した際は、出力は2と出力
しかし、イベントを発火させた際、命令1が来たといった出力は変わらず今まで接続されていた
分出力されてしまいます。

マルチポスト

teratail

本文から 226 文字削除
ソース リンク
kishi-kun
  • 71
  • 3
  • 11

###試したこと
https://teratail.com/questions/97749
で回答頂いた通り、下記の様に変更した所Last few GCsが発生してしまいました。

///fsでファイルを読むだけです。
while(socket.connected){
io.json.to(socket.id).emit(~~~);
}
});// watcher
///

###追記
上記コードを以下の様に変更したところ

###試したこと
https://teratail.com/questions/97749
で回答頂いた通り、下記の様に変更した所Last few GCsが発生してしまいました。

///fsでファイルを読むだけです。
while(socket.connected){
io.json.to(socket.id).emit(~~~);
}
});// watcher
///

###追記
上記コードを以下の様に変更したところ

###追記
上記コードを以下の様に変更したところ

出力を記述
ソース リンク
kishi-kun
  • 71
  • 3
  • 11
let clients = {};

var watcher = chikidar.watch('./***/',{
    ignored:/[\/\\]\./,
    persistent:true,
    alwaysStat:true,
    }
});

app.get('/',req,res)=>{
   res.SendFile(__dirname + './***.html');
});
    
io.on('connection',(socket)=>{
    clients[socket.id]= socket;
    console.log(socket.id+'connected')
    watcher.on('add',function(path){
///fsでファイルを読む処理をしています。
    io.json.to(socket.id).emit(~~~);
});// watcher
socket.on('命令1',function(data){
    console.log(socket.id)
    console.log('命令1が来た')
///fsでファイルを消しています。
});
socket.on('disconnect',(reason)=>{
     delete clients;
     console.log(socket.id+'disconnected')
});
});

###出力
例えば3回更新した時はこのように出力されます。

    [Time] (socket.id1) connected
    [Time] (socket.id1) disconnected
    [Time] (socket.id2) connected
    [Time] (socket.id2) disconnected      
    [Time] (socket.id3) connected

この時にemitさせるとこのように出力されます

    [Time] (socket.id1)
    [Time] 命令1が来た
    [Time] (socket.id2)
    [Time] 命令1が来た
    [Time] (socket.id3)
    [Time] 命令1が来た
let clients = {};

var watcher = chikidar.watch('./***/',{
    ignored:/[\/\\]\./,
    persistent:true,
    alwaysStat:true,
    }
});

app.get('/',req,res)=>{
   res.SendFile(__dirname + './***.html');
});
    
io.on('connection',(socket)=>{
    clients[socket.id]= socket;
    watcher.on('add',function(path){
///fsでファイルを読む処理をしています。
    io.json.to(socket.id).emit(~~~);
});// watcher
socket.on('命令1',function(data){
    console.log('命令1が来た')
///fsでファイルを消しています。
});
socket.on('disconnect',(reason)=>{
     delete clients;
});
});
let clients = {};

var watcher = chikidar.watch('./***/',{
    ignored:/[\/\\]\./,
    persistent:true,
    alwaysStat:true,
    }
});

app.get('/',req,res)=>{
   res.SendFile(__dirname + './***.html');
});
    
io.on('connection',(socket)=>{
    clients[socket.id]= socket;
    console.log(socket.id+'connected')
    watcher.on('add',function(path){
///fsでファイルを読む処理をしています。
    io.json.to(socket.id).emit(~~~);
});// watcher
socket.on('命令1',function(data){
    console.log(socket.id)
    console.log('命令1が来た')
///fsでファイルを消しています。
});
socket.on('disconnect',(reason)=>{
     delete clients;
     console.log(socket.id+'disconnected')
});
});

###出力
例えば3回更新した時はこのように出力されます。

    [Time] (socket.id1) connected
    [Time] (socket.id1) disconnected
    [Time] (socket.id2) connected
    [Time] (socket.id2) disconnected      
    [Time] (socket.id3) connected

この時にemitさせるとこのように出力されます

    [Time] (socket.id1)
    [Time] 命令1が来た
    [Time] (socket.id2)
    [Time] 命令1が来た
    [Time] (socket.id3)
    [Time] 命令1が来た
追記
ソース リンク
kishi-kun
  • 71
  • 3
  • 11
読み込んでいます
本文に 64 文字追加
ソース リンク
kishi-kun
  • 71
  • 3
  • 11
読み込んでいます
kishi-kunによって削除が取り消された投稿
削除済み投稿 (投票者: kishi-kun
ソース リンク
kishi-kun
  • 71
  • 3
  • 11
読み込んでいます