ee23102d
zhangqijia
支持mongo, grpc接服务器
|
1
2
3
|
package main
import (
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
4
5
|
"bytes"
"encoding/binary"
|
5d9cf01c
zhangqijia
plugin 热更
|
6
|
"github.com/golang/protobuf/proto"
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
7
|
"net"
|
5d9cf01c
zhangqijia
plugin 热更
|
8
|
"pro2d/protos/pb"
|
cad2b7f3
zhangqijia
reactor: 重构目录, 重构...
|
9
10
|
"pro2d/src/components/logger"
net2 "pro2d/src/components/net"
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
11
12
|
)
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
13
|
func main() {
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
14
|
|
cad2b7f3
zhangqijia
reactor: 重构目录, 重构...
|
15
|
head := &net2.Head{
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
16
|
Length: 0,
|
5d9cf01c
zhangqijia
plugin 热更
|
17
|
Cmd: int32(pb.ProtoCode_LoginRpc),
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
18
19
|
ErrCode: 0,
PreField: 0,
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
20
|
}
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
21
|
|
5d9cf01c
zhangqijia
plugin 热更
|
22
23
24
25
26
|
loginReq := &pb.LoginReq{
Uid: "141815055745814528",
Device: "123123",
}
l, _ :=proto.Marshal(loginReq)
|
88e31175
zhangqijia
grpc 增加tls, 使用san证书
|
27
|
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
28
29
|
b := net2.MsgPkg{
Head: head,
|
5d9cf01c
zhangqijia
plugin 热更
|
30
|
Body: l,
|
88e31175
zhangqijia
grpc 增加tls, 使用san证书
|
31
|
}
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
32
33
34
|
head.Length = int32(16 + len(b.Body))
buf := &bytes.Buffer{}
err := binary.Write(buf, binary.BigEndian, head)
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
35
|
if err != nil {
|
cad2b7f3
zhangqijia
reactor: 重构目录, 重构...
|
36
|
logger.Error("err: %v, head: %v", err, head)
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
37
38
|
return
}
|
cad2b7f3
zhangqijia
reactor: 重构目录, 重构...
|
39
|
logger.Debug("head: %v", head)
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
40
|
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
41
|
err = binary.Write(buf, binary.BigEndian, b.Body)
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
42
|
if err != nil {
|
cad2b7f3
zhangqijia
reactor: 重构目录, 重构...
|
43
|
logger.Error("err: %v, msg: %v", err, b.Body)
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
44
45
|
return
}
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
46
|
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
47
|
client, err := net.Dial("tcp", "localhost:8849")
|
1584eb4b
zhangqijia
修复创建唯一索引的bug
|
48
|
if err != nil {
|
cad2b7f3
zhangqijia
reactor: 重构目录, 重构...
|
49
|
logger.Error(err)
|
1584eb4b
zhangqijia
修复创建唯一索引的bug
|
50
51
|
return
}
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
52
|
client.Write(buf.Bytes())
|
88e31175
zhangqijia
grpc 增加tls, 使用san证书
|
53
|
}
|