Blame view

cmd/httpserver/service/http.go 1.23 KB
4a502dd5   zhangqijia   fix: game,account...
1
  package service
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
2
3
  
  import (
a24dea4c   zhangqijia   fix: id自增做了写更新。阵容...
4
  	"math/rand"
765431a4   zhangqijia   增加schema接口, 抽象 mo...
5
  	"pro2d/common"
0e5d52de   zhangqijia   reactor: 重构底层框架1.0
6
  	"pro2d/common/components"
436e0af4   zhangqijia   reactor: dir; Ac...
7
  	"pro2d/common/db/mongoproxy"
15864203   zhangqijia   feat: 增加短信接口
8
  	"pro2d/common/db/redisproxy"
8d983031   zhangqijia   loginReq uid -> t...
9
  	"pro2d/models"
101d1cc1   zhangqijia   feat: 一个基于redis的自...
10
  	"time"
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
11
12
  )
  
0e5d52de   zhangqijia   reactor: 重构底层框架1.0
13
14
  type AccountServer struct {
  	components.IHttp
f415f471   zhangqijia   fix: roleID自增加上限制...
15
  	Sconf *common.SConf
0e5d52de   zhangqijia   reactor: 重构底层框架1.0
16
17
18
19
20
21
  }
  
  func NewAccountServer(version string, port ...string) *AccountServer {
  	return &AccountServer{IHttp: components.NewHttpServer(version, port...)}
  }
  
15864203   zhangqijia   feat: 增加短信接口
22
  func (s *AccountServer) Init(sconf *common.SConf) error {
101d1cc1   zhangqijia   feat: 一个基于redis的自...
23
24
  	s.Sconf = sconf
  
765431a4   zhangqijia   增加schema接口, 抽象 mo...
25
  	//mgo init
a24dea4c   zhangqijia   fix: id自增做了写更新。阵容...
26
  	err := mongoproxy.ConnectMongo(sconf.MongoConf, sconf.ID)
0e5d52de   zhangqijia   reactor: 重构底层框架1.0
27
  
15864203   zhangqijia   feat: 增加短信接口
28
29
  	//redis init
  	if err = redisproxy.ConnectRedis(sconf.RedisConf.DB, sconf.RedisConf.Auth, sconf.RedisConf.Address); err != nil {
0e5d52de   zhangqijia   reactor: 重构底层框架1.0
30
31
  		return err
  	}
765431a4   zhangqijia   增加schema接口, 抽象 mo...
32
  
101d1cc1   zhangqijia   feat: 一个基于redis的自...
33
34
  	models.NewDBSeed(sconf.ID).InitServerDatabase(models.AccountModels())
  	models.DBSeedS().InitAutoIncreUidTable(models.AccountModels())
77f5eec7   zhangqijia   plugin 插件热更 接口
35
36
37
  	return nil
  }
  
101d1cc1   zhangqijia   feat: 一个基于redis的自...
38
39
40
41
42
43
  func (s *AccountServer) TimeOut() {
  	models.DBSeedS().SaveAutoincrementTimer(models.AccountModels())
  
  	components.TimeOut(1*time.Second, s.TimeOut)
  }
  
b3d79719   zhangqijia   fix: 返回值如果code=0则...
44
  func (s *AccountServer) Start() error {
15864203   zhangqijia   feat: 增加短信接口
45
  	if err := s.Init(common.GlobalConf.AccountConf); err != nil {
77f5eec7   zhangqijia   plugin 插件热更 接口
46
47
  		return err
  	}
a24dea4c   zhangqijia   fix: id自增做了写更新。阵容...
48
49
  	//设置随机种子
  	rand.Seed(time.Now().Unix())
101d1cc1   zhangqijia   feat: 一个基于redis的自...
50
51
52
  	//开始定时器
  	s.TimeOut()
  
9a9d092e   zhangqijia   每条连接增加一个定时器,每条连接增...
53
  	return s.IHttp.Start()
0e5d52de   zhangqijia   reactor: 重构底层框架1.0
54
55
  }
  
f415f471   zhangqijia   fix: roleID自增加上限制...
56
57
  func (s *AccountServer) Stop() {
  	s.IHttp.Stop()
f415f471   zhangqijia   fix: roleID自增加上限制...
58
  }