mongodb3.0分片及java代码连接操作测试(开启用户验证)

简介: 最近抽时间搭建了一下mongodb简单的分片,整个过程还算是蛮顺利,只不过在用户验证这一块遇到了一些问题,好在最后终于搞定。一、服务器搭建过程:1、安装四个mongodb:一个作为config、一个作为mongos、另外两个作为主要数据存储的服务器(机器ip192.168.0.201),如图:分别对应图中被红框框起来的mongoconf、mongos、mongo1、mong
最近抽时间搭建了一下mongodb简单的分片,整个过程还算是蛮顺利,只不过在用户验证这一块遇到了一些问题,好在最后终于搞定。

一、服务器搭建过程:

1、安装四个mongodb:一个作为config、一个作为mongos、另外两个作为主要数据存储的服务器(机器ip192.168.0.201),如图:


分别对应图中被红框框起来的mongoconf、mongos、mongo1、mongo2(解压安装,安装过程省略)。

2、分别建立data、conf、logs文件夹,并在logs文件夹下建立mongodb.log文件,在conf中建立mongodb.conf(启动配置参数)文件。
mongoconf中conf文件内容如下:
dbpath=/home/admin/mongoconf/data
logpath=/home/admin/mongoconf/logs/mongodb.log
logappend=true
fork=true
port=30000

mongos中conf文件内容个如下(与上边相比少了dbpath的指定):
logpath=/home/admin/mongos/logs/mongodb.log
logappend=true
fork=true
port=40000

mongo1中conf内容如下(和mongoconf中基本一样,只是路径指向的是自己的):
dbpath=/home/admin/mongo1/data
logpath=/home/admin/mongo1/logs/mongodb.log
logappend=true
fork=true
port=37117

mongo2中的conf也是一样,只是把mongo1改为mongo2(省略)。

3、依次启动mongoconf、mongos和mongo1、mongo2:
启动mongoconf,在bin目录下执行mongod命令:
./mongod -f ../conf/mongodb.conf

启动mongos,在bin目录下执行mongos命令:
./mongos -f ../conf/mongodb.conf --configdb=192.168.0.201:30000

启动mongo1和mongo2,在各自的bin目录中执行mongod命令:
./mongod -f ../conf/mongodb.conf

4、连接mongos服务器,并添加分片:
  (1)、连接mongos:在任意一个mongodb的bin目录执行如下命令:       
./mongo 192.168.0.201:40000/admin

  (2)、进入mongos后添加mongo1和mongo2位分片数据服务器:        
db.runCommand({"addshard":"192.168.0.201:37117"})
db.runCommand({"addshard":"192.168.0.201:47117"})
   

5、开启分片:   
db.runCommand({"enablesharding":"test"})
db.runCommand({"shardcollection":"test.user","key":{"name":1}})


6、测试:向test数据库的user表中添加10w条数据:
use test
for(var i=0;i<100000;i++){
    db.user.insert({"name":"test"+i,"age":i});
}


7、查看分片结果:
db.printShardingStatus()


二、开启用户验证:

1、切换数据库到admin创建root用户:
 db.createUser({"user":"root","pwd":"123456","roles":["root"]})


 再切换到test数据库创建读写权限的用户(非admin数据库中无法创建集群管理相关的用户):  
db.createUser({"user":"test","pwd":"123456","roles":[{"db":"test","role":"readWrite"},"readWrite"]})


2、退出mongo shell,创建keyFile(文件名可自取)文件,并赋予600权限,必须要600权限:
  进入到mongo1的data目录下执行如下命令:
openssl rand -base64 753 > keyFile
chmod 600 keyFile


3、把生成的keyFile文件拷贝到其他几个mongodb的data目录中:


4、修改mongodb.conf启动配置文件:
除开mongos之外,其他都加上如下内容(开启用户验证和keyFile验证):
auth=true
keyFile=/home/admin/mongo2/data/keyFile

mongos中没有auth参数,只需要keyFile。

5、重新依次启动 mongoconf、mongos和mongo1、mongo2(参考上边的启动说明);

三、java代码连接测试:

1、java连接代码如下:
public class MonTest {
    public static void main(String[] args) {
        mongodbfind2();
    }

   public static void mongodbfind2() {
        ServerAddress sa = new ServerAddress("192.168.0.201", 40000);
        List<MongoCredential> mongoCredentialList = new ArrayList<MongoCredential>();
        mongoCredentialList.add(MongoCredential.createCredential("test", "test", "123456".toCharArray()));
        MongoClient client = new MongoClient(sa, mongoCredentialList);
        MongoDatabase database = client.getDatabase("test");        // ********
        MongoCollection collection2 = database.getCollection("user");
        FindIterable<Document> findIterable = collection2.find();
        MongoCursor<Document> cursor2 = findIterable.iterator();
        while (cursor2.hasNext()) {
            Document doc = cursor2.next();
            System.out.println(doc.get("_id") + "," + doc.get("name") + "," + doc.get("age"));
        }
        // 关闭数据库连接
        client.close();
    }
}

