从 API 设计开始，了解一下 Golang 的新框架 Twirp

POST /stats/:namePUT /stats/:name

syntax = "proto3";import "google/protobuf/timestamp.proto";option go_package = "./rpc/stats";package stats;service StatsService {    rpc AddStats(AddStatsRequest) returns (AddStatsResponse);    rpc GetStats(GetStatsRequest) returns (GetStatsResponse);}message Stats {    string player_name = 1;    float minutes = 2;    int32 field_goals = 3;    int32 field_goal_attempts = 4;    int32 three_pointers_made = 5;    int32 three_pointer_attempts = 6;     int32 free_throws_made = 7;    int32 free_throw_attempts = 8;     int32 offensive_rebounds = 9;    int32 defensive_rebounds = 10;    int32 assists = 11;    int32 steals = 12;    int32 blocks = 13;    int32 turnovers = 14;    int32 personal_fouls = 15;    int32 points = 16;    string team = 17;    string opponent = 18;    google.protobuf.Timestamp game_date = 19;}message AddStatsRequest {        repeated Stats stats = 1;}message GetStatsRequest {        string player_name = 1;}message AddStatsResponse {        string status = 1;}message GetStatsResponse {        repeated Stats stats = 1;} 

go install github.com/twitchtv/twirp/protoc-gen-twirpgo install google.golang.org/protobuf/cmd/protoc-gen-go

protoc --proto_path=$GOPATH/src:. --twirp_out=../ --go_out=../ rpc/stats/stats.proto

package twirphandlerimport (      "context"      "net/http"      "time"      "github.com/subzero112233/golang-twirp/entity"      "github.com/subzero112233/golang-twirp/rpc/stats"      "github.com/subzero112233/golang-twirp/usecase/playerstats"      "github.com/twitchtv/twirp"      "google.golang.org/protobuf/types/known/timestamppb")type TwirpHandler struct {      Usecase playerstats.UseCase}func NewTwirpHandler(usecase playerstats.UseCase) http.Handler {      t := &TwirpHandler{            Usecase: usecase,      }      return stats.NewStatsServiceServer(t)}// errors may not be working well. check this by returning an error from the usecasefunc (t *TwirpHandler) GetStats(ctx context.Context, input *stats.GetStatsRequest) (*stats.GetStatsResponse, error) {      var stat entity.Stats      stat.PlayerName = input.PlayerName      data, err := t.Usecase.GetStats(stat.PlayerName)      if err != nil {            return &stats.GetStatsResponse{}, twirp.InternalError(err.Error())      }      statsSlice := convertFromEntity(data)      return &stats.GetStatsResponse{Stats: statsSlice}, nil}// errors may not be working well. check this by returning an error from the usecasefunc (t *TwirpHandler) AddStats(ctx context.Context, input *stats.AddStatsRequest) (*stats.AddStatsResponse, error) {      e := convertToEntity(input.Stats)      err := t.Usecase.AddStats(e)      if err != nil {            return &stats.AddStatsResponse{}, twirp.InternalError(err.Error())      }      return &stats.AddStatsResponse{Status: "success"}, nil}

~ $ go run cmd/main.go

package mainimport (      "context"      "fmt"      "net/http"      "github.com/subzero112233/golang-twirp/rpc/stats"      "github.com/twitchtv/twirp"      "google.golang.org/protobuf/types/known/timestamppb")func main() {      endpoint := "http://localhost:8000"      client := stats.NewStatsServiceProtobufClient(endpoint, &http.Client{})      header := make(http.Header)      ctx := context.Background()      ctx, err := twirp.WithHTTPRequestHeaders(ctx, header)      if err != nil {        return      }    var statz []*stats.Stats      statz = append(statz, &stats.Stats{        PlayerName:           "Devin Booker",        Minutes:              44,            FieldGoals:           18,            FieldGoalAttempts:    27,            ThreePointersMade:    6,            ThreePointerAttempts: 10,            FreeThrowsMade:       4,            FreeThrowAttempts:    4,            OffensiveRebounds:    0,            DefensiveRebounds:    5,            Assists:              3,        Steals:               1,            Blocks:               0,            Turnovers:            3,            PersonalFouls:        3,            Points:               55,            Team:                 "Phoenix Suns",            Opponent:             "Milwaukee_Bucks",            GameDate: timestamppb.Now(),    })    respAdd, err := client.AddStats(ctx, &stats.AddStatsRequest{            Stats: statz})    if err != nil {        fmt.Println("AddStats returned an error :", err)      }    fmt.Println(respAdd)      respGet, err := client.GetStats(ctx, &stats.GetStatsRequest{            PlayerName: "Nicolas Batum"})      if err != nil {            fmt.Println("GetStats returned an error :", err)      }      fmt.Println(respGet)}

~ $ go run example/example.go status:”success”stats:{player_name:”Reggie Jackson” minutes:32.9 field_goals:14 field_goal_attempts:20 three_pointers_made:4 three_pointer_attempts:7 free_throws_made:6 free_throw_attempts:6 offensive_rebounds:1 defensive_rebounds:3 assists:6 steals:1 turnovers:2 personal_fouls:3 points:38 game_date:{seconds:1625916051}}

echo 'player_name:"Jae Crowder"' \        | protoc --encode stats.GetStatsRequest ./rpc/stats/stats.proto \        | curl -s --request POST \            --header "Content-Type: application/protobuf" \            --data-binary @- \            http://localhost:8000/twirp/stats.StatsService/GetStats \        | protoc --decode stats.GetStatsResponse ./rpc/stats/stats.proto

~ $ go test -bench=. -benchtime=5000xgoos: linuxgoarch: amd64pkg: github.com/subzero112233/golang-twirpcpu: Intel(R) Core(TM) i7–8550U CPU @ 1.80GHzBenchmarkRestAdd-8 5000 533270 ns/opBenchmarkRestGet-8 5000 475062 ns/opBenchmarkTwirpAdd-8 5000 90284 ns/opBenchmarkTwirpGet-8 5000 91833 ns/opPASSok github.com/subzero112233/golang-twirp 5.966s