单 Server 多 Service

目前，该功能适用于：

• gRPC 传输协议
• Kitex Thrift 和 Protobuf(non-streaming)

使用方法

准备工作

请使用 Kitex 命令工具为每个 Service 生成代码。更多详情，请参考代码生成工具.

代码生成的结果如下所示：

kitex_gen
    |_ api
        |_ servicea
            |_ client.go
            |_ invoker.go
            |_ server.go
            |_ servicea.go
        |_ serviceb
            |_ client.go
            |_ invoker.go
            |_ server.go
            |_ serviceb.go
        |_ ...

您可以在每个 Service 的server.go中看到RegisterService函数。

func RegisterService(svr server.Server, handler XXX, opts ...server.RegisterOption) error {
   if err := svr.RegisterService(serviceInfo(), handler, opts...); err != nil {
      return err
   }
   return nil
}

创建 Server 并在 Server 上注册您的 Service

在 Server 上注册 Service 是一个简单的过程。

首先，创建一台 Server 。然后，通过在您生成的代码中调用RegisterService函数，即可注册 Service 。

可以在同一台 Server 上调用多个 Service ，根据需要注册任意多个 Service 。

package main

import (
   "github.com/cloudwego/kitex/pkg/server"
   
    servicea "your_servicea_kitex_gen_path"
    serviceb "your_serviceb_kitex_gen_path"
)   

func main() {
    // 通过调用 server.NewServer 创建 Server 
    svr := server.NewServer(your_server_option)
    // 在 Server 上注册多 Service
    err := servicea.RegisterService(svr, new(ServiceAImpl))
    err = serviceb.RegisterService(svr, new(ServiceBImpl))
    
    err = svr.Run()
    
    if err != nil {
       logs.Error("%s", err.Error())
    }
    logs.Stop()
}

备用 Service

假设 Service 之间有相同的命名方法。

// demo.thrift
namespace go api
struct Request {
1: string message
}

struct Response {
1: string message
}

service ServiceA {
Response sameNamedMethod(1: Request req)
}
service ServiceB {
Response sameNamedMethod(1: Request req)
}

在这种情况下，请注意，您需要指定一个 Service 作为备用 Service（Fallback Service） 。

当客户端使用旧的 Kitex 版本 ( < v0.9.0 ) 时，备用 Service 用于维护兼容性

• 或者当TTHeader未用于传输协议时，
• 或者客户端没有设置可选的元处理程序Transmeta.ClientTTHeaderHandler()。

如果未指定任何回退 Service 或指定了多个回退 Service ，则在 Server 启动时将返回错误。

请注意，您只能将一个 Service 指定为备用 Service 。

生成代码(server.go)中的RegisterService()有一个可选参数：server.RegisterOption。 如果传入server.WithFallback Service选项，则该 Service 将注册为回退 Service 。

func main() {
    // 通过调用 server.NewServer 创建 Server 
    svr := server.NewServer(your_server_option)
    // 在 Server 上注册多 Service 
    // servicea 将成为备用 Service 
    servicea.RegisterService(svr, new(ServiceAImpl), server.WithFallbackService())
    serviceb.RegisterService(svr, new(ServiceBImpl))
    
    err := svr.Run()
    if err != nil {
        logs.Error("%s", err.Error())
    }
    logs.Stop()
}

另一种避免 Server 启动错误而不指定回退 Service 的方法是使用server.WithRefuseTrafficWithoutServiceName选项。

使用此选项，即使您没有为名称冲突的方法指定回退 Service ，启动 Server 时也不会返回错误。

但在使用此选项时，必须注意以下事项：

当server.WithRefuseTrafficWithoutServiceName选项启用时，如果 Server 在以下情况下收到请求， 则会出现错误消息：“no service name while the server has WithRefuseTrafficWithoutServiceName option enabled”

• 客户端使用较旧的 Kitex 版本(<v0.9.0)，不支持多 Service 功能
• 请求的传输协议不是 TTHeader ( Kitex pb 的传输协议默认启用 TTHeader )
• 未设置客户端选项client.WithMetaHandler(transmeta.ClientTTHeaderHandler())

常见问题解答

1.单 Server 多 Service 和 Combine Service 有什么区别？

• Combine Service（通过生成带有 -combine-service 标志的代码，将多个 Service 合并成一个统一的 Service 形成的 Service）
  • 所有 Service（Combine Service 和被合并的每个 Service）的代码都会生成。
  • Service 的所有方法名称必须是唯一的。
  • 一个 Server 上只能注册一个 Service (即 combine service）。 否则，您将收到一条错误消息，提示您“在注册 Combine Service 时只能注册一个 Service”。
• 单 Server 多 Service（即 Multiple Services，更推荐使用）
  • 每个 Service 的代码都会单独生成。
  • Service 之间的方法名称可以相同，但也有一些限制。请选一个解决方案：
    • 您需要为冲突的方法指定备用 Service（Fallback Service） 。
    • 创建 Server 时增加server.WithRefuseTrafficWithoutServiceName选项。 并确保客户端使用的是 Kitex（版本 >= v0.9.0）， 且使用 TTHeader 协议，并设置client.WithMetaHandler(transmeta.ClientTTHeaderHandler())客户端选项。

2. Service 注册失败的原因？

可能的原因如下：

• 当您注册的 Service 之间具有相同名称的方法时，未指定备用 Service。请指定备用 Service 。
• 您正在尝试在 Server 上同时注册 Combine Service 和其他 Service 。 请注意，Combine Service 只能在 Server 上单独注册。如果您还想注册其他 Service ，则需要将这些 Service 合并到 Combine Service 中，或者在不使用 Combine Service 的情况下单独注册每个 Service 。