首页 / MONGODB / 57-4 数据库分片概念及mongodb sharding的实现

57-4 数据库分片概念及mongodb sharding的实现

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了57-4 数据库分片概念及mongodb sharding的实现，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含12328字，纯文字阅读大概需要18分钟。

内容图文

数据库分片的概念及mongodb sharding的实现

配置环境：

node1: 192.168.1.121 CentOS release 6.7

node2: 192.168.1.122 CentOS release 6.7

node3: 192.168.1.123 CentOS release 6.7

[root@node1 ~]# vim /etc/hosts

添加

192.168.1.121 node1

192.168.1.122 node2

192.168.1.123 node3

[root@node1 ~]# scp /etc/hosts node2:/etc

[root@node1 ~]# scp /etc/hosts node3:/etc

[root@node1 ~]# service mongod stop

[root@node1 ~]# vim /etc/mongod.conf

修改

#replSet=setname

为

replSet=testSet

replIndexPrefetch=_id_only

[root@node1 ~]# service mongod start

[root@node1 ~]# mongo

MongoDB shell version: 2.6.4

connecting to: test

> show dbs

admin (empty)

local 0.078GB

testdb 0.078GB

> use local

switched to db local

> show collections

startup_log

system.indexes

> exit

bye

[root@node1 mongodb-2.6.4]# scp mongodb-org-server-2.6.4-1.x86_64.rpm mongodb-org-tools-2.6.4-1.x86_64.rpm mongodb-org-shell-2.6.4-1.x86_64.rpm node2:/root

[root@node1 mongodb-2.6.4]# scp mongodb-org-server-2.6.4-1.x86_64.rpm mongodb-org-tools-2.6.4-1.x86_64.rpm mongodb-org-shell-2.6.4-1.x86_64.rpm node3:/root

[root@node2 ~]# yum -y install *rpm

[root@node2 ~]# mkdir -p /mongodb/data

[root@node2 ~]# chown -R mongod.mongod /mongodb/

[root@node3 ~]# yum -y install *rpm

[root@node3 ~]# mkdir -p /mongodb/data

[root@node3 ~]# chown -R mongod.mongod /mongodb/

[root@node1 ~]# scp /etc/mongod.conf node2:/etc/

[root@node1 ~]# scp /etc/mongod.conf node3:/etc/

[root@node2 ~]# service mongod start

[root@node3 ~]# service mongod start

[root@node1 ~]# mongo

MongoDB shell version: 2.6.4

connecting to: test

> rs.status()

{

"startupStatus" : 3,

"info" : "run rs.initiate(...) if not yet done for the set",

"ok" : 0,

"errmsg" : "can‘t get local.system.replset config from self or any seed (EMPTYCONFIG)"

}

> rs.initiate()

{

"info2" : "no configuration explicitly specified -- making one",

"me" : "node1:27017",

"info" : "Config now saved locally. Should come online in about a minute.",

"ok" : 1

}

> rs.status()

