MongoDB -- MongoClient连接池用法

2024-05-25 12:58
文章标签 用法 连接池 mongodb mongoclient

本文主要是介绍MongoDB -- MongoClient连接池用法，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

主要的调整在于2.10.0版本中引入了MongoClient类，同时在其API中也说明了Mongo类会在将来的版本中被MongoClient替换（Note: This class has been superseded by MongoClient, and may be deprecated in a future release.）。故在这次调整中，也对原先的Mongodb部分做了相应的修改。

MongoClient被设计成线程安全、可以被多线程共享的。通常访问数据库集群的应用只需要一个实例，所以这次调整我们设计成单例形式。如果出于某些原因，你决定使用多个实例，请注意：所有资源使用限制（最大连接数等等）对每个MongoClient都适用；销毁一个实例时，请确认调用MongoClient.close()方法来清理资源。

下面给出相关的代码：

    /** * 项目名：SpiderCrawler * 文件名：MongoDBDao.java * 作者：zhouyh * 时间：2014-8-30 下午03:46:55 * 描述：TODO(用一句话描述该文件做什么)  */  package com.newsTest.dao;  import java.util.ArrayList;  import com.mongodb.DB;  import com.mongodb.DBCollection;  import com.mongodb.DBObject;  /** * 类名： MongoDBDao * 包名： com.newsTest.dao * 作者： zhouyh * 时间： 2014-8-30 下午03:46:55 * 描述： TODO(这里用一句话描述这个类的作用)  */  public interface MongoDBDao {  /** *  * 方法名：getDb * 作者：zhouyh * 创建时间：2014-8-30 下午03:53:40 * 描述：获取指定的mongodb数据库 * @param dbName * @return */  public DB getDb(String dbName);  /** *  * 方法名：getCollection * 作者：zhouyh * 创建时间：2014-8-30 下午03:54:43 * 描述：获取指定mongodb数据库的collection集合 * @param dbName    数据库名 * @param collectionName    数据库集合 * @return */  public DBCollection getCollection(String dbName, String collectionName);  /** *  * 方法名：inSert * 作者：zhouyh * 创建时间：2014-8-30 下午04:07:35 * 描述：向指定的数据库中添加给定的keys和相应的values * @param dbName * @param collectionName * @param keys * @param values * @return */  public boolean inSert(String dbName, String collectionName, String[] keys, Object[] values);  /** *  * 方法名：delete * 作者：zhouyh * 创建时间：2014-8-30 下午04:09:00 * 描述：删除数据库dbName中，指定keys和相应values的值 * @param dbName * @param collectionName * @param keys * @param values * @return */  public boolean delete(String dbName, String collectionName, String[] keys, Object[] values);  /** *  * 方法名：find * 作者：zhouyh * 创建时间：2014-8-30 下午04:11:11 * 描述：从数据库dbName中查找指定keys和相应values的值 * @param dbName * @param collectionName * @param keys * @param values * @param num * @return */  public ArrayList<DBObject> find(String dbName, String collectionName, String[] keys, Object[] values, int num);  /** *  * 方法名：update * 作者：zhouyh * 创建时间：2014-8-30 下午04:17:54 * 描述：更新数据库dbName，用指定的newValue更新oldValue * @param dbName * @param collectionName * @param oldValue * @param newValue * @return */  public boolean update(String dbName, String collectionName, DBObject oldValue, DBObject newValue);  /** *  * 方法名：isExit * 作者：zhouyh * 创建时间：2014-8-30 下午04:19:21 * 描述：判断给定的keys和相应的values在指定的dbName的collectionName集合中是否存在 * @param dbName * @param collectionName * @param keys * @param values * @return */  public boolean isExit(String dbName, String collectionName, String key, Object value);  } 
