Учебные заметки Кратоса — простой анализ того, как приложение работает с макетом

задняя часть Go

0X00 Kratos

Kratos — это облегченная среда микросервисов Go, включающая большое количество сред и инструментов, связанных с микросервисами.

Название происходит от: Игра «Бог войны» основана на греческой мифологии и рассказывает о приключениях Кратоса, который из смертного стал богом войны и начал резню богов.

0X01 Изучите принцип работы kratos через макет (kratos v2.0.0-beta4)

Создать проект

Во-первых, вам необходимо установить соответствующую среду зависимостей и инструменты:

  • go
  • protoc
  • protoc-gen-go
  # 创建项目模板
kratos new helloworld

cd helloworld
# 拉取项目依赖
go mod download
# 生成proto模板
kratos proto add api/helloworld/helloworld.proto
# 生成proto源码
kratos proto client api/helloworld/helloworld.proto
# 生成server模板
kratos proto server api/helloworld/helloworld.proto -t internal/service

После выполнения команды в текущем каталоге будет создан сервисный проект.Скелет проекта выглядит следующим образом, и можно получить доступ к конкретному описанию скелета проекта.layout image.png

запустить проект

# 生成所有proto源码、wire等等
go generate ./...

# 编译成可执行文件
go build -o ./bin/ ./...

# 运行项目
./bin/helloworld -conf ./configs

Следующий вывод доказывает, что проект запускается нормально

level=INFO module=app service_id=7114ad8a-b3bf-11eb-a1b9-f0189850d2cb service_name=  version=
    level=INFO module=transport/grpc msg=[gRPC] server listening on: [::]:9000
level=INFO module=transport/http msg=[HTTP] server listening on: [::]:8000

тестовый интерфейс

curl 'http://127.0.0.1:8000/helloworld/krtaos'

输出：
{
  "message": "Hello kratos"
}

Как работает приложение?

image.pngБлагодаря приведенной выше легенде👆 мы можем визуально наблюдать цепочку вызовов приложения, которая упрощена, как показано на следующем рисунке👇

未命名文件(2).png

1. Внедрить зависимости и вызвать метод newApp()

// helloword/cmd/main.go
func main() {
flag.Parse()
logger := log.NewStdLogger(os.Stdout)

// 调用 go-kratos/kratos/v2/config,创建 config 实例,并指定了来源和配置解析方法
c := config.New(
config.WithSource(
file.NewSource(flagconf),
),
config.WithDecoder(func(kv *config.KeyValue, v map[string]interface{}) error {
return yaml.Unmarshal(kv.Value, v)
}),
)
if err := c.Load(); err != nil {
panic(err)
}

// 将配置扫描到,通过 proto 声明的 conf struct 上
var bc conf.Bootstrap
if err := c.Scan(&bc); err != nil {
panic(err)
}

// 通过 wire 将依赖注入,并调用 newApp 方法
app, cleanup, err := initApp(bc.Server, bc.Data, logger)
if err != nil {
panic(err)
}
// 省略代码...
}

2. Создайте экземпляр Кратоса

Проект main.gonewApp()метод, вызовgo-kratos/kratos/v2/app.goсерединаkratos.New()метод

// helloword/cmd/main.go
func newApp(logger log.Logger, hs *http.Server, gs *grpc.Server) *kratos.App {
	return kratos.New(
                // 配置应用   
		kratos.Name(Name),
		kratos.Version(Version),
		kratos.Metadata(map[string]string{}),
		kratos.Logger(logger),
                
             // kratos.Server() 传入的 http/grpc 服务会通过 buildInstance() 转换成registry.ServiceInstance struct*
		kratos.Server(
			hs,
			gs,
		),
	)
}

Этот метод возвращаетApp struct,ВключатьRun()а такжеStop()метод

// go-kratos/kratos/v2/app.go
type App struct {
	opts     options //配置
	ctx      context.Context // 上下文
	cancel   func() // context 的取消方法
	instance *registry.ServiceInstance //通过 kratos.Server()声明的实例,并通过 buildInstance() 转换后的 *registry.ServiceInstance struct
	log      *log.Helper // 日志
}

// Run executes all OnStart hooks registered with the application's Lifecycle.
func (a *App) Run() error {
 // 省略代码...
}

// Stop gracefully stops the application.
func (a *App) Stop() error {
 // 省略代码...
}

3. Вызвать метод Run()

Проект вызывается в основном методеkratos.App structизRun()метод.

// helloword/cmd/main.go
// 省略代码...
// 启动 Kratos
if err := app.Run(); err != nil {
	panic(err)
}

Run()подробности реализации метода

// go-kratos/kratos/v2/app.go
func (a *App) Run() error {
	a.log.Infow(
		"service_id", a.opts.id,
		"service_name", a.opts.name,
		"version", a.opts.version,
	)
	g, ctx := errgroup.WithContext(a.ctx)
        // 遍历通过 kratos.Server() 声明的服务实例
	for _, srv := range a.opts.servers {
		srv := srv
                // 执行两个goroutine, 用于处理服务启动和退出
		g.Go(func() error {
			<-ctx.Done() // 阻塞,等待调用 cancel 方法
			return srv.Stop() // 协程退出后,调用实例的停止方法
		})
		g.Go(func() error {
			return srv.Start() // 调用实例的运行方法
		})
	}
        // 判断是否调用 kratos.Registrar() 配置了注册发现中心
	if a.opts.registrar != nil {
             // 将实例注册到注册中心
		if err := a.opts.registrar.Register(a.opts.ctx, a.instance); err != nil 
			return err
		}
	}
        // 监听进程退出信号
	c := make(chan os.Signal, 1)
	signal.Notify(c, a.opts.sigs...)
        
        // 处理进程退出和 context 退出
	g.Go(func() error {
		for {
			select {
			case <-ctx.Done():
				return ctx.Err()
			case <-c:
                        // 调用 kratos.App 的停止方法
				a.Stop()
			}
		}
	})
	if err := g.Wait(); err != nil && !errors.Is(err, context.Canceled) {
		return err
	}
	return nil
}

4. Выход из приложения

Когда экземпляр Kratos запускается, он слушает сигнал завершения процесса системы.Когда сигнал выхода получен, kratos вызоветApp structизStop()метод

// go-kratos/kratos/v2/app.go
func (a *App) Stop() error {
	// 判断是否有注册中心配置
	if a.opts.registrar != nil {
		// 在注册中心中将实例注销
		if err := a.opts.registrar.Deregister(a.opts.ctx, a.instance); err != nil {
			return err
		}
	}
	// 控制 goroutine 的退出,当调用 a.cancel()时,Run()方法中 监听的 <-ctx.Done() 收到消息后,没有阻塞后,方法会调用 server 的 Stop()方法,停止服务
	if a.cancel != nil {
		a.cancel()
	}
	return nil
}
Категории