Blame view

test/client.go 947 Bytes
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
  }