2、运行结果:


收工完成!








目录
相关文章
|
11月前
|
SQL Java 关系型数据库
Java连接MySQL数据库环境设置指南
请注意,在实际部署时应该避免将敏感信息(如用户名和密码)硬编码在源码文件里面;应该使用配置文件或者环境变量等更为安全可靠地方式管理这些信息。此外,在处理大量数据时考虑使用PreparedStatement而不是Statement可以提高性能并防止SQL注入攻击;同时也要注意正确处理异常情况,并且确保所有打开过得资源都被正确关闭释放掉以防止内存泄漏等问题发生。
493 13
|
消息中间件 存储 NoSQL
java连接redis和基础操作命令
通过以上内容,您可以掌握在Java中连接Redis以及进行基础操作的基本方法,进而在实际项目中灵活应用。
787 30
|
前端开发 Java 数据库连接
Java后端开发-使用springboot进行Mybatis连接数据库步骤
本文介绍了使用Java和IDEA进行数据库操作的详细步骤,涵盖从数据库准备到测试类编写及运行的全过程。主要内容包括: 1. **数据库准备**:创建数据库和表。 2. **查询数据库**:验证数据库是否可用。 3. **IDEA代码配置**:构建实体类并配置数据库连接。 4. **测试类编写**:编写并运行测试类以确保一切正常。
905 2
|
Java Linux 数据库
java连接kerberos用户认证
java连接kerberos用户认证
534 22
|
Java 数据库连接 数据库
深入探讨Java连接池技术如何通过复用数据库连接、减少连接建立和断开的开销,从而显著提升系统性能
在Java应用开发中,数据库操作常成为性能瓶颈。本文通过问题解答形式,深入探讨Java连接池技术如何通过复用数据库连接、减少连接建立和断开的开销,从而显著提升系统性能。文章介绍了连接池的优势、选择和使用方法,以及优化配置的技巧。
349 1
|
SQL Java 数据库连接
在Java应用中,数据库访问常成为性能瓶颈。连接池技术通过预建立并复用数据库连接,有效减少连接开销,提升访问效率
在Java应用中,数据库访问常成为性能瓶颈。连接池技术通过预建立并复用数据库连接,有效减少连接开销,提升访问效率。本文介绍了连接池的工作原理、优势及实现方法,并提供了HikariCP的示例代码。
414 3
|
Java 数据库连接 数据库
Java连接池在数据库性能优化中的重要作用。连接池通过预先创建和管理数据库连接,避免了频繁创建和关闭连接的开销
本文深入探讨了Java连接池在数据库性能优化中的重要作用。连接池通过预先创建和管理数据库连接,避免了频繁创建和关闭连接的开销,显著提升了系统的响应速度和吞吐量。文章介绍了连接池的工作原理,并以HikariCP为例,展示了如何在Java应用中使用连接池。通过合理配置和优化,连接池技术能够有效提升应用性能。
410 1
|
存储 Java 关系型数据库
高效连接之道:Java连接池原理与最佳实践
在Java开发中,数据库连接是应用与数据交互的关键环节。频繁创建和关闭连接会消耗大量资源,导致性能瓶颈。为此,Java连接池技术通过复用连接,实现高效、稳定的数据库连接管理。本文通过案例分析,深入探讨Java连接池的原理与最佳实践,包括连接池的基本操作、配置和使用方法,以及在电商应用中的具体应用示例。
519 5
|
SQL Java 关系型数据库
java连接mysql查询数据(基础版,无框架)
【10月更文挑战第12天】该示例展示了如何使用Java通过JDBC连接MySQL数据库并查询数据。首先在项目中引入`mysql-connector-java`依赖,然后通过`JdbcUtil`类中的`main`方法实现数据库连接、执行SQL查询及结果处理,最后关闭相关资源。
1041 6
|
SQL 存储 Java
Java中使用ClickHouseDriver连接和基本操作
通过上述步骤,你可以轻松地在Java应用中集成ClickHouse数据库,执行基本的CRUD操作。需要注意的是,实际开发中应当根据实际情况调整数据库连接配置(如URL中的主机、端口、数据库名等),并根据应用需求选择合适的异常处理策略,确保代码的健壮性和资源的有效管理。此外,对于复杂查询和大批量数据处理,建议充分利用ClickHouse的特性(如分布式处理、列式存储优化等),以进一步提升性能。
1603 2

推荐镜像

更多