Blame view

actions/basic.go 798 Bytes
ee23102d   zhangqijia   支持mongo, grpc接服务器
1
2
3
4
5
  package actions
  
  import (
  	"fmt"
  	"net"
3592dfd3   zhangqijia   重构models, 索引唯一索引
6
  	"pro2d/components/db"
ee23102d   zhangqijia   支持mongo, grpc接服务器
7
  	"pro2d/conf"
3592dfd3   zhangqijia   重构models, 索引唯一索引
8
  	"pro2d/utils"
ee23102d   zhangqijia   支持mongo, grpc接服务器
9
10
11
  )
  
  type BasicServer struct {
eb417b0b   zhangqijia   reactor mongo
12
  	DBName string
ee23102d   zhangqijia   支持mongo, grpc接服务器
13
14
  }
  
eb417b0b   zhangqijia   reactor mongo
15
  func NewServer(db string) *BasicServer {
ee23102d   zhangqijia   支持mongo, grpc接服务器
16
  	return &BasicServer{
eb417b0b   zhangqijia   reactor mongo
17
  		DBName: db,
ee23102d   zhangqijia   支持mongo, grpc接服务器
18
19
20
21
  	}
  }
  
  func (b *BasicServer) Start(sConf *conf.SConf) (net.Listener, error) {
3592dfd3   zhangqijia   重构models, 索引唯一索引
22
23
24
25
26
27
  	//初始化数据库
  	err := db.Connect(conf.GlobalConf.MongoConf.User, conf.GlobalConf.MongoConf.Password, conf.GlobalConf.MongoConf.Host, conf.GlobalConf.MongoConf.Port, conf.GlobalConf.MongoConf.MaxNum, conf.GlobalConf.MongoConf.TimeOut, sConf.DBName)
  	if err != nil {
  		utils.Sugar.Errorf("mongodb init error: %v", err)
  	}
  
ee23102d   zhangqijia   支持mongo, grpc接服务器
28
29
30
31
32
33
34
35
36
37
  	listing := fmt.Sprintf(":%d", sConf.Port)
  	lis, err := net.Listen("tcp", listing)
  	if err != nil {
  		return nil, err
  	}
  	return lis, err
  }
  
  func (b *BasicServer) Close()  {
  }