syntax = "proto3";

package services;

import "google/api/annotations.proto";

message ProdRequest {

    int32 prod_id = 1; //传入id

}

message ProdResponse {

    int32 prod_stock = 1; //商品库存

}

message QuerySize {

    int32 size = 1; //页尺寸,这里的1并不是默认值，而是字段的顺序，如果有其他参数就就写2

}

message ProdResponseList {

    repeated ProdResponse prodres = 1; //返回了一堆商品库存,使用了repeated修饰符，还是用了结构体的引用，引用了ProdResponse结构体

}

service ProdService {

    rpc GetProdStock (ProdRequest) returns (ProdResponse) {

        option (google.api.http) = {

            get: "/v1/prod/{prod_id}" //和request中的prod_id对应，不能写错

        };

    }

    rpc GetProdStocks (QuerySize) returns (ProdResponseList);

}

package main

import (

    "context"

    "fmt"

    "google.golang.org/grpc"

    "grpccli/helper"

    "grpccli/services"

    "log"

)

func main() {

    //creds, err := credentials.NewClientTLSFromFile("keys/server.crt", "localhost")

    //if err != nil {

    //    log.Fatal(err)+

    //}

    creds := helper.GetClientCreds()

    conn, err := grpc.Dial(":8081", grpc.WithTransportCredentials(creds))

    if err != nil {

        log.Fatal(err)

    }

    defer conn.Close()

    prodClient := services.NewProdServiceClient(conn)

    /*

    proto文件内容

    message QuerySize {

    int32 size = 1; //页尺寸,这里的1并不是默认值，而是字段的顺序，如果有其他参数就就写2

    }

    message ProdResponseList {

        repeated ProdResponse prodres = 1; //返回了一堆商品库存,使用了repeated修饰符

    }

    service ProdService {

        rpc GetProdStock (ProdRequest) returns (ProdResponse) {

            option (google.api.http) = {

                get: "/v1/prod/{prod_id}" //和request中的prod_id对应，不能写错

            };

        }

        rpc GetProdStocks (QuerySize) returns (ProdResponseList); //定义了参数是QuerySize

    }

    */

    response, err := prodClient.GetProdStocks(context.Background(), &services.QuerySize{Size: 10}) //这里传入的QuerySize是在proto中定义好的参数

    if err != nil {

        log.Fatal(err)

    }

    fmt.Println(response.Prodres)

}