mongoDB 实现主从读写分离实现的实例代码 - 主机乐

mongodb_read.host=10.0.0.45mongodb_read.port=27017mongodb_read.apname=ecspmongodb_read.username=mongodb_read.password=mongodb_write.host=10.0.0.46mongodb_write.port=27017mongodb_write.apname=ecspmongodb_write.username=mongodb_write.password=

<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"xmlns:mongo="http://www.springframework.org/schema/data/mongo"xsi:schemaLocation="http://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context-2.0.xsdhttp://www.springframework.org/schema/data/mongohttp://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsdhttp://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-2.0.xsd"><bean id="propertyConfigurer"><property name="locations"><list><value>classpath:resources.properties</value></list></property></bean><bean id="mongoServerReadAddress" ><constructor-arg value="${mongodb_read.host}"></constructor-arg><constructor-arg value="${mongodb_read.port}"></constructor-arg></bean><bean id="chexunMongoReadOptions" ><property name="username" value="${mongodb_read.username}" /><property name="password" value="${mongodb_read.password}" /><property name="dbname" value="${mongodb_read.apname}" /><property name="connectionsPerHost" value="100" /><property name="threadsAllowedToBlockForConnectionMultiplier"value="5" /><property name="slaveOk" value="true" /></bean><bean id="mongo_read" ><constructor-arg ref="mongoServerReadAddress"></constructor-arg><constructor-arg ref="chexunMongoReadOptions"></constructor-arg></bean><bean id="mongoServerWriteAddress" ><constructor-arg value="${mongodb_write.host}"></constructor-arg><constructor-arg value="${mongodb_write.port}"></constructor-arg></bean><bean id="chexunMongoWriteOptions" ><property name="username" value="${mongodb_write.username}" /><property name="password" value="${mongodb_write.password}" /><property name="dbname" value="${mongodb_write.apname}" /><property name="connectionsPerHost" value="100" /><property name="threadsAllowedToBlockForConnectionMultiplier"value="5" /></bean><bean id="mongo_write" ><constructor-arg ref="mongoServerWriteAddress"></constructor-arg><constructor-arg ref="chexunMongoWriteOptions"></constructor-arg></bean><bean id="mongoHelper" ><constructor-arg ref="mongo_read"></constructor-arg><constructor-arg ref="mongo_write"></constructor-arg></bean></beans>

package com.ecsp.chexun.mongo;import javax.net.SocketFactory;import com.mongodb.DBDecoderFactory;import com.mongodb.MongoOptions;/** * Mongo配置类 ** @author vincent.he * @version 1.0, Created on 2012-3-12 **/public class ChexunMongoOptions extends MongoOptions{private String username;private String password;private String dbname;public ChexunMongoOptions(){super();}public void setDescription(String description) {this.description = description;}public void setConnectionsPerHost(int connectionsPerHost) {this.connectionsPerHost = connectionsPerHost;}public void setThreadsAllowedToBlockForConnectionMultiplier(int threadsAllowedToBlockForConnectionMultiplier) {this.threadsAllowedToBlockForConnectionMultiplier = threadsAllowedToBlockForConnectionMultiplier;}public void setMaxWaitTime(int maxWaitTime) {this.maxWaitTime = maxWaitTime;}public void setConnectTimeout(int connectTimeout) {this.connectTimeout = connectTimeout;}public void setSocketTimeout(int socketTimeout) {this.socketTimeout = socketTimeout;}public void setSocketKeepAlive(boolean socketKeepAlive) {this.socketKeepAlive = socketKeepAlive;}public void setAutoConnectRetry(boolean autoConnectRetry) {this.autoConnectRetry = autoConnectRetry;}public void setMaxAutoConnectRetryTime(long maxAutoConnectRetryTime) {this.maxAutoConnectRetryTime = maxAutoConnectRetryTime;}public void setSlaveOk(boolean slaveOk) {this.slaveOk = slaveOk;}public void setDbDecoderFactory(DBDecoderFactory dbDecoderFactory) {this.dbDecoderFactory = dbDecoderFactory;}public void setSafe(boolean safe) {this.safe = safe;}public void setW(int w) {this.w = w;}public void setWtimeout(int wtimeout) {this.wtimeout = wtimeout;}public void setFsync(boolean fsync) {this.fsync = fsync;}public void setJ(boolean j) {this.j = j;}public void setSocketFactory(SocketFactory socketFactory) {this.socketFactory = socketFactory;}public String getUsername() {return username;}public void setUsername(String username) {this.username = username;}public String getPassword() {return password;}public void setPassword(String password) {this.password = password;}public String getDbname() {return dbname;}public void setDbname(String dbname) {this.dbname = dbname;}}

