grpc

dyrpc/client/client.go

@@ -6,7 +6,9 @@ import (
 	"dy-test/dyrpc/services/prod"
 	"fmt"
 	"google.golang.org/grpc"
+	"google.golang.org/protobuf/types/known/timestamppb"
 	"log"
+	"time"
 )
 
 const (
@@ -50,4 +52,18 @@ func main() {
 	}
 	fmt.Println(prodInfo)
 
+	orderClient := prod.NewOrderServiceClient(conn)
+	newOrderRes, err := orderClient.NewOrder(context.Background(), &prod.ProdMain{
+		OrderId:    1,
+		OrderNo:    "123",
+		UserId:     456,
+		OrderMoney: 50.5,
+		OrderTime: &timestamppb.Timestamp{
+			Seconds: time.Now().Unix(),
+		},
+	})
+	if err != nil {
+		log.Fatal(err)
+	}
+	fmt.Println(newOrderRes)
 }

dyrpc/server/main.go

@@ -25,6 +25,7 @@ func main() {
 
 	rpcServer := grpc.NewServer(grpc.Creds(helper.GetCredentials(certFile, keyFile, caFile)))
 	prod.RegisterProdServiceServer(rpcServer, new(services.ProdService))
+	prod.RegisterOrderServiceServer(rpcServer, new(services.OrderService))
 
 	listen, err := net.Listen("tcp", ":8081")
 	if err != nil {

dyrpc/services/order_service.go

@@ -3,6 +3,8 @@ package services
 import (
 	"context"
 	"dy-test/dyrpc/services/prod"
+	"fmt"
+	"time"
 )
 
 type OrderService struct {
@@ -10,8 +12,11 @@ type OrderService struct {
 }
 
 func (o *OrderService) NewOrder(ctx context.Context, main *prod.ProdMain) (*prod.OrderResponse, error) {
-	//TODO implement me
-	panic("implement me")
+	fmt.Println(main.OrderTime.AsTime().Local().Format(time.DateTime))
+	return &prod.OrderResponse{
+		Status:  "123",
+		Message: "456",
+	}, nil
 }
 
 func (o *OrderService) mustEmbedUnimplementedOrderServiceServer() {