clienttest/action_login.go

@@ -1,105 +0,0 @@
-package main
-
-import (
-	"encoding/json"
-	"fmt"
-	"math/rand"
-	"mongo.games.com/game/protocol/activity"
-	"mongo.games.com/goserver/core/timer"
-	"time"
-
-	"mongo.games.com/goserver/core/logger"
-	"mongo.games.com/goserver/core/netlib"
-
-	"mongo.games.com/game/model"
-	"mongo.games.com/game/proto"
-	loginproto "mongo.games.com/game/protocol/login"
-	playerproto "mongo.games.com/game/protocol/player"
-)
-
-func init() {
-	// 心跳
-	netlib.Register(int(loginproto.GatePacketID_PACKET_SC_PONG), loginproto.SCPong{}, SCPong)
-	// 登录
-	netlib.Register(int(loginproto.LoginPacketID_PACKET_SC_LOGIN), loginproto.SCLogin{}, SCLogin)
-	// 玩家信息
-	netlib.Register(int(playerproto.PlayerPacketID_PACKET_SC_PLAYERDATA), playerproto.SCPlayerData{}, SCPlayerData)
-
-	netlib.Register(int(activity.PushCoinPacketID_PACKET_SCPushCoinInfo), activity.SCPushCoinInfo{}, SCPrint)
-}
-
-func SCPong(s *netlib.Session, packetid int, data interface{}) error {
-	accountID := s.GetAttribute(SessionAttributeClientAccountId)
-	logger.Logger.Tracef("SCPong username:%v %v", accountID, data)
-	return nil
-}
-
-func SCLogin(s *netlib.Session, packetid int, data interface{}) error {
-	logger.Logger.Trace("SCLogin ", data)
-
-	msg, ok := data.(*loginproto.SCLogin)
-	if !ok {
-		return nil
-	}
-
-	if msg.GetOpRetCode() != loginproto.OpResultCode_OPRC_Sucess {
-		accountID := s.GetAttribute(SessionAttributeClientAccountId)
-		logger.Logger.Error("登录失败 ", accountID)
-		s.Close()
-		return nil
-	}
-
-	csPlayerData := &playerproto.CSPlayerData{
-		AccId: msg.GetAccId(),
-	}
-	pp := &model.PlayerParams{
-		Platform:     1,
-		Ip:           fmt.Sprintf("%v.%v.%v.%v", 1+rand.Int31n(255), 1+rand.Int31n(255), 1+rand.Int31n(255), 1+rand.Int31n(255)),
-		City:         "北京",
-		Logininmodel: "app",
-	}
-	d, err := json.Marshal(pp)
-	if err == nil {
-		csPlayerData.Params = proto.String(string(d))
-	}
-
-	s.Send(int(playerproto.PlayerPacketID_PACKET_CS_PLAYERDATA), csPlayerData)
-	logger.Logger.Info("登录成功 ", msg.GetAccId())
-	return nil
-}
-
-func SCPlayerData(s *netlib.Session, packetid int, data interface{}) error {
-	logger.Logger.Trace("SCPlayerData ", data)
-	msg, ok := data.(*playerproto.SCPlayerData)
-	if !ok {
-		return nil
-	}
-
-	if msg.GetOpRetCode() != playerproto.OpResultCode_OPRC_Sucess {
-		accountID := s.GetAttribute(SessionAttributeClientAccountId)
-		logger.Logger.Errorf("获取玩家信息失败 %v", accountID)
-		s.Close()
-		return nil
-	}
-
-	s.SetAttribute(SessionAttributeUser, msg)
-
-	StartSessionPingTimer(s, timer.TimerActionWrapper(func(h timer.TimerHandle, ud interface{}) bool {
-		if !s.IsConned() {
-			StopSessionPingTimer(s)
-			return false
-		}
-		pack := &loginproto.CSPing{}
-		s.Send(int(loginproto.GatePacketID_PACKET_CS_PING), pack)
-		return true
-	}), nil, time.Second*time.Duration(60+rand.Int31n(100)), -1)
-
-	s.Send(int(activity.PushCoinPacketID_PACKET_CSPushCoinInfo), &activity.CSPushCoinInfo{})
-
-	return nil
-}
-
-func SCPrint(s *netlib.Session, packetid int, data interface{}) error {
-	logger.Logger.Info("SCPrint ", data)
-	return nil
-}

