5 ani în urmă
părinte
comite
69ad90b06e
2 a modificat fișierele cu 41 adăugiri și 1 ștergeri
  1. 25 1
      README.md
  2. 16 0
      src/qfw/mongodb/mongodbSim.go

+ 25 - 1
README.md

@@ -3,4 +3,28 @@
 
 - 优化原qfw/util/mongodb工具类,使用qfw/mongodb 替换包。
 > 原工具类每个连接都是一个session,每个session占用两个连接。对此问题进行了解决,并优化空闲连接个数。
- 
+
+## 使用方法
+
+- 全局方法使用 mongodbutil.go文件 (只支持一个连接地址)
+```
+import "qfw/mongodb"
+
+mongodb.InitMongodbPool(2,"192.168.3.207:27083","qfw")  //非集群模式
+mongodb.InitMongodbPool(2,"192.168.3.207:27083","qfw","qfws")  //集群模式
+
+mongodb.FindOne("db",`{}`)
+
+```
+
+- 对象方法使用 mongodbSim.go 文件 (支持多个连接地址)
+
+```
+import "qfw/mongodb"
+
+mgo:=mongodb.NewMongodbPool(2,"192.168.3.207:27083","qfw")  //非集群模式
+mgo:=mongodb.NewMongodbReplPool(2,"192.168.3.207:27083","qfw","qfws")  //集群模式
+
+mgo.FindOne("db",`{}`)
+
+```

+ 16 - 0
src/qfw/mongodb/mongodbSim.go

@@ -21,6 +21,22 @@ type MongodbSim struct {
 	ReplSet     string
 }
 
+func NewMongodbPool(size int, addr, dbName string) *MongodbSim {
+	return NewMongodbReplPool(size, addr, dbName, "")
+}
+
+func NewMongodbReplPool(size int, addr, dbName, replset string) (m *MongodbSim) {
+	m = &MongodbSim{
+		MongodbAddr: addr,
+		DbName:      dbName,
+		Size:        size,
+		ReplSet:     replset,
+	}
+	m.InitPool()
+	return
+}
+
+//全部关闭,一般不用
 func (m *MongodbSim) Destory() {
 L1:
 	for {