java实现mongodb的数据库连接池

 更新时间:2015年12月30日 11:44:47   转载 作者:xiaojimanman  
这篇文章主要介绍了基于java实现mongodb的数据库连接池,Java通过使用mongo-2.7.3.jar包实现mongodb连接池,感兴趣的小伙伴们可以参考一下

MongoDB是介于关系数据库和非关系数据库之间的一种产品,文件的存储格式为BSON(一种JSON的扩展),这里就主要介绍Java通过使用mongo-2.7.3.jar包实现mongodb连接池,具体的java代码实现如下:

数据库连接池配置参数:

 /** 
 *@Description: mongo连接池配置文件 
 */ 
package cn.lulei.mongo.pool; 
 
public class MongoConfig { 
  
 private static String userName;//用户名 
 private static String pwd;//密码 
 private static String[] host;//主机地址 
 private static int[] port;//端口地址 
 private static String dbName;//数据库名 
 private static int connectionsPerHost = 20;//每台主机最大连接数 
 private static int threadsAllowedToBlockForConnectionMultiplier = 10;//线程队列数 
 private static boolean authentication = false;//是否需要身份验证 
  
 public static String getUserName() { 
  return userName; 
 } 
 public static void setUserName(String userName) { 
  MongoConfig.userName = userName; 
 } 
 public static String getPwd() { 
  return pwd; 
 } 
 public static void setPwd(String pwd) { 
  MongoConfig.pwd = pwd; 
 } 
 public static String[] getHost() { 
  return host; 
 } 
 public static void setHost(String[] host) { 
  MongoConfig.host = host; 
 } 
 public static int[] getPort() { 
  return port; 
 } 
 public static void setPort(int[] port) { 
  MongoConfig.port = port; 
 } 
 public static String getDbName() { 
  return dbName; 
 } 
 public static void setDbName(String dbName) { 
  MongoConfig.dbName = dbName; 
 } 
 public static int getConnectionsPerHost() { 
  return connectionsPerHost; 
 } 
 public static void setConnectionsPerHost(int connectionsPerHost) { 
  MongoConfig.connectionsPerHost = connectionsPerHost; 
 } 
 public static int getThreadsAllowedToBlockForConnectionMultiplier() { 
  return threadsAllowedToBlockForConnectionMultiplier; 
 } 
 public static void setThreadsAllowedToBlockForConnectionMultiplier( 
   int threadsAllowedToBlockForConnectionMultiplier) { 
  MongoConfig.threadsAllowedToBlockForConnectionMultiplier = threadsAllowedToBlockForConnectionMultiplier; 
 } 
 public static boolean isAuthentication() { 
  return authentication; 
 } 
 public static void setAuthentication(boolean authentication) { 
  MongoConfig.authentication = authentication; 
 } 
} 

数据库连接池管理类:

 /** 
 *@Description: mongo数据库连接池管理类 
 */ 
package cn.lulei.mongo.pool; 
 
import java.util.ArrayList; 
import java.util.List; 
 
import com.mongodb.DB; 
import com.mongodb.DBCollection; 
import com.mongodb.Mongo; 
import com.mongodb.MongoOptions; 
import com.mongodb.ReadPreference; 
import com.mongodb.ServerAddress; 
 
public class MongoManager { 
  
 private static Mongo mongo; 
 private DB db; 
  
 static{ 
  init(); 
 } 
  
 /** 
 * @param dbName 
 * @param userName 
 * @param pwd 
 * 实例化dbName一个DB 
  */ 
 public MongoManager(String dbName, String userName, String pwd) { 
  if (dbName == null || "".equals(dbName)) { 
   throw new NumberFormatException("dbName is null"); 
  } 
  db = mongo.getDB(dbName); 
  if(MongoConfig.isAuthentication() && !db.isAuthenticated()){ 
   if (userName == null || "".equals(userName)) { 
    throw new NumberFormatException("userName is null"); 
   } 
   if (pwd == null || "".equals(pwd)) { 
    throw new NumberFormatException("pwd is null"); 
   } 
   db.authenticate(userName, pwd.toCharArray()); 
  } 
 } 
  
 /** 
  * 使用配置参数实例化 
  */ 
 public MongoManager() { 
  this(MongoConfig.getDbName(), MongoConfig.getUserName(), MongoConfig.getPwd()); 
 } 
  
 /** 
  * @param tableName 
  * @return 
  * @Description: 获取表tableName的链接DBCollection 
  */ 
 public DBCollection getDBCollection(String tableName) { 
  return db.getCollection(tableName); 
 } 
  
