ee23102d
zhangqijia
支持mongo, grpc接服务器
|
1
2
3
|
package main
import (
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
4
5
6
7
|
"bytes"
"encoding/binary"
"net"
net2 "pro2d/components/net"
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
8
9
10
|
"pro2d/utils"
)
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
11
|
func main() {
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
12
|
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
13
14
15
16
17
|
head := net2.Head{
Length: 0,
Cmd: 1,
ErrCode: 0,
PreField: 0,
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
18
|
}
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
19
|
|
88e31175
zhangqijia
grpc 增加tls, 使用san证书
|
20
|
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
21
22
23
|
b := net2.MsgPkg{
Head: head,
Body: []byte("hello world"),
|
88e31175
zhangqijia
grpc 增加tls, 使用san证书
|
24
|
}
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
25
26
27
|
head.Length = int32(16 + len(b.Body))
buf := &bytes.Buffer{}
err := binary.Write(buf, binary.BigEndian, head)
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
28
|
if err != nil {
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
29
|
utils.Sugar.Errorf("err: %v, head: %v", err, head)
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
30
31
|
return
}
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
32
|
utils.Sugar.Debugf("head: %v", head)
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
33
|
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
34
|
err = binary.Write(buf, binary.BigEndian, b.Body)
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
35
|
if err != nil {
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
36
|
utils.Sugar.Errorf("err: %v, msg: %v", err, b.Body)
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
37
38
|
return
}
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
39
|
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
40
|
client, err := net.Dial("tcp", "localhost:8849")
|
1584eb4b
zhangqijia
修复创建唯一索引的bug
|
41
|
if err != nil {
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
42
|
utils.Sugar.Error(err)
|
1584eb4b
zhangqijia
修复创建唯一索引的bug
|
43
44
|
return
}
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
45
46
|
client.Write(buf.Bytes())
select {}
|
88e31175
zhangqijia
grpc 增加tls, 使用san证书
|
47
|
}
|