RethinkDB 和 Node.js/Express - 为并行查询打开多个连接？

Posted 2023-03-25

技术标签:

【中文标题】RethinkDB 和 Node.js/Express - 为并行查询打开多个连接？【英文标题】：RethinkDB and Node.js/Express - Opening multiple connections for parallel queries? 【发布时间】：2015-09-05 02:49:43 【问题描述】：

有没有比每个请求打开多个连接更好的方法来使用 RethinkDB 节点驱动程序运行并行查询？或者这实际上是解决我需要的好方法吗？我宁愿远离连接池/第三方包。有问题的应用程序有一个包含包装 RethinkDB 查询的函数的单例。这些函数处理创建和关闭连接。这种模式允许我以最小的开销在多个路由器中要求数据库服务，而不必知道每个请求。人为的例子来解释被查询的数据可能是多么不相关：

数据库.js

var r = require('rethinkdb');

module.exports = 

    getApples: function(callback) 
        r.connect(/* config */)
            .then(function(conn)
                r.db('fruitDatabase').table('apples').run(conn)
                    .then(function(cursor)
                        return cursor.toArray();
                    )
                    .then(function(apples)
                        return callback(null, apples);
                    )
                    .finally(function()
                        return conn.close();
                    );
            );
    ,
    getPotatoes: function(callback) 
        r.connect(/* config */)
            .then(function(conn)
                r.db('vegetableDatabase').table('potatoes').run(conn)
                    .then(function(cursor)
                        return cursor.toArray();
                    )
                    .then(function(potatoes)
                        return callback(null, potatoes);
                    )
                    .finally(function()
                        return conn.close();
                    );
            );
    
;

现在，我需要创建一个显示所有苹果和所有土豆的页面/端点，因此我目前在我的页面路由器中通过 async.parallel 调用这两个函数：

pages.js

var pages = require('express').Router(),
    async = require('async'),
    db = require('./database');

pages.route('/food')
    .get(function(req, res, next)
        async.parallel(
            apples: db.getApples,
            potatoes: db.getPotatoes
        , function(err, data)
            if(err) return next(err);

            res.render('food',
                
                    apples: data.apples,
                    potatoes: data.potatoes
                );
        );
    );

想法？如果并行打开 4 个连接（或更多）会怎样？

【问题讨论】：

【参考方案1】：

如果你等不及官方驱动获取连接池，你也可以使用中间件为每个请求打开一个连接，如官方文档中的this example：

app.use(createConnection);                      // Create a RethinkDB connection

function createConnection(req, res, next) 
    r.connect(config.rethinkdb, function(error, conn) 
        if (error) 
            handleError(res, error);
        
        else 
            // Save the connection in `req`
            req._rdbConn = conn;
            // Pass the current request to the next middleware
            next();
        
    );

【讨论】：

【参考方案2】：

我认为 RethinkDB 可以很好地处理许多并行连接。它也可能更容易使用。如果大家使用共享连接，我们必须处理连接断开时重新尝试连接，并且必须确保它在请求或服务器的生命周期中是开放的。

这个 RethinkDB 驱动程序https://github.com/neumino/rethinkdbdash 在自己的连接上运行每个查询。