package main import ( "context" "fmt" "log" "github.com/go-kratos/kratos/examples/helloworld/helloworld" "github.com/go-kratos/kratos/v2" "github.com/go-kratos/kratos/v2/metadata" mmd "github.com/go-kratos/kratos/middleware/metadata/v2" "github.com/go-kratos/kratos/v2/transport/grpc" "github.com/go-kratos/kratos/v2/transport/http" ) // go build -ldflags "-X main.Version=x.y.z" var ( // Name is the name of the compiled software. Name = "helloworld" // Version is the version of the compiled software. Version = "v1.0.0" ) // server is used to implement helloworld.GreeterServer. type server struct { helloworld.UnimplementedGreeterServer } // SayHello implements helloworld.GreeterServer func (s *server) SayHello(ctx context.Context, in *helloworld.HelloRequest) (*helloworld.HelloReply, error) { var extra string if md, ok := metadata.FromServerContext(ctx); ok { extra = md.Get("x-md-global-extra") } return &helloworld.HelloReply{Message: fmt.Sprintf("Hello %s extra_meta: %s", in.Name, extra)}, nil } func main() { grpcSrv := grpc.NewServer( grpc.Address(":9000"), grpc.Middleware( mmd.Server(), )) httpSrv := http.NewServer( http.Address(":8000"), http.Middleware( mmd.Server(), ), ) s := &server{} helloworld.RegisterGreeterServer(grpcSrv, s) helloworld.RegisterGreeterHTTPServer(httpSrv, s) app := kratos.New( kratos.Name(Name), kratos.Server( httpSrv, grpcSrv, ), ) if err := app.Run(); err != nil { log.Fatal(err) } }