client.go 1.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. package main
  2. import (
  3. "context"
  4. "dy-test/dyrpc/helper"
  5. "dy-test/dyrpc/services/prod"
  6. "fmt"
  7. "google.golang.org/grpc"
  8. "log"
  9. )
  10. const (
  11. certFile = "/Users/duyong/workspace/gotest/dyrpc/ssl/client/client.pem"
  12. keyFile = "/Users/duyong/workspace/gotest/dyrpc/ssl/client/client.key"
  13. caFile = "/Users/duyong/workspace/gotest/dyrpc/ssl/ca/ca.pem"
  14. )
  15. func main() {
  16. //creds, err := credentials.NewClientTLSFromFile("/Users/duyong/workspace/gotest/dyrpc/ssl/server/server.pem", "localhost")
  17. //if err != nil {
  18. // grpclog.Fatalf("Failed to create TLS credentials %v", err)
  19. //}
  20. conn, err := grpc.Dial(":8081", grpc.WithTransportCredentials(helper.GetCredentials(certFile, keyFile, caFile)))
  21. if err != nil {
  22. log.Fatalf("failed to dial: %v", err)
  23. }
  24. defer conn.Close()
  25. client := prod.NewProdServiceClient(conn)
  26. res, err := client.GetProdStock(context.Background(), &prod.ProdRequest{ProdId: 100})
  27. if err != nil {
  28. log.Fatal(err)
  29. }
  30. fmt.Println(res.ProdStock)
  31. prodList, err := client.GetProdStocks(context.Background(), &prod.QueryProdStocks{
  32. PageNo: 1,
  33. PageSize: 10,
  34. })
  35. if err != nil {
  36. log.Fatal(err)
  37. }
  38. fmt.Println(prodList.ProdRes)
  39. }