作者：王宇轩(github: DMwangnima)，Kitex Committer

在社区同学的热情帮助下，目前 codec-dubbo 能做到 Kitex 与 Dubbo-Java，Kitex 与 Dubbo-Go 互通，支持 Dubbo 用户向 Kitex 迁移。

方正证券原有的服务采用 Java 和 Dubbo 框架编写，两者稳定且经过了大量场景的验证，符合他们的生产和开发需求。以请求量较大的小方个股详情页为例，高峰期的接口 QPS 在 3-4k，使用 16 台 16 Core 64G 虚拟机进行承载。

目前，使用了 codec-dubbo 的 Kitex 服务已成功上线，稳定运行两个月。还是以小方个股详情页为例，Kitex 和 Hertz 承载了该页面一半左右的接口，在 QPS 不变的情况下，只需要提供 12 个 4 Core 4G Pod，降低资源占用效果显著。

Dubbo 协议编解码器

Dubbo 服务主要使用 Dubbo 协议进行通信，为了支持 Kitex <-> Dubbo 互通，我们需要在 Kitex 中实现 Dubbo 协议。得益于 Kitex 优秀的扩展性，codec-dubbo 根据 Kitex 提供的 Codec 接口实现了 DubboCodec 这一核心编解码器，只需在初始化时注入 DubboCodec 便能使用 Dubbo 协议。

类型映射与拓展

类型映射

Dubbo 主要使用 Hessian2 序列化协议进行 Payload 的编解码，它最大的特点是自描述序列化类型，即不依赖外部 Schema 或接口定义。序列化过程依赖编程语言类型和 Hessian2 类型之间的映射，以 Go 类型转化为 Java 类型为例：

经过分析，我们发现 Hessian2 的基础类型系统与 Thrift 基本重合。为了保证 Kitex + codec-dubbo 的使用体验与 Kitex + Thrift 基本一致，我们基于 Thrift IDL 来生成 Kitex Dubbo-Hessian2 脚手架代码，此时类型转化过程如下所示：

参考 Dubbo 官方的 dubbo-go-hessian2 类型映射，codec-dubbo 提供如下类型映射（此处仅包含部分映射，更多注意事项请参考 codec-dubbo Readme）：

使用 Kitex 命令行工具，并指定协议为 Hessian2：

之后初始化 DubboCodec 并将其注入 Kitex ，利用生成代码编写以下 Client 端代码即可实现 Kitex -> Dubbo 调用：

Kitex + codec-dubbo Server 端流程与 Client 端基本类似，具体例子可参考项目主页。

类型拓展

Hessian2 schema-free 的特性导致 Dubbo 的实现“过于灵活”，可以使用任意类型。为了适配 Dubbo Hessian2 的类型使用灵活性，codec-dubbo 支持类型拓展，其中主要包括自定义映射与 Java 常用类型拓展。

• 自定义映射
  

Java 的基础类型有与之对应的包装类型，例如 boolean 与 java.lang.Boolean。类型映射中默认将 Go 的 bool 类型映射到 Java 的 java.lang.Boolean 类型并不能覆盖到使用 boolean 的情况。

为了统一用户使用体验，让他们在 Kitex 侧只需使用 bool 类型，我们可以在 Thrift 的方法定义后面加上 hessian.argsType="boolean" 注解，利用 thriftgo 的 IDL 反射功能，提前生成 IDL 元信息并注入 codec-dubbo，便可以在运行时动态地将默认映射类型 java.lang.Boolean 改写成 boolean 。具体 Thrift 定义如下所示：

与 boolean 和 java.lang.Boolean 类似，其他 Java 基础类型和包装类型也能通过这种方式进行自定义映射，此时 codec-dubbo 提供的完整类型映射如下：

• java 常用类型拓展

由于 Thrift 类型的局限性，我们无法直接使用 Java 类库中提供的常用类型。为此，codec-dubbo 在 codec-dubbo/java 包中维护了 Thrift 不支持的 Java 类型（例如 java.lang.Object、java.util.Date）以及与之对应的 java.thrift ，同时借助 thriftgo 提供的 idl-ref 功能，我们可以直接在 Thrift IDL 中引用这些类型并生成相应代码。当前的 java.thrift 如下所示：