/*** 项目名：SpiderCrawler* 文件名：MongoDBDaoImpl.java* 作者：zhouyh* 时间：2014-8-30 下午04:21:11* 描述：TODO(用一句话描述该文件做什么) */
package com.newsTest.dao.impl;import java.net.UnknownHostException;
import java.util.ArrayList;import com.newsTest.dao.MongoDBDao;
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientOptions;
import com.mongodb.MongoException;
import com.mongodb.WriteResult;/*** 类名： MongoDBDaoImpl* 包名： com.newsTest.dao.impl* 作者： zhouyh* 时间： 2014-8-30 下午04:21:11* 描述： TODO(这里用一句话描述这个类的作用) */
public class MongoDBDaoImpl implements MongoDBDao{/*** MongoClient的实例代表数据库连接池，是线程安全的，可以被多线程共享，客户端在多线程条件下仅维持一个实例即可* Mongo是非线程安全的，目前mongodb API中已经建议用MongoClient替代Mongo*/private MongoClient mongoClient = null;/*** * 私有的构造函数* 作者：zhouyh*/private MongoDBDaoImpl(){if(mongoClient == null){MongoClientOptions.Builder build = new MongoClientOptions.Builder();        build.connectionsPerHost(50);   //与目标数据库能够建立的最大connection数量为50build.autoConnectRetry(true);   //自动重连数据库启动build.threadsAllowedToBlockForConnectionMultiplier(50); //如果当前所有的connection都在使用中，则每个connection上可以有50个线程排队等待/** 一个线程访问数据库的时候，在成功获取到一个可用数据库连接之前的最长等待时间为2分钟* 这里比较危险，如果超过maxWaitTime都没有获取到这个连接的话，该线程就会抛出Exception* 故这里设置的maxWaitTime应该足够大，以免由于排队线程过多造成的数据库访问失败*/build.maxWaitTime(1000*60*2);build.connectTimeout(1000*60*1);    //与数据库建立连接的timeout设置为1分钟MongoClientOptions myOptions = build.build();       try {//数据库连接实例mongoClient = new MongoClient("127.0.0.1", myOptions);          } catch (UnknownHostException e) {// TODO 这里写异常处理的代码e.printStackTrace();} catch (MongoException e){e.printStackTrace();}}}/********单例模式声明开始，采用饿汉式方式生成，保证线程安全********************///类初始化时，自行实例化，饿汉式单例模式private static final MongoDBDaoImpl mongoDBDaoImpl = new MongoDBDaoImpl();/*** * 方法名：getMongoDBDaoImplInstance* 作者：zhouyh* 创建时间：2014-8-30 下午04:29:26* 描述：单例的静态工厂方法* @return*/public static MongoDBDaoImpl getMongoDBDaoImplInstance(){return mongoDBDaoImpl;}/************************单例模式声明结束*************************************/@Overridepublic boolean delete(String dbName, String collectionName, String[] keys,Object[] values) {DB db = null;DBCollection dbCollection = null;if(keys!=null && values!=null){if(keys.length != values.length){   //如果keys和values不对等，直接返回falsereturn false;}else{try {db = mongoClient.getDB(dbName); //获取指定的数据库dbCollection = db.getCollection(collectionName);    //获取指定的collectionName集合BasicDBObject doc = new BasicDBObject();    //构建删除条件WriteResult result = null;  //删除返回结果String resultString = null;for(int i=0; i<keys.length; i++){doc.put(keys[i], values[i]);    //添加删除的条件}result = dbCollection.remove(doc);  //执行删除操作resultString = result.getError();if(null != db){try {db.requestDone();   //请求结束后关闭dbdb = null;} catch (Exception e) {// TODO: handle exceptione.printStackTrace();}}return (resultString!=null) ? false : true; //根据删除执行结果进行判断后返回结果} catch (Exception e) {// TODO: handle exceptione.printStackTrace();} finally{if(null != db){db.requestDone();   //关闭dbdb = null;}}}}return false;}@Overridepublic ArrayList<DBObject> find(String dbName, String collectionName,String[] keys, Object[] values, int num) {ArrayList<DBObject> resultList = new ArrayList<DBObject>(); //创建返回的结果集DB db = null;DBCollection dbCollection = null;DBCursor cursor = null;if(keys!=null && values!=null){if(keys.length != values.length){return resultList;  //如果传来的查询参数对不对，直接返回空的结果集}else{try {db = mongoClient.getDB(dbName); //获取数据库实例dbCollection = db.getCollection(collectionName);    //获取数据库中指定的collection集合BasicDBObject queryObj = new BasicDBObject();   //构建查询条件for(int i=0; i<keys.length; i++){   //填充查询条件queryObj.put(keys[i], values[i]);}               cursor = dbCollection.find(queryObj);   //查询获取数据int count = 0;if(num != -1){  //判断是否是返回全部数据，num=-1返回查询全部数据，num!=-1则返回指定的num数据while(count<num && cursor.hasNext()){resultList.add(cursor.next());count++;}return resultList;}else{while(cursor.hasNext()){resultList.add(cursor.next());}return resultList;}} catch (Exception e) {// TODO: handle exception} finally{              if(null != cursor){cursor.close();}if(null != db){db.requestDone();   //关闭数据库请求}}}}return resultList;}@Overridepublic DBCollection getCollection(String dbName, String collectionName) {// TODO Auto-generated method stubreturn mongoClient.getDB(dbName).getCollection(collectionName);}@Overridepublic DB getDb(String dbName) {// TODO Auto-generated method stubreturn mongoClient.getDB(dbName);}@Overridepublic boolean inSert(String dbName, String collectionName, String[] keys,Object[] values) {DB db = null;DBCollection dbCollection = null;WriteResult result = null;String resultString = null;if(keys!=null && values!=null){if(keys.length != values.length){return false;}else{db = mongoClient.getDB(dbName); //获取数据库实例dbCollection = db.getCollection(collectionName);    //获取数据库中指定的collection集合BasicDBObject insertObj = new BasicDBObject();for(int i=0; i<keys.length; i++){   //构建添加条件insertObj.put(keys[i], values[i]);}try {result = dbCollection.insert(insertObj);resultString = result.getError();} catch (Exception e) {// TODO: handle exceptione.printStackTrace();}finally{if(null != db){db.requestDone();   //请求结束后关闭db}}               return (resultString != null) ? false : true;}}return false;}@Overridepublic boolean isExit(String dbName, String collectionName, String key,Object value) {// TODO Auto-generated method stubDB db = null;DBCollection dbCollection = null;if(key!=null && value!=null){try {db = mongoClient.getDB(dbName); //获取数据库实例dbCollection = db.getCollection(collectionName);    //获取数据库中指定的collection集合BasicDBObject obj = new BasicDBObject();    //构建查询条件obj.put(key, value);if(dbCollection.count(obj) > 0) {return true;}else{return false;}} catch (Exception e) {// TODO: handle exceptione.printStackTrace();} finally{if(null != db){db.requestDone();   //关闭dbdb = null;}}}return false;}@Overridepublic boolean update(String dbName, String collectionName,DBObject oldValue, DBObject newValue) {DB db = null;DBCollection dbCollection = null;WriteResult result = null;String resultString = null;if(oldValue.equals(newValue)){return true;}else{try {db = mongoClient.getDB(dbName); //获取数据库实例dbCollection = db.getCollection(collectionName);    //获取数据库中指定的collection集合result = dbCollection.update(oldValue, newValue);resultString = result.getError();return (resultString!=null) ? false : true;} catch (Exception e) {// TODO: handle exceptione.printStackTrace();} finally{if(null != db){db.requestDone();   //关闭dbdb = null;}}}return false;}/*** 方法名：main* 作者：zhouyh* 创建时间：2014-8-30 下午04:21:11* 描述：TODO(这里用一句话描述这个方法的作用)* @param args*/public static void main(String[] args) {// TODO Auto-generated method stub}}

这篇关于MongoDB -- MongoClient连接池用法的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1001567。

相关文章

C语言中%zu的用法解读

C语言中%zu的用法解读

《C语言中%zu的用法解读》size_t是无符号整数类型,用于表示对象大小或内存操作结果,%zu是C99标准中专为size_t设计的printf占位符,避免因类型不匹配导致错误,使用%u或%d可能引发... 目录size_t 类型与 %zu 占位符%zu 的用途替代占位符的风险兼容性说明其他相关占位符验证示
阅读更多...
MySQL中EXISTS与IN用法使用与对比分析

MySQL中EXISTS与IN用法使用与对比分析

《MySQL中EXISTS与IN用法使用与对比分析》在MySQL中,EXISTS和IN都用于子查询中根据另一个查询的结果来过滤主查询的记录,本文将基于工作原理、效率和应用场景进行全面对比... 目录一、基本用法详解1. IN 运算符2. EXISTS 运算符二、EXISTS 与 IN 的选择策略三、性能对比
阅读更多...
全面解析Golang 中的 Gorilla CORS 中间件正确用法

全面解析Golang 中的 Gorilla CORS 中间件正确用法

《全面解析Golang中的GorillaCORS中间件正确用法》Golang中使用gorilla/mux路由器配合rs/cors中间件库可以优雅地解决这个问题,然而,很多人刚开始使用时会遇到配... 目录如何让 golang 中的 Gorilla CORS 中间件正确工作一、基础依赖二、错误用法（很多人一开
阅读更多...
Java Stream流之GroupBy的用法及应用场景

Java Stream流之GroupBy的用法及应用场景

《JavaStream流之GroupBy的用法及应用场景》本教程将详细介绍如何在Java中使用Stream流的groupby方法,包括基本用法和一些常见的实际应用场景,感兴趣的朋友一起看看吧... 目录Java Stream流之GroupBy的用法1. 前言2. 基础概念什么是 GroupBy？Stream
阅读更多...
Java Spring的依赖注入理解及@Autowired用法示例详解

Java Spring的依赖注入理解及@Autowired用法示例详解

《JavaSpring的依赖注入理解及@Autowired用法示例详解》文章介绍了Spring依赖注入（DI）的概念、三种实现方式（构造器、Setter、字段注入）,区分了@Autowired（注入... 目录一、什么是依赖注入（DI）？1. 定义2. 举个例子二、依赖注入的几种方式1. 构造器注入（Con
阅读更多...
详解MySQL中JSON数据类型用法及与传统JSON字符串对比

详解MySQL中JSON数据类型用法及与传统JSON字符串对比

《详解MySQL中JSON数据类型用法及与传统JSON字符串对比》MySQL从5.7版本开始引入了JSON数据类型,专门用于存储JSON格式的数据,本文将为大家简单介绍一下MySQL中JSON数据类型... 目录前言基本用法jsON数据类型 vs 传统JSON字符串1. 存储方式2. 查询方式对比3. 索引
阅读更多...
全面掌握 SQL 中的 DATEDIFF函数及用法最佳实践

全面掌握 SQL 中的 DATEDIFF函数及用法最佳实践

《全面掌握SQL中的DATEDIFF函数及用法最佳实践》本文解析DATEDIFF在不同数据库中的差异,强调其边界计算原理,探讨应用场景及陷阱,推荐根据需求选择TIMESTAMPDIFF或inte... 目录1. 核心概念：DATEDIFF 究竟在计算什么？2. 主流数据库中的 DATEDIFF 实现2.1
阅读更多...
MySQL中的LENGTH()函数用法详解与实例分析

MySQL中的LENGTH()函数用法详解与实例分析

《MySQL中的LENGTH()函数用法详解与实例分析》MySQLLENGTH()函数用于计算字符串的字节长度,区别于CHAR_LENGTH()的字符长度,适用于多字节字符集（如UTF-8）的数据验证... 目录1. LENGTH()函数的基本语法2. LENGTH()函数的返回值2.1 示例1：计算字符串
阅读更多...
Java中的数组与集合基本用法详解

Java中的数组与集合基本用法详解

《Java中的数组与集合基本用法详解》本文介绍了Java数组和集合框架的基础知识,数组部分涵盖了一维、二维及多维数组的声明、初始化、访问与遍历方法,以及Arrays类的常用操作,对Java数组与集合相... 目录一、Java数组基础1.1 数组结构概述1.2 一维数组1.2.1 声明与初始化1.2.2 访问
阅读更多...
MySQL 中的 CAST 函数详解及常见用法

MySQL 中的 CAST 函数详解及常见用法

《MySQL中的CAST函数详解及常见用法》CAST函数是MySQL中用于数据类型转换的重要函数,它允许你将一个值从一种数据类型转换为另一种数据类型,本文给大家介绍MySQL中的CAST... 目录mysql 中的 CAST 函数详解一、基本语法二、支持的数据类型三、常见用法示例1. 字符串转数字2. 数字
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2