Kratos Transport

Overview

This skill provides a guide to the Kratos transport layer. Kratos abstracts server implementations (like HTTP and gRPC) behind a unified transport.Server interface. This allows a Kratos application to seamlessly manage the lifecycle (start, stop) of multiple servers at once.

When to Use

Use this skill when you need to:

• Configure the address and timeout for your HTTP or gRPC servers.
• Add middleware to your HTTP or gRPC servers.
• Understand how to register your implemented services with the transport servers.
• Run both an HTTP and a gRPC server in the same application.

Core Pattern: Creating and Running Servers

The standard pattern is to create your HTTP and/or gRPC server instances and then pass them to the main kratos.App.

// cmd/server/main.go

import (
	"github.com/go-kratos/kratos/v2"
	"github.com/go-kratos/kratos/v2/transport/grpc"
	"github.com/go-kratos/kratos/v2/transport/http"

	"path/to/your/service"
	"path/to/your/conf"
)

func newApp(logger log.Logger, hs *http.Server, gs *grpc.Server) *kratos.App {
	return kratos.New(
		kratos.Name("my-service"),
		kratos.Server(
			// Register both your HTTP and gRPC servers with the app.
			hs,
			gs,
		),
		// ... other app options
	)
}

// This function will be part of your dependency injection setup.
func NewHTTPServer(c *conf.Server, greeter *service.GreeterService) *http.Server {
	var opts = []http.ServerOption{
		http.Address(c.Http.Addr),
		http.Middleware(
			recovery.Recovery(),
		),
	}
	// Create the HTTP server
	srv := http.NewServer(opts...)
	// Register your service implementation with the HTTP server.
	pb.RegisterGreeterHTTPServer(srv, greeter)
	return srv
}

// This function will be part of your dependency injection setup.
func NewGRPCServer(c *conf.Server, greeter *service.GreeterService) *grpc.Server {
	var opts = []grpc.ServerOption{
		grpc.Address(c.Grpc.Addr),
		grpc.Middleware(
			recovery.Recovery(),
		),
	}
	// Create the gRPC server
	srv := grpc.NewServer(opts...)
	// Register your service implementation with the gRPC server.
	pb.RegisterGreeterServer(srv, greeter)
	return srv
}