main.go 1.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354
  1. package main
  2. import (
  3. "database/sql"
  4. "fmt"
  5. "google.golang.org/grpc"
  6. "google.golang.org/grpc/reflection"
  7. client "iaun.cn/linux/services/client"
  8. "log"
  9. "net"
  10. "net/http"
  11. )
  12. const (
  13. port = ":30001"
  14. )
  15. var db *sql.DB
  16. //type Greeter struct {
  17. // service.UnimplementedGreeterServer
  18. //}
  19. //
  20. //func (s *Greeter) SayHello(ctx context.Context, in *service.HelloRequest) (*service.HelloReply, error) {
  21. // fmt.Println(in.GetName())
  22. // return &service.HelloReply{Message: "return message " + in.GetName()}, nil
  23. //}
  24. func rpcServer(s *grpc.Server, lis net.Listener) {
  25. if err := s.Serve(lis); err != nil {
  26. log.Fatalf("failed to serve: %v", err)
  27. }
  28. }
  29. func main() {
  30. var err error
  31. db, err = sqlOpen()
  32. if err != nil {
  33. return
  34. }
  35. lis, err := net.Listen("tcp", port)
  36. if err != nil {
  37. log.Fatalf("failed to listen: %v", err)
  38. return
  39. }
  40. s := grpc.NewServer()
  41. client.RegisterClientServer(s, &Client{})
  42. reflection.Register(s)
  43. go rpcServer(s, lis)
  44. httpHandle()
  45. fmt.Println("http server started")
  46. _ = http.ListenAndServe("0.0.0.0:808", nil)
  47. }