本文介绍如何将符合 Kitex 架构的 Go 应用接入微服务引擎。

前提条件

• 已完成 MSE 和 Nacos 注册中心的对接，操作详情参见 基于 Kitex 使用 Nacos 服务注册中心。

使用限制

• https://github.com/kitex-contrib/obs-opentelemetry ：仅支持 v0.2.6 及以上版本。
• https://github.com/kitex-contrib/registry-nacos ：仅支持 v0.1.2 及以上版本。
• https://github.com/kitex-contrib/xds ：仅支持 v3.0.0 及以上版本。

操作步骤

第一步：变更服务端代码

1. 添加代码库。

   "github.com/kitex-contrib/obs-opentelemetry/tracing" // tracing sdk
   "github.com/kitex-contrib/registry-nacos/registry"   // nacos registry sdk
   

   说明

   • https://github.com/kitex-contrib/obs-opentelemetry ：仅支持 v0.2.6 及以上版本。
   • https://github.com/kitex-contrib/registry-nacos ：仅支持 v0.1.2 及以上版本。

2. 添加初始化。

   registry, err := registry.NewDefaultNacosRegistry()
           if err != nil {
                   panic(err)
           }
   

3. 添加服务端配置。

   // add registey middleware to register service info to nacos server
   server.WithRegistry(registry),
   // add tracing middleware suit to propagate baggage
   server.WithSuite(tracing.NewServerSuite()),
   

第二步：变更客户端代码

1. 添加代码库。

   "github.com/cloudwego/kitex/pkg/xds"                 // xds sdk from kitex
   "github.com/kitex-contrib/obs-opentelemetry/tracing" // tracing sdk
   xdsmanager "github.com/kitex-contrib/xds"            // xds suite
   "github.com/kitex-contrib/xds/xdssuite"              // xds suite
   

2. 添加客户端配置。

   // add tracing middleware suit to propagate baggage
   kclient.WithSuite(tracing.NewClientSuite()),
   // add xDS suite to connect to xDS server and route requests by the
   // config received from xDS server.
   client.WithXDSSuite(xds.ClientSuite{
   				RouterMiddleware: xdssuite.NewXDSRouterMiddleware(
   								xdssuite.WithRouterMetaExtractor(tracing.ExtractFromPropagator),
   				),
   				Resolver: xdssuite.NewXDSResolver(),
   }),
   

第三步：获取接入 MSE 所需 Label

1. 登录 微服务引擎控制台。
2. 左侧导航栏单击 治理中心 > 接入指引。
3. 在 接入指引 页面，填写服务配置并获取应用接入工作负载所需的 Label 信息。
   

第四步：在 Deployment 中添加 Label

在 Deployment 的 Template 中加入以下标签，实现服务配置信息自动注入。

spec:
  template:
    metadata:
      labels:
        sidecar.mesh.io/data-plane-mode: "kitex"
        sidecar.mesh.io/lane: "lane-****"
        sidecar.mesh.io/mse-namespace: "****-group"

代码示例

服务端代码示例

package main

import (
        "context"

        "github.com/cloudwego/kitex-examples/kitex_gen/api"
        "github.com/cloudwego/kitex-examples/kitex_gen/api/echo"
        "github.com/cloudwego/kitex/pkg/klog"
        "github.com/cloudwego/kitex/pkg/rpcinfo"
        "github.com/cloudwego/kitex/server"
        "github.com/kitex-contrib/obs-opentelemetry/tracing" // tracing sdk
        "github.com/kitex-contrib/registry-nacos/registry"   // nacos registry sdk
)

var otherClient echo.Client

type echoImpl struct{}

func (e *echoImpl) Echo(ctx context.Context, req *api.Request) (*api.Response, error) {

        // the client should use the ctx from the input request
        return otherClient.Echo(ctx, &api.Request{Message: req.Message})
}

func main() {
        // initialize nacos register
        registry, err := registry.NewDefaultNacosRegistry()
        if err != nil {
                panic(err)
        }
        svr := echo.NewServer(
                new(echoImpl),
                server.WithServerBasicInfo(&rpcinfo.EndpointBasicInfo{ServiceName: "echo"}),
                // add registey middleware to register service info to nacos server.
                server.WithRegistry(registry),
                // add tracing middleware suit to propagate baggage
                server.WithSuite(tracing.NewServerSuite()),
        )
        if err := svr.Run(); err != nil {
                klog.Infof("server stopped with error:", err)
        } else {
                klog.Infof("server stopped")
        }
}

客户端接入代码示例

package main

import (
        "context"
        "fmt"

        "github.com/cloudwego/kitex/client"
        "github.com/cloudwego/kitex/pkg/xds"                 // xds sdk from kitex
        "github.com/kitex-contrib/obs-opentelemetry/tracing" // tracing sdk
        xdsmanager "github.com/kitex-contrib/xds"            // xds suite
        "github.com/kitex-contrib/xds/xdssuite"              // xds suite

        api "github.com/cloudwego/kitex-examples/kitex_gen/api"
        "github.com/cloudwego/kitex-examples/kitex_gen/api/echo"
        kclient "github.com/cloudwego/kitex/client"
)

func main() {
        // initialize xds module
        err := xdsmanager.Init()
        if err != nil {
                return
        }

        destService := "echo"

        // initialize the client
        cli, err := echo.NewClient(
                destService,
                // add tracing middleware suit to propagate baggage
                kclient.WithSuite(tracing.NewClientSuite()),
                // add xDS suite to connect to xDS server and route requests by the
                // config received from xDS server.
                client.WithXDSSuite(xds.ClientSuite{
                        RouterMiddleware: xdssuite.NewXDSRouterMiddleware(
                                xdssuite.WithRouterMetaExtractor(tracing.ExtractFromPropagator),
                        ),
                        Resolver: xdssuite.NewXDSResolver(),
                }),
        )
        for {
                resp, err := cli.Echo(context.TODO(), &api.Request{})
                if err != nil {
                        panic(err)
                }
                fmt.Println("resp:", resp.Message)
        }
}