clienttest/config.go

@@ -1,35 +0,0 @@
-package main
-
-import (
-	"mongo.games.com/goserver/core"
-	"mongo.games.com/goserver/core/logger"
-	"mongo.games.com/goserver/core/netlib"
-)
-
-var Config = &Configuration{}
-
-type Configuration struct {
-	Count    int                  // 机器人总数
-	AppId    string               // appID
-	Connects netlib.SessionConfig // 网络连接配置
-}
-
-func (this *Configuration) Name() string {
-	return "benchmark"
-}
-
-func (this *Configuration) Init() error {
-	logger.Logger.Tracef("%+v", *this)
-	if this.Count == 0 {
-		this.Count = 20
-	}
-	return nil
-}
-
-func (this *Configuration) Close() error {
-	return nil
-}
-
-func init() {
-	core.RegistePackage(Config)
-}

clienttest/config.yaml

@@ -1,67 +0,0 @@
-netlib:
-  SrvInfo:
-    Name: BenchmarkServer
-    Type: 9
-    Id: 902
-    AreaID: 1
-    Banner:
-      - =================
-      - benchmark server
-      - =================
-  IoServices: []
-module:
-  Options:
-    QueueBacklog: 1024
-    MaxDone: 1024
-    Interval: 100
-executor:
-  Options:
-    QueueBacklog: 1024
-    MaxDone: 1024
-    Interval: 0
-  Worker:
-    WorkerCnt: 8
-    Options:
-      QueueBacklog: 1024
-      MaxDone: 1024
-      Interval: 0
-timer:
-  Options:
-    QueueBacklog: 1024
-    MaxDone: 1024
-    Interval: 100
-signal:
-  SupportSignal: true
-cmdline:
-  SupportCmdline: true
-benchmark:
-  Count: 1
-  AppId: 5c56d1644966f078bfb90c71
-  Connects:
-    Id: 402
-    Type: 4
-    AreaId: 1
-    Name: ClientService
-    Ip: 127.0.0.1
-    Port: 11001
-    Protocol: tcp
-    Path: /
-    MaxDone: 200
-    MaxPend: 200
-    MaxPacket: 65535
-    MaxConn: 2000
-    RcvBuff: 4096
-    SndBuff: 4096
-    WriteTimeout: 3600
-    ReadTimeout: 3600
-    SoLinger: 10
-    IsInnerLink: true
-    NoDelay: true
-    SupportFragment: true
-    AuthKey: www.jxjy.games.cn
-    IsClient: true
-    AllowMultiConn: true
-    FilterChain:
-      - session-filter-auth
-    HandlerChain:
-      - handler-gate-session

clienttest/connect.go

@@ -1,69 +0,0 @@
-package main
-
-import (
-	"time"
-
-	"mongo.games.com/goserver/core/logger"
-	"mongo.games.com/goserver/core/module"
-	"mongo.games.com/goserver/core/netlib"
-)
-
-const (
-	// RobotSessionStartId 机器人session开始id
-	RobotSessionStartId = 100000000
-)
-
-var (
-	BenchMarkModule     = &BenchMark{}
-	WaitConnectSessions []*netlib.SessionConfig
-)
-
-// NewSession 新建session
-// id 连接id, 默认自动分配
-func NewSession(id ...int) {
-	cfg := Config.Connects
-	if len(id) > 0 && id[0] > 0 {
-		cfg.Id = id[0]
-	} else {
-		BenchMarkModule.idx++
-		cfg.Id = BenchMarkModule.idx
-	}
-	cfg.Init()
-	logger.Logger.Info("waite connect session id=", cfg.Id)
-	WaitConnectSessions = append(WaitConnectSessions, &cfg)
-}
-
-type BenchMark struct {
-	idx int
-}
-
-func (m *BenchMark) ModuleName() string {
-	return "benchmark-module"
-}
-
-func (m *BenchMark) Init() {
-	m.idx = RobotSessionStartId
-	for i := 0; i < Config.Count; i++ {
-		NewSession()
-	}
-}
-
-// Update 机器开始连接游戏服务器
-func (m *BenchMark) Update() {
-	n := len(WaitConnectSessions)
-	if n > 0 {
-		config := WaitConnectSessions[n-1]
-		WaitConnectSessions = WaitConnectSessions[:n-1]
-		if err := netlib.Connect(config); err != nil {
-			logger.Logger.Error("netlib.Connect error", err)
-		}
-	}
-}
-
-func (m *BenchMark) Shutdown() {
-	module.UnregisteModule(m)
-}
-
-func init() {
-	module.RegisteModule(BenchMarkModule, time.Millisecond, 1)
-}

