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
|
}
|