{

"set" : "testSet",

"date" : ISODate("2017-01-08T14:33:14Z"),

"myState" : 1,

"members" : [

{

"_id" : 0,

"name" : "node1:27017",

"health" : 1,

"state" : 1,

"stateStr" : "PRIMARY",

"uptime" : 1316,

"optime" : Timestamp(1483885955, 1),

"optimeDate" : ISODate("2017-01-08T14:32:35Z"),

"electionTime" : Timestamp(1483885956, 1),

"electionDate" : ISODate("2017-01-08T14:32:36Z"),

"self" : true

}

"ok" : 1

}

#添加节点

testSet:PRIMARY> rs.add("192.168.1.122")

{ "ok" : 1 }

testSet:PRIMARY> rs.status()

{

"set" : "testSet",

"date" : ISODate("2017-01-08T14:38:50Z"),

"myState" : 1,

"members" : [

{

"_id" : 0,

"name" : "node1:27017",

"health" : 1,

"state" : 1,

"stateStr" : "PRIMARY",

"uptime" : 1652,

"optime" : Timestamp(1483886304, 1),

"optimeDate" : ISODate("2017-01-08T14:38:24Z"),

"electionTime" : Timestamp(1483885956, 1),

"electionDate" : ISODate("2017-01-08T14:32:36Z"),

"self" : true

{

"_id" : 1,

"name" : "192.168.1.122:27017",

"health" : 1,

"state" : 2,

"stateStr" : "SECONDARY",

"uptime" : 26,

"optime" : Timestamp(1483886304, 1),

"optimeDate" : ISODate("2017-01-08T14:38:24Z"),

"lastHeartbeat" : ISODate("2017-01-08T14:38:48Z"),

"lastHeartbeatRecv" : ISODate("2017-01-08T14:38:48Z"),

"pingMs" : 1,

"syncingTo" : "node1:27017"

}

"ok" : 1

}

[root@node2 ~]# mongo

MongoDB shell version: 2.6.4

connecting to: test

Welcome to the MongoDB shell.

For interactive help, type "help".

For more comprehensive documentation, see

http://docs.mongodb.org/

Questions? Try the support group

http://groups.google.com/group/mongodb-user

testSet:SECONDARY> show dbs

admin (empty)

local 1.078GB

testdb 0.078GB

testSet:SECONDARY> use testdb;

switched to db testdb

testSet:SECONDARY> rs.slaveOk()

testSet:SECONDARY> rs.status()

{

"set" : "testSet",

"date" : ISODate("2017-01-09T12:02:14Z"),

"myState" : 2,

"syncingTo" : "node1:27017",

"members" : [

{

"_id" : 0,

"name" : "node1:27017",

"health" : 1,

"state" : 1,

"stateStr" : "PRIMARY",

"uptime" : 77028,

"optime" : Timestamp(1483886304, 1),

"optimeDate" : ISODate("2017-01-08T14:38:24Z"),

"lastHeartbeat" : ISODate("2017-01-09T12:02:13Z"),

"lastHeartbeatRecv" : ISODate("2017-01-09T12:02:13Z"),

"pingMs" : 1,

"electionTime" : Timestamp(1483885956, 1),

"electionDate" : ISODate("2017-01-08T14:32:36Z")

{

"_id" : 1,

"name" : "192.168.1.122:27017",

"health" : 1,

"state" : 2,

"stateStr" : "SECONDARY",

"uptime" : 77851,

"optime" : Timestamp(1483886304, 1),

"optimeDate" : ISODate("2017-01-08T14:38:24Z"),

"self" : true

}

"ok" : 1

}

testSet:SECONDARY> rs.isMaster()

{

"setName" : "testSet",

"setVersion" : 2,

"ismaster" : false,

"secondary" : true,

"hosts" : [

"192.168.1.122:27017",

"node1:27017"

"primary" : "node1:27017",

"me" : "192.168.1.122:27017",

"maxBsonObjectSize" : 16777216,

"maxMessageSizeBytes" : 48000000,

"maxWriteBatchSize" : 1000,

"localTime" : ISODate("2017-01-09T12:03:59.702Z"),

"maxWireVersion" : 2,

"minWireVersion" : 0,

"ok" : 1

}

testSet:PRIMARY> rs.isMaster()

{

"setName" : "testSet",

"setVersion" : 2,

"ismaster" : true,

"secondary" : false,

"hosts" : [

"node1:27017",

"192.168.1.122:27017"

"primary" : "node1:27017",

"me" : "node1:27017",

"maxBsonObjectSize" : 16777216,

"maxMessageSizeBytes" : 48000000,

"maxWriteBatchSize" : 1000,

"localTime" : ISODate("2017-01-09T12:05:47.182Z"),

"maxWireVersion" : 2,

"minWireVersion" : 0,

"ok" : 1

}

#增加新节点

testSet:PRIMARY> rs.add("192.168.1.123")

{ "ok" : 1 }

[root@node3 ~]# mongo

MongoDB shell version: 2.6.4

connecting to: test

Welcome to the MongoDB shell.

For interactive help, type "help".

For more comprehensive documentation, see

http://docs.mongodb.org/

Questions? Try the support group

http://groups.google.com/group/mongodb-user

testSet:SECONDARY> rs.slaveOk()

testSet:SECONDARY> rs.status()

{

"set" : "testSet",

"date" : ISODate("2017-01-09T12:10:20Z"),

"myState" : 2,

"syncingTo" : "node1:27017",

"members" : [

{

"_id" : 0,

"name" : "node1:27017",

"health" : 1,

"state" : 1,

"stateStr" : "PRIMARY",

"uptime" : 78,

"optime" : Timestamp(1483963739, 1),

"optimeDate" : ISODate("2017-01-09T12:08:59Z"),

"lastHeartbeat" : ISODate("2017-01-09T12:10:18Z"),

"lastHeartbeatRecv" : ISODate("2017-01-09T12:10:19Z"),

"pingMs" : 1,

"electionTime" : Timestamp(1483885956, 1),

"electionDate" : ISODate("2017-01-08T14:32:36Z")

{

"_id" : 1,

"name" : "192.168.1.122:27017",

"health" : 1,

"state" : 2,

"stateStr" : "SECONDARY",

"uptime" : 78,

"optime" : Timestamp(1483963739, 1),

"optimeDate" : ISODate("2017-01-09T12:08:59Z"),

"lastHeartbeat" : ISODate("2017-01-09T12:10:18Z"),

"lastHeartbeatRecv" : ISODate("2017-01-09T12:10:18Z"),

"pingMs" : 1,

"syncingTo" : "node1:27017"

{

"_id" : 2,

"name" : "192.168.1.123:27017",

"health" : 1,

"state" : 2,

"stateStr" : "SECONDARY",

"uptime" : 78317,

"optime" : Timestamp(1483963739, 1),

"optimeDate" : ISODate("2017-01-09T12:08:59Z"),

"self" : true

}

"ok" : 1

}

testSet:SECONDARY> use testdb

switched to db testdb

testSet:SECONDARY> db.students.findOne()

{ "_id" : ObjectId("5871e94113222f399a5240a3"), "name" : "tom", "age" : 23 }

testSet:SECONDARY> rs.conf()

{

"_id" : "testSet",

"version" : 3,

"members" : [

{

"_id" : 0,

"host" : "node1:27017"

{

"_id" : 1,

"host" : "192.168.1.122:27017"

{

"_id" : 2,

"host" : "192.168.1.123:27017"

}

]

}

testSet:PRIMARY> use testdb

switched to db testdb

testSet:PRIMARY> db.classes.insert({class: "One",nostu: 40})

WriteResult({ "nInserted" : 1 })

testSet:PRIMARY> show collections;

classes

students

system.indexes

testSet:SECONDARY> db.classes.findOne()

{

"_id" : ObjectId("58737e8606a316aec46edfdc"),

"class" : "One",

"nostu" : 40

}

testSet:SECONDARY> db.classes.insert({class: "Two", nostu: 50})

WriteResult({ "writeError" : { "code" : undefined, "errmsg" : "not master" } })

testSet:SECONDARY> rs.conf()

{

"_id" : "testSet",

"version" : 3,

"members" : [

{

"_id" : 0,

"host" : "node1:27017"

{

"_id" : 1,

"host" : "192.168.1.122:27017"

{

"_id" : 2,

"host" : "192.168.1.123:27017"

}

]

}

#使主结点“下台”

testSet:PRIMARY> rs.stepDown()

2017-01-09T20:23:48.978+0800 DBClientCursor::init call() failed

2017-01-09T20:23:48.980+0800 Error: error doing query: failed at src/mongo/shell/query.js:81

2017-01-09T20:23:48.982+0800 trying reconnect to 127.0.0.1:27017 (127.0.0.1) failed

2017-01-09T20:23:48.984+0800 reconnect 127.0.0.1:27017 (127.0.0.1) ok

testSet:SECONDARY> rs.status()

{

"set" : "testSet",

"date" : ISODate("2017-01-09T12:24:27Z"),

"myState" : 2,

"syncingTo" : "192.168.1.123:27017",

"members" : [

{

"_id" : 0,

"name" : "node1:27017",

"health" : 1,

"state" : 2,

"stateStr" : "SECONDARY",

"uptime" : 79989,

"optime" : Timestamp(1483964038, 1),

"optimeDate" : ISODate("2017-01-09T12:13:58Z"),

"infoMessage" : "syncing to: 192.168.1.123:27017",

"self" : true

<st 本文系统来源：http://sihua.blog.51cto.com/377227/1890849

内容总结

以上是互联网集市为您收集整理的57-4 数据库分片概念及mongodb sharding的实现全部内容，希望文章能够帮你解决57-4 数据库分片概念及mongodb sharding的实现所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/473500.html

来源：【匿名】

【上一篇】mongodb基本概念【下一篇】在MongoDB上如何进行数据的导入与导出

更多 ►

【57-4 数据库分片概念及mongodb sharding的实现】教程文章相关的互联网学习教程文章

mongodb入门-关系型RDMS数据库对比及适用场景

引言最近工作接触到了mongodb数据库，记录下个人对其的理解和使用情况。虽然mongodb 出来的时间已经不短，但是相对mysql mssql oracle 这样传统的关系型数据库来说还是比较年轻，接触其的程序员应该也很少，本文从仅作介绍用。名字看MongoDB疑似Humongous Database（网络资料看到）。中文意思就是巨大无比的数据库，顾名思义，MongoDB就是为处理大数据而生，以解决海量数据的存储和高效查询使用为使命。说道mongodb不得不说到nosq...

mysql数据库和mongodb数据库的相关操作以及两个数据库的区别【图】

在docs命令中执行数据操作 MySQL数据库先启动MySQL服务器 net start mysql进入MySQL服务器MySQL -uroot -p（这里写你的数据库密码）（-P是从哪个端口进）我第一次操作是就是因为电脑上有 MySQL MySQL57 MySQLla 三个服务引起端口冲突导致我找不到相应的数据数据库操作create database 创建数据库show databases 显示MySQL服务上的数据库use 数据库使用数据库数据表操作create table 表名（）创建数据表 ...

dotnet core 使用 MongoDB 进行高性能Nosql数据库操作【图】

好久没有写过Blog, 每天看着开源的Java社区流口水, 心里满不是滋味. 终于等到了今年六月份 dotnet core 的正式发布, 看着dotnet 社区也一步一步走向繁荣, 一片蒸蒸日上的大好景象. 不在绑定Windows, 相信众位dotneter的春天就要来了废话不多说, 早就对dotnet core 跃跃欲试, 手头一个新项目也正计划使用dotnet core来开发. 正好自己做做调研, 就与大家分享一点使用MongoDB的经验.首先, 安装VS Code, 并安装C#插件, 官网地址, 我把...

Linux 系统安装 Mongodb 数据库【代码】【图】

一、通过rpm方式安装 1、系统准备我们的系统版本为 CentOS Linux release 7.3.1611 (Core)2、安装包下载下载地址：http://mirrors.aliyun.com/mongodb/yum/redhat/ ，可以根据自己的系统版本选择。我选择的路径：http://mirrors.aliyun.com/mongodb/yum/redhat/7/mongodb-org/3.2/x86_64/RPMS/ 。我选择 mongodb 的版本是3.2.6，软件包如下：mongodb-org-3.2.6-1.el7.x86_64.rpmmongodb-org-mongos-3.2.6-1.el7.x86_64.rpmmongodb-...

python 在Centos6下部署Mongodb数据库【代码】

注：Cenots7的系统不需要部署glibc，可以直接安装启动Mongodb数据库脚本如下cat mongodbInstall.py #!/usr/bin/env python #coding:utf-8import os import zipfile import tarfile import shutilline = os.linesep script_path = os.getcwd() glibc_package = ‘glibc-2.14.zip‘ mongo_package = ‘mongodb-linux-x86_64-rhel70-3.2.8.tgz‘ mongo_path = ‘/usr/local/mongodb‘def decomPression():try:z = zipfile.ZipFile(gl...

java操作mongoDB数据库的简单实例

首先导入mongoDB的jar包http://pan.baidu.com/s/1bnGMJRD //DataBase.javapackage com.mongodb.test;import java.net.UnknownHostException;import com.mongodb.DB; import com.mongodb.DBCollection; import com.mongodb.DBCursor; import com.mongodb.DBObject; import com.mongodb.Mongo; import com.mongodb.MongoException; import com.mongodb.util.JSON;public class DataBase { public static void main(String[] args) ...

MongoDB，无模式文档型数据库简介【图】

MongoDB的名字源自一个形容词humongous（巨大无比的），在向上扩展和快速处理大数据量方面，它会损失一些精度，在旧金山举行的MondoDB大会上，Merriman说：“你不适宜用它来处理复杂的金融事务，如证券交易，数据的一致性可能无法得到保证”。若想了解更多关于MongoDB的信息，请看51CTO数据库频道推荐《MongoDB，无模式文档型数据库简介》。NoSQL数据库都被贴上不同用途的标签，如MongoDB和CouchDB都是面向文档的数据库，但这并不意...

在MongoDB数据库中查询数据(上)【代码】【图】

在MongoDB数据库中查询数据(上)在MongoDB数据库中，可以使用Collection对象的find方法从一个集合中查询多个数据文档，find方法使用方法如下所示：collection.find(selector, [options]);selector值为一个对象，用于指定查询时使用的查询条件，options是可选的参数，该参数值是一个对象，用于指定查询数据时所选用的选项。find方法返回一个代表游标的Cursor对象，在该游标中包含了所有查询到的数据文档信息。可以使用Cursor对象的to...

PHP操作MongoDB 数据库

最近有个项目，需要用php操作mongoDb数据，整理如下　　1，连接MongoDB数据库$conn = new Mongo();其他链接方式//$conn=new Mongo(); #连接本地主机,默认端口.//$conn=new Mongo(“172.21.15.69″); #连接远程主机//$conn=new Mongo(“xiaocai.loc:10086″); #连接指定端口远程主机//$conn=new Mongo(“xiaocai.loc”,array(“replicaSet”=>true)); #负载均衡//$conn=new Mongo(“xiaocai.loc”,array(“persist”=>”t”)); #持久...

mongodb4.0数据库权限配置【图】

今天给大家分享一个关于mongodb数据库权限配置的小知识点，这里呢，我用的是mongodb4.0版本，下载地址：https://www.mongodb.com/download-center/community，这里最好用默认的安装路径，因为后面需要用windows+R的services.msc来重启mongodb server服务，如果安装到自定义盘，这里会无重启服务的选项，所以建议大家直接傻瓜式安装即可到这里呢，假如大家都已经安装成功，并且各种配置都OK了，然后就是今天的主题了1.检查当前某个数...

mongodb数据库自动备份 windows【代码】【图】

1、新建空白txt文档在文档中输入以下代码，其中1）D:\mongoDB\data\backup\ 为备份文件的路径2）D:\Mongodb\bin\mongodump为mongodb的bin目录下的备份命令的路径3）databasename ：替换为自己的数据库名字4）最后将.txt替换为.bat文件@ECHO OFF md D:\mongoDB\data\backup\%date:~0,4%-%date:~5,2%-%date:~8,2% D:\Mongodb\bin\mongodump -h 127.0.0.1 -d databasename -o D:\mongoDB\data\backup\%date:~0,4%-%date:~5,2%-%date:~...

Nodejs操作MongoDB数据库【代码】【图】

数据库连接要在node.js中使用MongoDb，首先需要执行命令 npm install mongodb --save 进行安装，然后在页面中进行引入：const MongoClient = require(‘mongodb‘).MongoClient; const url = ‘mongodb://127.0.0.1:27017‘; const dbName = ‘mongo‘; const client = new MongoClient(url,{useUnifiedTopology:true}); client.connect(function(error){if(error){console.log(error);return;}else{console.log(‘连接成功‘);} }...

使用bs4对海投网内容信息进行提取并存入mongodb数据库【代码】

example: http://xyzp.haitou.cc/article/722427.html首先是直接下载好每个页面，可以使用 os.system( "wget "+str(url)) 或者urllib2.urlopen(url) ，很简单不赘述。然后，重头戏，进行信息抽取：#!/usr/bin/env python # coding=utf-8from bs4 import BeautifulSoup import codecs import sys import os reload(sys) sys.setdefaultencoding("utf-8") import refrom pymongo import MongoClientdef get_jdstr(fname):soup = ...