ee23102d
zhangqijia
支持mongo, grpc接服务器
|
1
2
3
|
package main
import (
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
4
5
6
|
"bytes"
"encoding/binary"
"net"
|
cad2b7f3
zhangqijia
reactor: 重构目录, 重构...
|
7
8
|
"pro2d/src/components/logger"
net2 "pro2d/src/components/net"
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
9
10
|
)
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
11
|
func main() {
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
12
|
|
cad2b7f3
zhangqijia
reactor: 重构目录, 重构...
|
13
|
head := &net2.Head{
|
fee11bff
zhangqijia
客户端无法使用grpc热更,不用g...
|
14
15
16
17
|
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 {
|
cad2b7f3
zhangqijia
reactor: 重构目录, 重构...
|
29
|
logger.Error("err: %v, head: %v", err, head)
|
ee23102d
zhangqijia
支持mongo, grpc接服务器
|
30
31
|
return
}
|
cad2b7f3
zhangqijia
reactor: 重构目录, 重构...
|
32
|
logger.Debug("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 {
|
cad2b7f3
zhangqijia
reactor: 重构目录, 重构...
|
36
|
logger.Error("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 {
|
cad2b7f3
zhangqijia
reactor: 重构目录, 重构...
|
42
|
logger.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
|
}
|