clienttest/constants.go

@@ -1,31 +0,0 @@
-package main
-
-import (
-	"mongo.games.com/goserver/core/netlib"
-	"mongo.games.com/goserver/core/timer"
-	"time"
-)
-
-const (
-	SessionAttributeClientAccountId int = iota // 账号
-	SessionAttributeUser
-	SessionAttributePingTimer
-)
-
-func StartSessionPingTimer(s *netlib.Session, act timer.TimerAction, ud interface{}, interval time.Duration, times int) bool {
-	StopSessionPingTimer(s)
-	if hTimer, ok := timer.StartTimer(act, ud, interval, times); ok {
-		s.SetAttribute(SessionAttributePingTimer, hTimer)
-		return true
-	}
-	return false
-}
-
-func StopSessionPingTimer(s *netlib.Session) {
-	if h, ok := s.GetAttribute(SessionAttributePingTimer).(timer.TimerHandle); ok {
-		if h != timer.TimerHandle(0) {
-			timer.StopTimer(h)
-			s.RemoveAttribute(SessionAttributePingTimer)
-		}
-	}
-}

clienttest/gatesessionhandler.go

@@ -1,97 +0,0 @@
-package main
-
-import (
-	"crypto/md5"
-	"encoding/hex"
-	"encoding/json"
-	"fmt"
-	"io"
-	"math/rand"
-	"mongo.games.com/game/common"
-	"mongo.games.com/game/model"
-	loginproto "mongo.games.com/game/protocol/login"
-	"mongo.games.com/goserver/core/logger"
-	"mongo.games.com/goserver/core/netlib"
-	"strconv"
-	"sync/atomic"
-	"time"
-)
-
-/*
- 添加到客户端管理器，管理器负责登录
- 当连接断开时，从管理器中移除，判断是否需要重连
-*/
-
-const (
-	GateSessionHandlerName = "handler-gate-session"
-)
-
-type GateSessionHandler struct {
-	netlib.BasicSessionHandler
-}
-
-func (g *GateSessionHandler) GetName() string {
-	return GateSessionHandlerName
-}
-
-func (g *GateSessionHandler) GetInterestOps() uint {
-	return 1<<netlib.InterestOps_Opened |
-		1<<netlib.InterestOps_Closed
-}
-
-func (g *GateSessionHandler) OnSessionOpened(s *netlib.Session) {
-	// 登录账号
-	StartLogin(s)
-	return
-}
-
-func (g *GateSessionHandler) OnSessionClosed(s *netlib.Session) {
-
-}
-
-func init() {
-	netlib.RegisteSessionHandlerCreator(GateSessionHandlerName, func() netlib.SessionHandler {
-		return &GateSessionHandler{}
-	})
-}
-
-var UserNameIndex int64
-
-func StartLogin(s *netlib.Session) {
-	ts := time.Now().UnixNano()
-	username := fmt.Sprintf("benchmark-%v", atomic.AddInt64(&UserNameIndex, 1))
-	s.SetAttribute(SessionAttributeClientAccountId, username)
-	csLogin := &loginproto.CSLogin{
-		Username:    username,
-		TimeStamp:   ts,
-		Platform:    "1",
-		Channel:     "",
-		PlatformTag: "test.win88.yy_android",
-	}
-
-	params := &model.PlayerParams{
-		Ip:           fmt.Sprintf("%v.%v.%v.%v", 1+rand.Int31n(255), 1+rand.Int31n(255), 1+rand.Int31n(255), 1+rand.Int31n(255)),
-		City:         "北京",
-		Platform:     1,
-		Logininmodel: "app",
-	}
-	data, err := json.Marshal(params)
-	if err == nil {
-		csLogin.Params = string(data[:])
-	}
-
-	h := md5.New()
-	io.WriteString(h, fmt.Sprintf("%v%v", username, Config.AppId))
-	pwd := hex.EncodeToString(h.Sum(nil))
-	h.Reset()
-	io.WriteString(h, fmt.Sprintf("%v%v%v", pwd, Config.AppId, ts))
-	pwd = hex.EncodeToString(h.Sum(nil))
-	csLogin.Password = pwd
-
-	csLogin.LoginType = 0
-	csLogin.Sign = common.MakeMd5String(csLogin.GetUsername(), csLogin.GetPassword(),
-		strconv.Itoa(int(csLogin.GetTimeStamp())), csLogin.GetParams(), Config.AppId)
-
-	s.Send(int(loginproto.LoginPacketID_PACKET_CS_LOGIN), csLogin)
-	logger.Logger.Infof("账号 [%v] 开始登录", username)
-}