package com.ecsp.chexun.mongo;import java.util.List;import com.mongodb.BasicDBObject;import com.mongodb.CommandResult;import com.mongodb.DB;import com.mongodb.DBCollection;import com.mongodb.DBObject;import com.mongodb.Mongo;/** * mongo 操做方法 * @author zhanglibing **/public class MongoHelper {private Mongo mongo;private Mongo mongo_read;private Mongo mongo_write;private String dataBaseName = "cxec";public MongoHelper(){}public MongoHelper(Mongo mongo,Mongo mongo_read,Mongo mongo_write){this.mongo = mongo;this.mongo_read = mongo_read;this.mongo_write = mongo_write;}// public MongoHelper(String dbName){// dataBaseName = dbName; // }public int add(String collectionName,BasicDBObject dbObject){// DB db = MongoManager.getDB(dataBaseName); DB db = mongo_write.getDB(dataBaseName);DBCollection dbc = db.getCollection(collectionName); return dbc.save(dbObject).getN();}//批量添加public int addAll( String collectionName,List<DBObject> list){// DB db = MongoManager.getDB(dataBaseName); DB db = mongo_write.getDB(dataBaseName);DBCollection dbc = db.getCollection(collectionName); return dbc.insert(list).getN();}public int isExists(String collectionName,BasicDBObject query){// DB db = MongoManager.getDB(dataBaseName); DB db = mongo_read.getDB(dataBaseName);DBCollection dbc = db.getCollection(collectionName);return dbc.find(query).size(); }public List<DBObject> get(String collectionName,BasicDBObject query){// DB db = MongoManager.getDB(dataBaseName);DB db = mongo_read.getDB(dataBaseName);DBCollection dbc = db.getCollection(collectionName);return dbc.find(query).toArray();}public int getCount(String collectionName,BasicDBObject query){// DB db = MongoManager.getDB(dataBaseName);DB db = mongo_read.getDB(dataBaseName);DBCollection dbc = db.getCollection(collectionName);return dbc.find(query).count();}public List<DBObject> get(String collectionName,BasicDBObject query,BasicDBObject keys){// DB db = MongoManager.getDB(dataBaseName);DB db = mongo_read.getDB(dataBaseName);DBCollection dbc = db.getCollection(collectionName);return dbc.find(query, keys).toArray();}/*** * 获取mongo 中 collection 的值 * @param collectionName * @param query 查询条件 * @param keys查询字段 * @param batchSize 返回个数 * @return */public List<DBObject> get(String collectionName,BasicDBObject query,BasicDBObject keys,BasicDBObject orderBy,int batchSize){// DB db = MongoManager.getDB(dataBaseName);DB db = mongo_read.getDB(dataBaseName);DBCollection dbc = db.getCollection(collectionName);if(orderBy != null){return dbc.find(query, keys).sort(orderBy).limit(batchSize).toArray(); }return dbc.find(query, keys).limit(batchSize).toArray();}public List<DBObject> get(String collectionName,BasicDBObject query,BasicDBObject keys,BasicDBObject orderBy,int batchSize,int n){// DB db = MongoManager.getDB(dataBaseName);DB db = mongo_read.getDB(dataBaseName);DBCollection dbc = db.getCollection(collectionName);if(orderBy != null){return dbc.find(query, keys).sort(orderBy).limit(batchSize).skip(n).toArray(); }return dbc.find(query, keys).limit(batchSize).toArray();}public List<DBObject> get(String collectionName,DBObject query,int batchSize){// DB db = MongoManager.getDB(dataBaseName);DB db = mongo_read.getDB(dataBaseName);DBCollection dbc = db.getCollection(collectionName);return dbc.find(query).limit(batchSize).toArray();}public List<DBObject> get(String collectionName,int number){DB db = mongo_read.getDB(dataBaseName);DBCollection dbc = db.getCollection(collectionName);List<DBObject> dboList = dbc.find().skip(0).limit(number).toArray();return dboList;}public List<DBObject> get(String collectionName,BasicDBObject query,BasicDBObject orderBy,int n,int pageSize ){DB db = mongo_read.getDB(dataBaseName);DBCollection dbc = db.getCollection(collectionName);List<DBObject> dboList = dbc.find(query).sort(orderBy).skip(n).limit(pageSize).toArray();return dboList;}public List<DBObject> get(String collectionName,BasicDBObject query,int top ){DB db = mongo_read.getDB(dataBaseName);DBCollection dbc = db.getCollection(collectionName);List<DBObject> dboList = dbc.find(query).skip(0).limit(top).toArray();return dboList;}public List<DBObject> get(String collectionName,DBObject query,DBObject orderBy,int batchSize){// DB db = MongoManager.getDB(dataBaseName);DB db = mongo_read.getDB(dataBaseName);DBCollection dbc = db.getCollection(collectionName);return dbc.find(query).sort(orderBy).limit(batchSize).toArray();}public int reomve(String collectionName,BasicDBObject o){// DB db = MongoManager.getDB(dataBaseName);DB db = mongo_write.getDB(dataBaseName);DBCollection dbc = db.getCollection(collectionName);return dbc.remove(o).getN();}public int edit(String collectionName,BasicDBObject query,BasicDBObject update){// DB db = MongoManager.getDB(dataBaseName);DB db = mongo_write.getDB(dataBaseName);DBCollection dbc = db.getCollection(collectionName);return dbc.update(query, update).getN();//return dbc.updateMulti(query, update).getN();}public int edit(String cmd){// DB db = MongoManager.getDB(dataBaseName);DB db = mongo.getDB(dataBaseName);CommandResult cmdResult = db.command(cmd);if(cmdResult.ok()){return 1;}return 0;}// public DBCollection get(String collectionName){////DB db = MongoManager.getDB(dataBaseName);// DB db = mongo.getDB(dataBaseName);// return db.getCollection(collectionName);// }public void setMongo(Mongo mongo) {this.mongo = mongo;}public void setMongo_read(Mongo mongo_read) {this.mongo_read = mongo_read;}public void setMongo_write(Mongo mongo_write) {this.mongo_write = mongo_write;}}

帮助中心/最新通知

所有文章

【服务器相关】mongoDB 实现主从读写分离实现的实例代码