Blame view

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