clienttest/logger.xml

@@ -1,22 +0,0 @@
-<?xml version="1.0" encoding="utf-8" ?>
-	<seelog type="adaptive" mininterval="2000000" maxinterval="100000000" critmsgcount="500" minlevel="trace">
-        <exceptions>
-            <exception filepattern="test*" minlevel="error"/>
-        </exceptions>
-        <outputs formatid="all">
-            <rollingfile formatid="all" type="size" filename="./all.log" maxsize="50000000" maxrolls="5" />
-            <filter levels="info,trace,warn,error">
-              <console formatid="fmtinfo"/>
-            </filter>
-            <filter levels="error,critical" formatid="fmterror">
-              <console/>
-              <file path="errors.log"/>
-            </filter>
-        </outputs>
-        <formats>
-            <format id="fmtinfo" format="[%Date][%Time] [%Level] %Msg%n"/>
-            <format id="fmterror" format="[%Date][%Time] [%LEVEL] [%FuncShort @ %File.%Line] %Msg%n"/>
-            <format id="all" format="[%Date][%Time] [%Level] [@ %File.%Line] %Msg%n"/>
-            <format id="criticalemail" format="Critical error on our server!\n    %Time %Date %RelFile %Func %Msg \nSent by Seelog"/>
-        </formats>
-    </seelog>

clienttest/main.go

@@ -1,24 +0,0 @@
-package main
-
-import (
-	_ "mongo.games.com/game"
-	"mongo.games.com/goserver/core"
-	"mongo.games.com/goserver/core/module"
-)
-
-func main() {
-	defer core.ClosePackages()
-	core.LoadPackages("config.yaml")
-	// core hook
-	core.RegisteHook(core.HOOK_BEFORE_START, func() error {
-
-		return nil
-	})
-	core.RegisteHook(core.HOOK_AFTER_STOP, func() error {
-
-		return nil
-	})
-	// module模块
-	waiter := module.Start()
-	waiter.Wait("main()")
-}

data/DB_PigBank_Diamond.dat

@@ -1,4 +1,4 @@
 
 


 (€­β8–
@΅θ;PdX–
`c
-< ((€­β2ΕΈ
2συ
8¬@Άθ;Jσυ
JΖΈ
PdX¬`Η

+< ((€­β2ΕΈ
2συ
8¬@Άθ;JΖΈ
Jσυ
PdX¬`Η

 ?<18>ΑΧ/ 2(€­β2ΕΈ2συ
8ξ@£θ;JΖΈJσυ
PdXξ`σ

data/DB_PropExchange.json

@@ -127,6 +127,48 @@
 			"Custom": {
 				"1": 1
 			}
-		}
+		},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{},
+		{}
 	]
 }