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

本文涉及的产品
云数据库 MongoDB,独享型 2核8GB
推荐场景:
构建全方位客户视图
简介: 最近抽时间搭建了一下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、运行结果:


收工完成!








相关实践学习
MongoDB数据库入门
MongoDB数据库入门实验。
快速掌握 MongoDB 数据库
本课程主要讲解MongoDB数据库的基本知识,包括MongoDB数据库的安装、配置、服务的启动、数据的CRUD操作函数使用、MongoDB索引的使用(唯一索引、地理索引、过期索引、全文索引等)、MapReduce操作实现、用户管理、Java对MongoDB的操作支持(基于2.x驱动与3.x驱动的完全讲解)。 通过学习此课程,读者将具备MongoDB数据库的开发能力,并且能够使用MongoDB进行项目开发。 &nbsp; 相关的阿里云产品:云数据库 MongoDB版 云数据库MongoDB版支持ReplicaSet和Sharding两种部署架构,具备安全审计,时间点备份等多项企业能力。在互联网、物联网、游戏、金融等领域被广泛采用。 云数据库MongoDB版(ApsaraDB for MongoDB)完全兼容MongoDB协议,基于飞天分布式系统和高可靠存储引擎,提供多节点高可用架构、弹性扩容、容灾、备份回滚、性能优化等解决方案。 产品详情: https://www.aliyun.com/product/mongodb
目录
相关文章
|
14天前
|
Java
在 Java 中捕获和处理自定义异常的代码示例
本文提供了一个 Java 代码示例,展示了如何捕获和处理自定义异常。通过创建自定义异常类并使用 try-catch 语句,可以更灵活地处理程序中的错误情况。
|
25天前
|
jenkins Java 测试技术
如何使用 Jenkins 自动发布 Java 代码,通过一个电商公司后端服务的实际案例详细说明
本文介绍了如何使用 Jenkins 自动发布 Java 代码,通过一个电商公司后端服务的实际案例,详细说明了从 Jenkins 安装配置到自动构建、测试和部署的全流程。文中还提供了一个 Jenkinsfile 示例,并分享了实践经验,强调了版本控制、自动化测试等关键点的重要性。
60 3
|
26天前
|
分布式计算 Java MaxCompute
ODPS MR节点跑graph连通分量计算代码报错java heap space如何解决
任务启动命令:jar -resources odps-graph-connect-family-2.0-SNAPSHOT.jar -classpath ./odps-graph-connect-family-2.0-SNAPSHOT.jar ConnectFamily 若是设置参数该如何设置
|
27天前
|
SQL Java 数据库连接
在Java应用中,数据库访问常成为性能瓶颈。连接池技术通过预建立并复用数据库连接,有效减少连接开销,提升访问效率
在Java应用中,数据库访问常成为性能瓶颈。连接池技术通过预建立并复用数据库连接,有效减少连接开销,提升访问效率。本文介绍了连接池的工作原理、优势及实现方法,并提供了HikariCP的示例代码。
41 3
|
24天前
|
Java
Java代码解释++i和i++的五个主要区别
本文介绍了前缀递增(++i)和后缀递增(i++)的区别。两者在独立语句中无差异,但在赋值表达式中,i++ 返回原值,++i 返回新值;在复杂表达式中计算顺序不同;在循环中虽结果相同但使用方式有别。最后通过 `Counter` 类模拟了两者的内部实现原理。
Java代码解释++i和i++的五个主要区别
|
27天前
|
Java 数据库连接 数据库
深入探讨Java连接池技术如何通过复用数据库连接、减少连接建立和断开的开销,从而显著提升系统性能
在Java应用开发中,数据库操作常成为性能瓶颈。本文通过问题解答形式,深入探讨Java连接池技术如何通过复用数据库连接、减少连接建立和断开的开销,从而显著提升系统性能。文章介绍了连接池的优势、选择和使用方法,以及优化配置的技巧。
26 1
|
11天前
|
Java 开发者
Java多线程编程中的常见误区与最佳实践####
本文深入剖析了Java多线程编程中开发者常遇到的几个典型误区,如对`start()`与`run()`方法的混淆使用、忽视线程安全问题、错误处理未同步的共享变量等,并针对这些问题提出了具体的解决方案和最佳实践。通过实例代码对比,直观展示了正确与错误的实现方式,旨在帮助读者构建更加健壮、高效的多线程应用程序。 ####
|
2天前
|
缓存 Java 开发者
Java多线程编程的陷阱与最佳实践####
本文深入探讨了Java多线程编程中常见的陷阱,如竞态条件、死锁和内存一致性错误,并提供了实用的避免策略。通过分析典型错误案例,本文旨在帮助开发者更好地理解和掌握多线程环境下的编程技巧,从而提升并发程序的稳定性和性能。 ####
|
1天前
|
安全 Java 开发者
Java中的多线程编程:从基础到实践
本文深入探讨了Java多线程编程的核心概念和实践技巧,旨在帮助读者理解多线程的工作原理,掌握线程的创建、管理和同步机制。通过具体示例和最佳实践,本文展示了如何在Java应用中有效地利用多线程技术,提高程序性能和响应速度。
19 1
|
10天前
|
安全 Java 开发者
Java 多线程并发控制:深入理解与实战应用
《Java多线程并发控制:深入理解与实战应用》一书详细解析了Java多线程编程的核心概念、并发控制技术及其实战技巧,适合Java开发者深入学习和实践参考。