0

我正在使用 node.js、express.js、socket.io 等所有东西的当前版本...我正在尝试连接到一个服务器，该服务器的唯一目的只是发送文本，然后将其发送到通过连接的 Web 客户端套接字.io。文本只是具有标准行结尾的字符串，最大数据速率约为 1024 字节/秒。我的代码，核心位，是这样的

var express = require('express')
  , app = express()
  , routes = require('./routes')
  , user = require('./routes/user')
  , server = require('http').createServer(app)
  , io = require('socket.io').listen(server)
  , path = require('path')
  , dataSourcePort = 5000
  , host = "10.0.1.32"
  , dataStream = require('net').createConnection(dataSourcePort, host);

dataStream.setEncoding('utf8');

io.sockets.on('connection', function (socket) {
    dataStream.on('data',function(data){
        socket.emit("stuff",data);
    });  
  });

app.configure(function(){
  app.set('port', process.env.PORT || 3000);
  app.set('views', __dirname + '/views');
  app.set('view engine', 'jade');
  app.use(express.favicon());
  app.use(express.logger('dev'));
  app.use(express.bodyParser());
  app.use(express.methodOverride());
  app.use(app.router);
  app.use(express.static(path.join(__dirname, 'public')));
});

app.configure('development', function(){
  app.use(express.errorHandler());
});

app.get('/', routes.index);
app.get('/users', user.list);

server.listen(app.get('port'), function(){
  console.log("Express server listening on port " + app.get('port'));
});

这一切都很好而且很花哨，但是每隔一段时间它就会挂起，因为数据停止发送给客户端。我假设缓冲区被塞满了沿线的某个地方，但不确定。有没有更好的方法来做到这一点并避免填充部分？

4

1 回答 1

0

我看到的主要问题是您永远不会取消绑定您的data处理程序，因此当人们连接和断开连接时，您将累积data侦听器和内存使用量，并浪费资源尝试将数据发送到断开连接的套接字。

io.sockets.on('connection', function (socket) {
  function ondata(data){
    socket.emit("stuff",data);
  }

  function ondisconnect(){
    dataStream.off('data', ondata);
    socket.off('disconnect', ondisconnect);
  }

  dataStream.on('data', ondata);
  socket.on('disconnect', ondisconnect);
});
于 2013-02-15T03:04:11.480 回答