一.mongoDB中的连接池
刚上手MongoDB，在做应用时，受以前使用关系型数据库的影响，会考虑数据库连接池的问题！
关系型数据库中，我们做连接池无非就是事先建立好N个连接(connection)，并构建成一个连接池(connection pool)，提供去连接和归还连接等操作。
而在MongoDB中，我们先来看看怎么进行操作，以insert为例：
Mongo m =new Mongo("localhost" ,27017 );
DB db = m.getDB("mydb" );
//get collection
DBCollection coll = db.getCollection("testCollection")
//insert
BasicDBObject doc =new BasicDBObject();
...
coll.insert(doc);
[伪代码]
如果套用以前的经验，可能会想偏，引用官方文档的一句话可能会豁然开朗。
Note: The Mongo object instance actually represents a pool of connections to the database; you will only need one object of class Mongo even with multiple threads. See the concurrency doc page for more information.
The Mongo class is designed to be thread safe and shared among threads. Typically you create only 1 instance for a given DB cluster and use it across your app. If for some reason you decide to create many mongo intances, note that:
all resource usage limits (max connections, etc) apply per mongo instance
to dispose of an instance, make sure you call mongo.close() to clean up resources
mongo实例其实已经是一个现成的连接池了，而且线程安全。这个内置的连接池默认初始了10个连接，每一个操作(增删改查等)都会获取一个连接，执行操作后释放连接。
二.连接池的重要参数
内置连接池有多个重要参数，分别是：
connectionsPerHost：每个主机的连接数
threadsAllowedToBlockForConnectionMultiplier： 线程队列数，它以上面connectionsPerHost值相乘的结果就是线程队列最大值。如果连接线程排满了队列就会抛出“Out of semaphores to get db”错误。
maxWaitTime:最大等待连接的线程阻塞时间
connectTimeout：连接超时的毫秒。0是默认和无限
socketTimeout：socket超时。0是默认和无限
autoConnectRetry：这个控制是否在一个连接时，系统会自动重试
其设置方式如下：
MongoOptions opt = mongo.getMongoOptions();
opt.connectionsPerHost =10 ;//poolsize
opt.threadsAllowedToBlockForConnectionMultiplier =10;
//其他参数类似
详情参考mongoDB API：
Field Summary
boolean
int
int
Mongo instances created with these options.
boolean
boolean
long
int
boolean
true the driver will use a WriteConcern of WriteConcern.SAFE for all operations.
boolean
Deprecated. Replaced in MongoDB 2.0/Java Driver 2.7 with ReadPreference.SECONDARY
boolean
Socket.setKeepAlive(boolean) Default
is false.
int
Socket.setSoTimeout(int) Default
is 0 and means no timeout.
int
int
int
三.连接池实践
package com.bts.dao.mongodb;
import java.net.UnknownHostException;
import com.bts.util.ConfTool;
import com.mongodb.DB;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
import com.mongodb.MongoOptions;
/**
*
@author huangfox
*
@data 2012-4-1
*
@email huangfox009@126.com
*
@desc
*/
public class MongoManager
{
private static Mongo
mongo =null;
private MongoManager()
{
}
/**
*
根据名称获取DB，相当于是连接
*
*
@param dbName
*
@return
*/
public static DB
getDB(String dbName) {
if (mongo
==null)
{
//
初始化
init();
}
return mongo.getDB(dbName);
}
/**
*
初始化连接池，设置参数。
*/
private static void init()
{
String
confFilePath ="";
ConfTool
conf =new ConfTool(confFilePath);
String
host = conf.getValue("host");//
主机名
int port
=new Integer(conf.getValue("port"));//
端口
int poolSize
=new Integer(conf.getValue("poolSize"));//
连接数量
int blockSize
=new Integer(conf.getValue("blockSize"));//
等待队列长度
//
其他参数根据实际情况进行添加
try {
mongo
=new Mongo(host,
port);
MongoOptions
opt = mongo.getMongoOptions();
opt.connectionsPerHost
= poolSize;
opt.threadsAllowedToBlockForConnectionMultiplier
= blockSize;
}catch (UnknownHostException
e) {
//
log error
}catch (MongoException
e) {
//
log error
}
}
}
MongoDB中的连接池
参见 http://www.cnblogs.com/huangfox/archive/2012/04/01/2428947.html
SpringBoot 整合mongoDB并自定义连接池
SpringBoot 整合mongoDB并自定义连接池 得力于SpringBoot的特性,整合mongoDB是很容易的,我们整合mongoDB的目的就是想用它给我们提供的mongoTemplate,它 ...
node-mysql中的连接池代码学习
node-mysql是一个node.js下的mysql驱动,前段时间在处理连接池的问题上遇到了连接不释放的疑难杂症,虽已解决,但仍需总结经验避免下次重蹈覆辙.下面是node-mysql中的连接池的部分 ...
Mybatis中的连接池
Mybatis中DataSource的存取 MyBatis是通过工厂模式来创建数据源DataSource对象的,MyBatis定义了抽象的工厂接口:org.apache.ibatis.datasour ...
WebSphere中数据源连接池太小导致的连接超时错误记录
WebSphere中数据源连接池太小导致的连接超时错误记录. 应用连接超时错误信息: [// ::: CST] webapp E com.ibm.ws.webcontainer.webapp.WebA ...
使用MongoDB 2.6 C++驱动中的连接池
.post p{text-indent: 2em;} MongoDB2.6的CXX驱动(mongo-cxx-driver-26compat),内置包含了数据库连接池,方便管理数据库连接,但是官方文档说 ...
在Tomcat中配置连接池和数据源
1.DataSource接口介绍 (1)DataSource 概述 JDBC1.0原来是用DriverManager类来产生一个对数据源的连接.JDBC2.0用一种替代的方法,使用DataSource ...
Spring框架中获取连接池的几种方式
什么是数据库连接池? 数据库连接池是一种关键的有限的昂贵的资源,对数据库连接的管理能显著影响到整个应用程序的伸缩性和健壮性,影响到程序的性能指标.数据库连接池就是用来解决这些问题而提出的. 数据库连接 ...
JSP(Servlet)中从连接池获取连接
1) 建立连接. 2) 执行SQL. 3) 处理结果. 4) 释放资源. Connection pool:连接池 DataSource: LDAP ( Light directory access p ...
随机推荐
我的Markdown笔记
一片简单的Markdown笔记,共8项,基本上满足Markdown文档的编写(表格不建议用Markdown),每项上半部分是源码,下半部分是效果图片. 标题 段落 列表 强调 分割线 代码 连接 图片 ...
JAVA Web day02--- Android小白的第二天学习笔记
CSS(美工部分知识,了解) 1. CSS概述 1.1.CSS是什么? * CSS 指层叠样式表 样式表:存储样式的地方 层叠:一层一层叠加 高大富有帅气人 1.2.CSS有什么作用? *CSS就是用 ...
Buffer Overflow Study
-- These days I learned and studied buffer overflow. I like to write on the paper and it can keep sy ...
Nikola的5项依赖注入法则
本篇文章来自对 Nikola Malovic 博客文章
weiapi 获取项目根目录
无法使用: Server.Map("~"); Server.Map("~/"); Server.Map("./"); Server.Map( ...
python爬去电影天堂恐怖片+游戏
1.爬去方式python+selenium 2.工作流程 selenium自动输入,自动爬取,建立文件夹,存入磁力链接到记事本 3.贴上代码 #!/usr/bin/Python# -*- coding ...
webpack打包优化之外部扩展externals的实际应用
目录 前言 externals定义 用法 string array object function regex 实际案例 打包时间 打包之后包的大小 浏览器加载 需要注意 参考 前言 使用vue-cl ...
webpack入门教程--1
首先说什么是webpack:Webpack 是一个前端资源加载/打包工具.它将根据模块的依赖关系进行静态分析,然后将这些模块按照指定的规则生成对应的静态资源. 然后因为webpack有不同的版本,所以 ...
In-App Purchase iap 内付费 二次验证代码 (java 服务器端)
参考网址:https://blog.csdn.net/a351945755/article/details/22919533 package com.yichangmao.buyVerify.Comm ...
CoreFoundation对象的内存管理
近来没什么新项目做,想学习一些swift开源项目,看了几个文件感觉有点懵,可能水平还没达到,等用到具体内容的时候再去仔细看吧. 关于现在的项目,想想单元测试还可以完善一下,就在framwork工程中写 ...