为了启用这些类型，我们需要在 Thrift IDL 中使用 include "java.thrift" 导入它们，并且在使用 Kitex 命令行工具生成代码时添加 -hessian2 java_extension 参数来拉取该拓展包。

Kitex 命令行工具会自动下载 java.thrift ，你也可以手动下载后放到项目的根目录。引用 java.thrift 中类型的 Thrift IDL 示例：

方法重载

Go 原生不支持方法重载，只能通过定义多个方法来达到类似重载的效果。为了将 Go 中的多个方法映射到 Java 中的重载方法，与自定义映射一节类似，我们在 Thrift 的方法定义后面加上 JavaMethodName 标签，借助 thriftgo 的 IDL 反射功能在运行时动态地将 Golang 侧原本的方法名改写成 JavaMethodName 指定的 Java 侧中的重载方法。

以 Java 侧的 EchoMethod 为例：

我们编写如下 Thrift 定义，即可完成 Go 与 Java 间的重载方法映射，注意到 JavaMethodName 和 hessian.argsType 可以同时使用：

异常处理

codec-dubbo 将 Java 中的异常映射为 Go 中的错误，这些错误统一实现以下接口：

根据 Dubbo 官方推荐的异常处理实践以及企业用户目前的需求，我们将异常划分为常见异常与自定义异常，同时兼顾用户的基础需求以及可扩展需求。

常见异常

codec-dubbo 在 pkg/hessian2/exception 包中提供了 Java 常见的异常，目前支持 java.lang.Exception 。

常见异常无需 Kitex 命令行工具的支持，直接引用即可，以下是 Client 端提取异常和 Server 端返回异常的示例。

• Client 端提取异常

• Server 端返回异常

自定义异常

Java 中的自定义异常往往会继承一个基础异常，这里以 CustomizedException 为例，CustomizedException 继承了 java.lang.Exception：

得益于 thriftgo 支持生成嵌套结构体，为了在 Kitex 侧定义与之对应的异常，我们在 Thrift 中编写如下定义：

注意 exception 字段的注解 thrift.nested="true"，它让 thriftgo 生成嵌套结构体，达到类似继承的效果。

和 Java 常用类型扩展一样，需要在使用 kitex 脚手架工具生成代码时添加 -hessian2 java_extension 参数来拉取拓展包，生成代码如下：

使用方法与常见异常一致，此处不再赘述。

服务注册与发现

Dubbo 同时提供接口级与应用级服务注册发现模型，根据企业用户当前的生产环境需要，我们选择优先实现基于 zookeeper 的接口级模型：Dubbo registry-zookeeper。

与我们熟知的应用级模型不同，接口级模型需要维护接口名 => 服务（不同于微服务，更接近 Handler）的映射关系，一个接口名会映射到多个服务，这些服务可能会存在于同一个进程中。

考虑到 Dubbo 的接口级服务模型与 Kitex 的服务模型差别较大，且 Dubbo registry-zookeeper 应绑定 codec-dubbo 使用，因此不考虑修改 kitex-contrib 中原有的 registry-zookeeper，让 dubbo registry-zookeeper 成为 codec-dubbo 的一个子 go module 统一进行开发与维护。

综合考虑 Dubbo 接口级服务模型、Kitex API 与用户的使用体验，我们提供以下的配置层次：

1. registry/options.go 与 resolver/options.go 中的 WithServers 和 WithRegistryGroup 函数提供注册中心级别的配置，分别指定 zookeeper 的地址和这些 zookeeper 所属的组。用户使用这些函数生成 Kitex 中 registry.Registry 和 discovery.Resolver 实例。

2. 服务级别的配置由 client.WithTag 与 server.WithRegistryInfo 进行传递，registries/common.go 提供 Tag keys，这些 key 与 Dubbo 中的服务元数据一一对应。

resolver 示例

registry 示例

Kitex 支持了 Dubbo 协议，是 CloudWeGo 助力多语言云原生生态融合的一大步，解决了众多企业用户 Java 转 Go、 Java 与 Go 并存的痛点，欢迎大家试用和接入；如果在使用过程遇到任何问题，可以加入我们的飞书用户群，或者在 Github 上给我们提反馈。