main_svr.go 482 B

123456789101112131415161718192021222324252627282930
  1. package main
  2. import (
  3. "fmt"
  4. "log"
  5. "math"
  6. "net"
  7. "research/grpc_msg_size/pb"
  8. "google.golang.org/grpc"
  9. )
  10. func init() {
  11. log.SetFlags(log.Lmicroseconds | log.LstdFlags | log.Lshortfile)
  12. }
  13. func main() {
  14. addr := fmt.Sprintf(":%d", 55555)
  15. lis, err := net.Listen("tcp", addr)
  16. if err != nil {
  17. log.Fatal(err)
  18. }
  19. s := grpc.NewServer(grpc.MaxRecvMsgSize(math.MaxInt32))
  20. pb.RegisterTestServer(s, &server{})
  21. log.Println("listen", addr)
  22. err = s.Serve(lis)
  23. log.Println(err)
  24. }