rss· 投稿· 设为首页· 加入收藏· 繁體版
当前位置: 火魔网 » 数据库 » NoSQL

mongodb 分布式部署 实践

http://fastdl.mongodb.org/linux/mongodb-linux-x86_64-static-legacy-1.6.3.tgz

wget "http://fastdl.mongodb.org/linux/mongodb-linux-x86_64-static-legacy-1.6.2.tgz"
tar -xzvf mongodb-linux-x86_64-static-legacy-1.6.2.tgz
./bin/mongod --help

215.123
cd ~
wget "http://fastdl.mongodb.org/linux/mongodb-linux-x86_64-static-legacy-1.6.3.tgz"
tar -xzvf mongodb-linux-x86_64-static-legacy-1.6.3.tgz
./bin/mongod --help
cd /home
mv /root/mongodb-linux-x86_64-static-1.6.3/ mongodb
cd mongodb/
./bin/mongod --version
mkdir data
mkdir logs
./bin/mongod --dbpath=/home/mongodb/data/ --logpath=/home/mongodb/logs/mongod.log --logappend &
./bin/mongod --pairwith 172.16.215.124 --bind_ip 172.16.215.123 --noauth --dbpath=/home/mongodb/data/ --logpath=/home/mongodb/logs/mongod.log --logappend &
tail -f /home/mongodb/logs/mongod.log

215.124
cd /home
scp -P 32200 -r .
cd mongodb
rm -rf data logs
mkdir -p /diska/mongodb/data
mkdir -p /diska/mongodb/logs
./bin/mongod --dbpath=/diska/mongodb/data/ --logpath=/diska/mongodb/logs/mongod.log --logappend &
./bin/mongod --pairwith 172.16.215.123 --bind_ip 172.16.215.124 --noauth --dbpath=/diska/mongodb/data/ --logpath=/diska/mongodb/logs/mongod.log --logappend &
tail -f /diska/mongodb/logs/mongod.log

215.126
cd /home
scp -P 32200 -r .
cd mongodb
rm -rf data logs
mkdir -p /diska/mongodb/data
mkdir -p /diska/mongodb/logs
./bin/mongod --dbpath=/diska/mongodb/data/ --logpath=/diska/mongodb/logs/mongod.log --logappend &
./bin/mongod --pairwith 172.16.215.119 --bind_ip 172.16.215.126 --noauth --dbpath=/diska/mongodb/data/ --logpath=/diska/mongodb/logs/mongod.log --logappend &
tail -f /diska/mongodb/logs/mongod.log

215.119
cd /home
scp -P 32200 -r .
cd mongodb
rm -rf data logs
mkdir -p /diska/mongodb/data
mkdir -p /diska/mongodb/logs
./bin/mongod --dbpath=/diska/mongodb/data/ --logpath=/diska/mongodb/logs/mongod.log --logappend &
./bin/mongod --pairwith 172.16.215.126 --bind_ip 172.16.215.119 --noauth --dbpath=/diska/mongodb/data/ --logpath=/diska/mongodb/logs/mongod.log --logappend &
tail -f /diska/mongodb/logs/mongod.log

215.112
cd /home
scp -P 32200 -r .
cd mongodb
rm -rf data logs
mkdir data
mkdir logs
./bin/mongod --dbpath=/home/mongodb/data/ --logpath=/home/mongodb/logs/mongod.log --logappend &
./bin/mongod --configsvr --bind_ip 172.16.215.112 --dbpath=/home/mongodb/data/ --logpath=/home/mongodb/logs/mongod.log --logappend &
tail -f /home/mongodb/logs/mongod.log

215.127
cd /home
scp -P 32200 -r .
cd mongodb
rm -rf data logs
mkdir -p /diska/mongodb/data
mkdir -p /diska/mongodb/logs
./bin/mongod --dbpath=/diska/mongodb/data/ --logpath=/diska/mongodb/logs/mongod.log --logappend &
./bin/mongos --configdb 172.16.215.112 --bind_ip 0.0.0.0 --logpath=/diska/mongodb/logs/mongod.log --logappend &
tail -f /diska/mongodb/logs/mongod.log

在127,mongos上的操作
./bin/mongo --host 172.16.215.127 --port 27017

show dbs
admin = db.getSisterDB("admin")     //新增数据库
use admin
show collections

db.runCommand( { addshard : "172.16.215.110,10.13.127.212:18020", allowLocal : true } )
db.runCommand( { listshards : 1 } );
test = db.getSisterDB("test")       //新增数据库test
db.runCommand( { enablesharding : "<dbname>" } );
db.runCommand( { shardcollection : "<namespace>",key : <shardkeypatternobject>} )
db.runCommand( { shardcollection : "test.fs.chunks", key : { _id : 1 } } )
db.runCommand( { shardcollection : "test.users" , key : { email : 1 } , unique : true } );
db.createCollection(name, { size : ..., capped : ..., max : ... } )
db.coll_1.drop()
db.coll_1.ensureIndex({"id":1})
db.coll_1.dropIndex(name)
db.coll_1.dropIndexes()
db.coll_1.getIndexes()

db.coll_1.count(query);
db.coll_1.find(query );
db.coll_1.insert(obj);
db.coll_1.update(query, object[, upsert_bool]);
db.coll_1.save(obj);
db.coll_1.remove(query)

db.coll_1.stats()

------------------------------------------------------------
help                         show help
show dbs                     show database names
show collections             show collections in current database
show users                   show users in current database
show profile                 show most recent system.profile entries with time >= 1ms
use <db name>                set curent database to <db name>

db.addUser (username, password)
db.removeUser(username)

db.cloneDatabase(fromhost)
db.copyDatabase(fromdb, todb, fromhost)
db.createCollection(name, { size : ..., capped : ..., max : ... } )

db.getName()
db.dropDatabase()
db.printCollectionStats()

db.currentOp() displays the current operation in the db
db.killOp() kills the current operation in the db

db.getProfilingLevel()
db.setProfilingLevel(level) 0=off 1=slow 2=all

db.getReplicationInfo()
db.printReplicationInfo()
db.printSlaveReplicationInfo()
db.repairDatabase()

db.version() current version of the server

db.shutdownServer()

db.foo.drop() drop the collection
db.foo.dropIndex(name)
db.foo.dropIndexes()
db.foo.getIndexes()
db.foo.ensureIndex(keypattern,options) - options object has these possible
                                         fields: name, unique, dropDups

db.foo.find( [query] , [fields])       - first parameter is an optional
                                         query filter. second parameter
                                         is optional
                                         set of fields to return.
                                    e.g. db.foo.find(
                                                  { x : 77 } ,
                                                  { name : 1 , x : 1 } )
db.foo.find(...).count()
db.foo.find(...).limit(n)
db.foo.find(...).skip(n)
db.foo.find(...).sort(...)
db.foo.findOne([query])

db.foo.getDB() get DB object associated with collection

db.foo.count()
db.foo.group( { key : ..., initial: ..., reduce : ...[, cond: ...] } )

db.foo.renameCollection( newName ) renames the collection

db.foo.stats()
db.foo.dataSize()
db.foo.storageSize() - includes free space allocated to this collection
db.foo.totalIndexSize() - size in bytes of all the indexes
db.foo.totalSize() - storage allocated for all data and indexes
db.foo.validate() (slow)

db.foo.insert(obj)
db.foo.update(query, object[, upsert_bool])
db.foo.save(obj)
db.foo.remove(query)                   - remove objects matching query
                                         remove({}) will remove all

------------------------------------------------------------

顶一下
(0)
踩一下
(0)