express mongodb 连接池

东风不度玉门 發表於 2019-11-24 22:16:00

因为网络上虽然有mongodb nodejs 连接池的教程，但是用的是已经过时的api，所以想出这个方法，分享一下
 
需要基础的express的知识http://www.expressjs.com.cn/
 
使用的是官方的mongodb驱动和generic-pool
<div class="cnblogs_code">
<pre>npm install --save mongodb generic-pool</pre>
</div>
 
当然我写的也是按照官方问档来写的，如果头比较铁的也可以直接去看（滑稽），这里给出链接，看完文章后也可以看一下官方文档
https://www.npmjs.com/package/generic-pool
https://docs.mongodb.com/ecosystem/drivers/node/
毕竟我写的博客也是中文的嘛。。。
 
创建连接池代码：
<div class="cnblogs_code">
<pre>const MongodbClient = require('mongodb').MongoClient;
const GenericPool = require('generic-pool');

const factory = {

create: function() {//创建链接 　　　　return MongodbClient.connect("mongodb://" + "localhost" + ":" + "27017", { useUnifiedTopology: true }); 　　　　//返回一个mongodb的client链接对象
},
destroy: function(client) {//销毁链接
 client.close();//关闭链接，这里需要注意，形参client就是上面我们创建的对象
}
}
//
const opts = {
max: 10,//最大链接数
min: 2//最小。。
}

const myPool = GenericPool.createPool(factory, opts);//就是在这里创建链接池

module.exports = myPool;//export给其他模块使用</pre>
</div>
 创建factory对象和opt对象，分别表示创建和销毁的方法与选项
 
使用方法，在这里我是使用了express的route，创建了一个路由user，当然这是express的知识，不讨论：
<div class="cnblogs_code">
<pre>const express = require('express');
const Router = express.Router();
const myPool = require('./db_pool');//这里的db_pool就是上面的代码文件

Router.get('/user', (req, res, next) => {
var name = req.query.name || '';//获得查询的参数

var queryObject = {}
if (name != '') {
 queryObject.name = name;
}

var resoursePro = myPool.acquire();//在这里请求一个连接池的连接，它返回的是一个promise对象，如果不明白的给个链接：https://developer.mozilla.org/zh-CN/docs/Web/JavaScript/Reference/Global_Objects/Promise
resoursePro.then((client) => { //这里的client就是上面我们在factory对象中create的返回值
 let cursor = client.db('dbname').collection('user').find(queryObject);//下面使用的就是常规操作啦，因为主要讲的连接池，就懒得写了...
 let somethign = cursor.toArray();
 somethign.then((result) => {
 // console.log(result);
 res.json(result);//响应查询的结果
 myPool.release(client).then(() => {//使用完了这个链接就要归还了啊
 console.log('release')
 });
 }).catch((err) => {
 myPool.release(client).catch((err) => {
 console.log(err)
 })
 })
})
})</pre>
</div>
  
来源：https://www.cnblogs.com/incredible-x/p/11924768.html

頁: [1]

琼殿技术论坛's Archiver

express mongodb 连接池