Blame view

cmd/test/client.go 831 Bytes
ee23102d   zhangqijia   支持mongo, grpc接服务器
1
2
3
  package main
  
  import (
5d9cf01c   zhangqijia   plugin 热更
4
  	"github.com/golang/protobuf/proto"
54b3f133   zhangqijia   add connector int...
5
  	"pro2d/common"
0e5d52de   zhangqijia   reactor: 重构底层框架1.0
6
  	"pro2d/common/components"
765431a4   zhangqijia   增加schema接口, 抽象 mo...
7
  	"pro2d/common/logger"
7f269318   zhangqijia   add pb.go; 添加关闭连接...
8
  	"pro2d/pb"
98b0736d   zhangqijia   添加定时器, 检查心跳
9
  	"time"
ee23102d   zhangqijia   支持mongo, grpc接服务器
10
11
  )
  
fee11bff   zhangqijia   客户端无法使用grpc热更,不用g...
12
  func main() {
ee23102d   zhangqijia   支持mongo, grpc接服务器
13
  
0e5d52de   zhangqijia   reactor: 重构底层框架1.0
14
  	head := &components.PBHead{
fee11bff   zhangqijia   客户端无法使用grpc热更,不用g...
15
  		Length:   0,
0e5d52de   zhangqijia   reactor: 重构底层框架1.0
16
  		Cmd:      uint32(pb.ProtoCode_LoginReq),
fee11bff   zhangqijia   客户端无法使用grpc热更,不用g...
17
18
  		ErrCode:  0,
  		PreField: 0,
ee23102d   zhangqijia   支持mongo, grpc接服务器
19
  	}
ee23102d   zhangqijia   支持mongo, grpc接服务器
20
  
5d9cf01c   zhangqijia   plugin 热更
21
  	loginReq := &pb.LoginReq{
b499527e   zhangqijia   feat: 消息包用aes加密
22
  		Token:  "141815055745814528",
5d9cf01c   zhangqijia   plugin 热更
23
24
  		Device: "123123",
  	}
b499527e   zhangqijia   feat: 消息包用aes加密
25
  	l, _ := proto.Marshal(loginReq)
88e31175   zhangqijia   grpc 增加tls, 使用san证书
26
  
54b3f133   zhangqijia   add connector int...
27
28
  	options := []components.ConnectorOption{
  		components.WithCtorCount(common.GlobalConf.TestClient.Count),
b499527e   zhangqijia   feat: 消息包用aes加密
29
  		components.WithCtorSplitter(components.NewPBSplitter(nil)),
88e31175   zhangqijia   grpc 增加tls, 使用san证书
30
  	}
ee23102d   zhangqijia   支持mongo, grpc接服务器
31
  
54b3f133   zhangqijia   add connector int...
32
33
  	client := components.NewConnector(common.GlobalConf.TestClient.Ip, common.GlobalConf.TestClient.Port, options...)
  	if err := client.Connect(); err != nil {
cad2b7f3   zhangqijia   reactor: 重构目录, 重构...
34
  		logger.Error(err)
1584eb4b   zhangqijia   修复创建唯一索引的bug
35
36
  		return
  	}
98b0736d   zhangqijia   添加定时器, 检查心跳
37
  
b499527e   zhangqijia   feat: 消息包用aes加密
38
  	for {
54b3f133   zhangqijia   add connector int...
39
  		client.Send(head.Cmd, l)
b499527e   zhangqijia   feat: 消息包用aes加密
40
  		time.Sleep(1 * time.Second)
98b0736d   zhangqijia   添加定时器, 检查心跳
41
  	}
b499527e   zhangqijia   feat: 消息包用aes加密
42
  }