2

我有一台服务器启动并运行，没有抛出任何错误。我正在从 mongodb 流式传输数据。当数据完成流式传输时，我想调用“关闭”，然后断开 mongo 数据库。

以下是我拥有的代码。当我尝试连接到服务器时，第一个请求成功，但任何其他请求都失败。

当我试图检查 mongodb 是否被断开时，我发现它不是。

你如何使用 amongoose.connection.close()以及它什么时候会失败？

var http = require('http')
  , url = require('url')
  , mongoose = require('mongoose')
  , Schema = mongoose.Schema
  , server, n;

server = http.createServer(function(request, response) {
  var path = url.parse(request.url).pathname.slice(0, 4);
  n = url.parse(request.url).pathname.slice(5);

  // connect to mongo
  mongoose.set('debug', true);
  mongoose.connect('localhost', 'lotsOfNumber');
  mongoose.connection.on('error', function(err) {
    console.error('connection error: ' + err);
  });

  mongoose.connection.on('open',function() {

    var stuff = mongoose.model('numbersHere', new Schema({serialNumber: Number}, {safe: true}));

    switch (path) {

      case '/slq':

        var stream = stuff.find({}).limit(1).skip(n).sort('field value').stream();

        stream.on('error', function(err) {
          console.error("Error trying to stream from collection:" + err);
        });

        stream.on('data', function(doc) {
          response.writeHead(200, {'Content-Type': 'text/plain'});
          response.write(doc.value.toString() + '\n', 'utf8');
          response.end();
        });

        stream.on('close', function() {
          mongoose.connection.close();
          mongoose.connection.on('close', function() {console.log('closed');});
        });

        break;

      default:
        console.log('nothing');
        mongoose.connection.close();
        break;
    }
  });
});

server.listen(8080);

任何帮助表示赞赏。

4

1 回答 1

8

我一直使用这样的模式：

mongoose.connect('localhost', 'lotsOfNumber');
...
mongoose.disconnect();

但是你不应该像你一样在每个请求上连接和断开连接。相反，在应用程序启动期间连接并在关闭期间断开连接。

mongoose.connect打开并发请求可以共享的连接池。

于 2012-11-02T21:53:14.353 回答