wangkaiyue 5 年之前
父節點
當前提交
155f769fb3
共有 1 個文件被更改,包括 15 次插入12 次删除
  1. 15 12
      core/src/main.go

+ 15 - 12
core/src/main.go

@@ -29,17 +29,20 @@ import (
 	"qfw/util/fsw"
 	ip "qfw/util/ip17mon"
 	"qfw/util/mongodb"
+	mongodbutil "qfw/util/mongodbutil"
 	"qfw/util/redis"
 	"time"
 
-	"github.com/go-xweb/httpsession"
-	"github.com/go-xweb/xweb"
 	"qfw/jyelastic"
 	//_ "qfw/util/sq"
 	"qfw/coreutil"
 	"qfw/util/mysql"
 	_ "qfw/yellowpage"
 	"runtime"
+	ca "ucbsutil/cassandra"
+
+	"github.com/go-xweb/httpsession"
+	"github.com/go-xweb/xweb"
 )
 
 //初始化
@@ -54,21 +57,21 @@ func init() {
 		util.ReadConfig(configfile, &SysConfig)
 	}
 	//初始化cassandra
-	//ca.ViewCacheLen = true
-	//ca.InitCassandra("jianyu", SysConfig.Cassandrasize, SysConfig.Cassandra)
+	ca.ViewCacheLen = true
+	ca.InitCassandra("jianyu", SysConfig.Cassandrasize, SysConfig.Cassandra)
 
 	//mongodb初始化
 	//util.MongodbAddr = SysConfig.Mongodbservers
 	mongodb.InitMongodbPool(SysConfig.MongodbPoolSize, SysConfig.Mongodbservers, SysConfig.MongodbName)
 	//企业mongodb初始化
-	//conf := *new(mongodbutil.PoolConfig)
-	//conf.Addr = SysConfig.EntMongodbservers
-	//conf.Alias = SysConfig.EntMongodbAlias
-	//conf.DB = SysConfig.EntMongodbName
-	//conf.Size = SysConfig.EntMongodbPoolSize
-	//mongodbutil.Config = append(mongodbutil.Config, conf)
-	//
-	//mongodbutil.InitMongodbPool()
+	conf := *new(mongodbutil.PoolConfig)
+	conf.Addr = SysConfig.EntMongodbservers
+	conf.Alias = SysConfig.EntMongodbAlias
+	conf.DB = SysConfig.EntMongodbName
+	conf.Size = SysConfig.EntMongodbPoolSize
+	mongodbutil.Config = append(mongodbutil.Config, conf)
+
+	mongodbutil.InitMongodbPool()
 	//mysql 数据导出订单
 	coreutil.Mysql = &mysql.Mysql{
 		Address:  SysConfig.Mysql["address"],