 /** 
  * @Description: mongo连接池初始化 
  */ 
 private static void init() { 
  if (MongoConfig.getHost() == null || MongoConfig.getHost().length == 0) { 
   throw new NumberFormatException("host is null"); 
  } 
  if (MongoConfig.getPort() == null || MongoConfig.getPort().length == 0) { 
   throw new NumberFormatException("port is null"); 
  } 
  if (MongoConfig.getHost().length != MongoConfig.getPort().length) { 
   throw new NumberFormatException("host's length is not equals port's length"); 
  } 
  try { 
   //服务列表 
   List<ServerAddress> replicaSetSeeds = new ArrayList<ServerAddress>(); 
   for (int i = 0; i < MongoConfig.getHost().length; i++) { 
    replicaSetSeeds.add(new ServerAddress(MongoConfig.getHost()[i], MongoConfig.getPort()[i])); 
   } 
   //连接池参数设置 
   MongoOptions options = new MongoOptions(); 
   options.connectionsPerHost = MongoConfig.getConnectionsPerHost(); 
   options.threadsAllowedToBlockForConnectionMultiplier = MongoConfig.getThreadsAllowedToBlockForConnectionMultiplier(); 
   mongo = new Mongo(replicaSetSeeds, options); 
   //从服务器可读 
   mongo.setReadPreference(ReadPreference.SECONDARY); 
  } catch (Exception e){ 
   e.printStackTrace(); 
  } 
 } 
} 

下面通过一个简单的测试类,来看下如何使用这个连接池~

 /** 
 *@Description:mongo测试 
 */ 
package cn.lulei.mongo.test; 
 
import cn.lulei.mongo.pool.MongoConfig; 
import cn.lulei.mongo.pool.MongoManager; 
 
public class Test { 
 
 public static void main(String[] args) { 
  // TODO Auto-generated method stub 
  String[] host = {"127.0.0.1"}; 
  int[] port = {27001}; 
  MongoConfig.setHost(host); 
  MongoConfig.setPort(port); 
  MongoConfig.setDbName("novel"); 
  MongoManager mongoManager = new MongoManager(); 
  mongoManager.getDBCollection("chapter"); 
 } 
 
} 

在使用上述管理类时,只需要初始化MongoConfig类即可。对类MongoManager的实例话,既可以使用MongoConfig的配置也可以自己通过参数来设置,每次获取DBCollection 时,只需要调用getDBCollection(String tableName)方法即可。

以上就是本文的全部内容,希望本文所述对大家学习java程序设计有所帮助。

相关文章

  • java+selenium爬取图片签名的方法

    java+selenium爬取图片签名的方法

    这篇文章主要为大家详细介绍了java+selenium爬取图片签名的方法,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2019-08-08
  • Jersey框架的统一异常处理机制分析

    Jersey框架的统一异常处理机制分析

    初学者往往不清楚java的异常为什么会设计成这个样子,他们通常会对异常只进行简单的处理
    2016-07-07
  • java自带的工具Jstack截取进程中的堆栈信息

    java自带的工具Jstack截取进程中的堆栈信息

    本文给大家记录的是java自带的工具Jstack截取进程中的堆栈信息的方法,非常的实用,有需要的小伙伴可以参考下。
    2016-01-01
  • Java中的泛型详解

    Java中的泛型详解

    这篇文章主要介绍了Java中的泛型详解,本文讲解了泛型类或接口、从泛型类派生子类、伪泛型、类型通配符、通配符的上限、通配符的下限、擦除和转换等内容,需要的朋友可以参考下
    2015-04-04
  • Hibernate三种状态和Session常用的方法

    Hibernate三种状态和Session常用的方法

    本文主要介绍了Hibernate三种状态和Session常用的方法,具有很好的参考价值,下面跟着小编一起来看下吧
    2017-03-03
  • java使用nio2拷贝文件的示例

    java使用nio2拷贝文件的示例

    这篇文章主要介绍了java使用nio2拷贝文件的示例,需要的朋友可以参考下
    2014-04-04
  • Springboot通过aop实现事务控制过程解析

    Springboot通过aop实现事务控制过程解析

    这篇文章主要介绍了Springboot通过aop实现事务控制过程解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-03-03
  • 基于HTML5+js+Java实现单文件文件上传到服务器功能

    基于HTML5+js+Java实现单文件文件上传到服务器功能

    应公司要求,在HTML5页面上实现上传文件到服务器功能,对于我这样的菜鸟,真是把我难住了,最后还是请教大神搞定的,下面小编把例子分享到脚本之家平台,供大家参考
    2017-08-08
  • Struts2 的国际化实现方式示例

    Struts2 的国际化实现方式示例

    这篇文章主要介绍了Struts2 的国际化实现方式示例,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-10-10
  • java  StringBuilder类的详解及简单实例

    java StringBuilder类的详解及简单实例

    这篇文章主要介绍了java StringBuilder类的详解及简单实例的相关资料,实现了StringBuilder类的追加、插入、替换、删除等操作,需要的朋友可以参考下
    2017-08-08

最新评论