Apache Dubbo 多语言体系再添新员：首个 Rust 语言版本正式发布

欢迎通过以下方式参与 Dubbo Rust 社区：

• 搜索并关注 Apache Dubbo 微信公众号了解社区最新动态
• 直接到 GitHub 提交 Issue 或贡献代码 https://github.com/apache/dubbo-rust

近日，Apache Dubbo 发布了其 Rust 语言实现的首个版本，进一步丰富其多语言体系，这是社区全面对齐 Dubbo3 架构的第三个语言实现。对 Rust 语言社区来说，Apache Dubbo 的加入也是其开源微服务开发框架生态非常重要的补充，Dubbo 也成为 Apache 社区中为数不多的提供 Rust 语言官方支持的项目。
Dubbo Rust 定位为 Dubbo 多语言体系的重要实现，提供高性能、易用、可扩展的 RPC 框架，同时通过接入 Dubbo Mesh 体系提供丰富的服务治理能力。本文主要为大家介绍 Dubbo Rust 项目基本情况，通过一个示例快速体验 Rust 首个正式版本特性，并给出了 Dubbo Rust 社区的近期规划，适合于关注或正在采用 Rust 语言的开发者与企业用户阅读。

1 云原生时代的 Dubbo

自从 Apache Dubbo 在 2008 年由阿里巴巴开源已来，Dubbo 一直是国内微服务领域最具影响力的开源项目之一，被无数互联网、科技、制造企业选型作为内部微服务体系的基石，根据《中国开源发展研究分析 2022》Dubbo 在所有开源项目总排行榜中位列第 6。
Apache Dubbo 是一款支持多语言的、易用的微服务开发框架， 提供一些列组件为构建微服务提供高性能 RPC 通信、流量治理、动态配置、可观测、认证鉴权等服务治理能力。

• 高性能的基于 HTTP/2 的通用 RPC 协议及 Streaming 通信模型。
• 强大的流量治理能力，如地址发现、负载均衡、路由选址、动态配置等。
• 多语言 SDK 实现，涵盖 Java、Golang、Rust、Node.js 等，更多语言实现将会陆续发布。
• 丰富的生态及组件适配，如服务发现、链路追踪、事务、可观测性等业界主流产品均由官方支持接入。
• 云原生友好，全面兼容 Kubernetes 部署及 Service Mesh 架构，支持接入 Istio、Envoy、Proxyless 等。

除以上核心功能外，Dubbo 还具备以下优势：

• 开箱即用

  • 易用性高，如 Java 版本的面向接口代理特性能实现本地透明调用
  • 功能丰富，基于原生库或轻量扩展即可实现绝大多数的微服务治理能力

• 面向超大规模微服务集群设计

  • 极致性能，业界领先的高性能的 RPC 通信协议设计与实现
  • 横向可扩展，轻松支持百万规模集群实例的地址发现与流量治理

• 高度可扩展

  • 调用过程中对流量及协议的拦截扩展，如 Filter、Router、Load Banlancing 等
  • 微服务治理组件扩展，如 Registry、Config Center、Metadata Center 等

• 企业级微服务治理能力

  • 国内公有云厂商支持的事实标准服务框架
  • 多年大型企业规模化实践验证

在过去的一段时间里，Dubbo 社区一直在积极的拥抱云原生，包括在 Dubbo3（HTTP/2、Service Discovery 等）、Kubernetes、Proxyless Mesh 等方面做了大量的开发与建设工作，而这也取得了很好的回报，我们实现了 Dubbo3 取代全面 HSF 并在阿里巴巴的全面推广落地，同时也得到了大量社区头部企业的跟进。在接下来，Dubbo 社区在持续跟进以上特性的同时，会将相当一部分精力放在面向用户侧的易用性、稳定性等体验提升上来，这包括官方网站、文档、快速入门、示例实践等的建设，同时，Dubbo 的多语言建设也将是非常重要的一环，因为我们认为让用户知道如何用好 Dubbo 将是社区的一项非常重要的职责。

2 Dubbo 多语言及 Rust 项目简介

多语言体系建设是 Dubbo3 规划中的重要一环，长期以来 Dubbo2 提供的语言实现仅有 Java、Golang 两种，Dubbo2 的架构设计等都与 Java 语言有较强的绑定关系，如服务定义方式、通信协议、服务发现模型等。为了实现云原生时代微服务多语言，彻底摆脱特定语言绑定的问题，Dubbo 社区陆续启动了 Golang、Rust、Node.js、Python 等语言实现开发工作

• Dubbo 官网：https://dubbo.apache.org/
• Dubbo Java：https://github.com/apache/dubbo/
• Dubbo Golang：https://github.com/apache/dubbo-go/
• Dubbo Rust：https://github.com/apache/dubbo-rust/
• Dubbo Node：https://github.com/apache/dubbo-js/

Dubbo Rust 项目的目标是对齐 Dubbo3 的所有核心功能设计，包括基于 HTTP/2 的高性能通信、用户友好的微服务开发编程模式、通过接入 Dubbo Mesh 提供丰富的服务治理能力等，相比于其他语言实现，Dubbo Rust 将很好的利用 Rust 语言带来的极致性能、内存安全和零成本抽象的特点。
对于微服务框架，主流的编程语言都有对应的实现，而 Dubbo Rust 将很好的填补 Rust 领域的空白：

• Golang：在微服务框架领域已经占据着很重要的地位；开源社区出现了dubbo-go、gRPC、go-micro、go-zero等多个微服务框架
• Java：国内用户量最大的编程语言，Spring Cloud、Dubbo 等优秀的微服务框架已经非常流行
• C/C++：brpc、grpc 等微服务框架
• Rust：目前没有很完善的微服务框架

依托 Dubbo 庞大的用户群，以及 Dubbo 体系下的 Mesh 服务治理整体方案规划。Dubbo Rust 可以轻松地融入到现有的云原生研发体系中，不会增加使用者的研发负担。下图是社区推出的 Dubbo Mesh 架构设计。

在上述架构下，整体分为控制面和数据面两个部分，其中，

• 控制面负责管理流量治理、地址发现、安全认证、可观测性等服务治理相关的配置信管控工作，包括与K8S等底层技术设施的对接；
• Dubbo Rust 作为数据面组件，负责接收来自控制面的配置；将配置应用到服务中；同时为服务提供基础的RPC通信能力。

在架构设计方面，Dubbo Rust 将围绕 Dubbo 核心设计以及 Rust 语言的特性进行设计，并将 Dubbo 框架的核心设计输出为文档，从而提升Dubbo框架的易用性。因此，Dubbo Rust 具有如下特点：易用性、高性能以及可扩展，同时面向云原生提供丰富的服务治理能力。

3 首个 Rust 版本核心能力

Dubbo Rust 首个正式版本为 v0.2.0，v0.2.0 提供的能力包括

• 基于 HTTP/2 的 Triple 协议的基础通信能力
• 基于 IDL 的 RPC 定义支持，Protobuf 来生成代码，同时支持 Serde 序列化
• request-response、request streaming、response streaming、bi-streaming 通信模型支持
• 设计了简洁的、可扩展的架构，支持对 Listener、Connector、Filter、Protocol 以及 Invoker 组件进行扩展

Dubbo Rust v0.2.0 的核心组件及通信流程如下图所示：

核心架构已经基本完成，接下来的版本将重点关注核心组件扩展以及服务治理相关组件的设计实现。

4 Dubbo Rust 开发初体验

完整示例可查看 【Dubbo官网】 -> 【Rust SDK 文档】。
https://dubbo.apache.org/zh/docs3-v2/rust-sdk/quick-start/

使用 Dubbo Rust 服务开发的基本步骤为

1. 环境准备
2. 使用 IDL 定义服务
3. 添加 Dubbo Rust 依赖到项目
4. 编译 IDL
5. 基于 IDL 编译生成的 stub 编写 Server & Client 逻辑
6. 运行项目

1. 环境准备

1）安装 Rust 开发环境

curl --proto '=https' --tlsv1.2 -sSf https://sh.rustup.rs | sh

2) 安装 protoc 工具

$ brew install protobuf
$ protoc --version  # Ensure compiler version is 3+

注：上述命令为 MacOS 环境下的，其他环境的安装方案请参考官方文档示例。

2. 使用 IDL 定义 Dubbo 服务

Greeter 服务定义如下，包含一个 Unary (request-response) 模型的 Dubbo 服务。

// ./proto/greeter.proto
syntax = "proto3";

option java_multiple_files = true;

package org.apache.dubbo.sample.tri;

// The request message containing the user's name.
message GreeterRequest {
  string name = 1;
}

// The response message containing the greetings
message GreeterReply {
  string message = 1;
}

service Greeter{
  // unary
  rpc greet(GreeterRequest) returns (GreeterReply);
}

3. 增加 Dubbo Rust 依赖

# ./Cargo.toml
[package]
name = "example-greeter"
version = "0.2.0"
edition = "2021"

[dependencies]
dubbo = "0.2.0"
dubbo-config = "0.2.0"

[build-dependencies]
dubbo-build = "0.2.0"

4. 编译 IDL

在项目根目录创建 (注意不是 src 目录)，创建 build.rs文件并添加以下内容：

// ./build.rs
fn main() {
    dubbo_build::prost::configure()
        .compile(&["proto/greeter.proto"], &["proto/"])
        .unwrap();
}

这样配置之后，编译项目就可以生成 Dubbo Rust 的 Stub 代码，路径一般在./target/debug/build/example-greeter-<id>/out/org.apache.dubbo.sample.tri.rs。

5. 根据生成的 stub 编写逻辑

5.1 编写 Dubbo Server

// ./src/greeter/server.rs
use ...

#[tokio::main]
async fn main() {
    register_server(GreeterServerImpl {
        name: "greeter".to_string(),
    });

    // Dubbo::new().start().await;
    Dubbo::new()
        .with_config({
            let r = RootConfig::new();
            match r.load() {
                Ok(config) => config,
                Err(_err) => panic!("err: {:?}", _err), // response was droped
            }
        })
        .start()
        .await;
}

#[allow(dead_code)]
#[derive(Default, Clone)]
struct GreeterServerImpl {
    name: String,
}

#[async_trait]
impl Greeter for GreeterServerImpl {
    async fn greet(
        &self,
        request: Request<GreeterRequest>,
    ) -> Result<Response<GreeterReply>, dubbo::status::Status> {
        println!("GreeterServer::greet {:?}", request.metadata);

        Ok(Response::new(GreeterReply {
            message: "hello, dubbo-rust".to_string(),
        }))
    }
}

5.2 配置 dubbo.yaml

dubbo.yaml 指示server端的配置，包括暴露的服务列表、协议配置、监听配置等。

# ./dubbo.yaml
name: dubbo
service:
  org.apache.dubbo.sample.tri.Greeter:
    version: 1.0.0
    group: test
    protocol: triple
    registry: ''
    serializer: json
    protocol_configs:
      triple:
        ip: 0.0.0.0
        port: '8888'
        name: triple
protocols:
  triple:
    ip: 0.0.0.0
    port: '8888'
    name: triple

5.3 编写 Dubbo Client

// ./src/greeter/client.rs
use ...

#[tokio::main]
async fn main() {
    let mut cli = GreeterClient::new().with_uri("http://127.0.0.1:8888".to_string());

    println!("# unary call");
    let resp = cli
        .greet(Request::new(GreeterRequest {
            name: "message from client".to_string(),
        }))
        .await;
    let resp = match resp {
        Ok(resp) => resp,
        Err(err) => return println!("{:?}", err),
    };
    let (_parts, body) = resp.into_parts();
    println!("Response: {:?}", body);
}

6. 运行项目

6.1 编译

执行 cargo build来编译 server 和 client。

6.2 运行server

执行 ./target/debug/greeter-server 来运行 server，如上文 dubbo.yaml 所配置，server 会监听 8888 端口，并以 triple 协议提供 RPC 服务。

$ ./target/debug/greeter-server
2022-11-06T14:53:33.201033Z  INFO dubbo::framework: url: Some(Url { uri: "triple://0.0.0.0:8888/org.apache.dubbo.sample.tri.Greeter", protocol: "triple", location: "0.0.0.0:8888", ip: "0.0.0.0", port: "8888", service_key: ["org.apache.dubbo.sample.tri.Greeter"], params: {} })

6.3 运行client

执行 ./target/debug/greeter-client 来运行 client ，调用triple://127.0.0.1:8888/org.apache.dubbo.sample.tri.Greeter 下的各种方法。

$ ./target/debug/greeter-client
# unary call
Response: GreeterReply { message: "hello, dubbo-rust" }

这样，一个简单的 Dubbo Rust 示例就开发完成了。

5 Roadmap 及未来规划

Dubbo Rust 致力于成为 Rust 语言社区最受欢迎的微服务开发框架之一，将 Dubbo 在微服务框架领域的积累带给开发者，填补 Rust 社区微服务开发框架的空缺。为了达成这个目标，Dubbo Rust Roadmap 规划总体上分为三个阶段：

• 首先，提供作为 RPC 框架的基础能力，此阶段重点完成的包括基于 HTTP/2 的 RPC 通信、基于 IDL 的 RPC 定义、其他必要的 RPC 内核组件等
• 其次是完善 Dubbo Rust 作为微服务框架的高级功能，此阶段包括微服务定义、配置、功能设计等，如服务超时、异步调用、上下文传递、开发者工效学提升（developer ergonomics）、FFI支持等，具体可参见 Dubbo Java 的高级特性。
• 第三阶段重点是引入丰富的服务治理能力支持，如流量治理、限流降级、可观测性等，这一目标将主要通过融入 Dubbo Mesh 体系，即适配 Dubbo Mesh 控制面实现。

其中，第一阶段的工作已经基本完成，大家可通过上文的 Quick Start 进行深入体验，第二、第三阶段的工作已经在社区全面开展，欢迎感兴趣的社区开发者参与进来，具体联系方式参见下文。

下图是侧重从第一阶段（RPC框架）、第二阶段（微服务开发框架）的视角对当前 Dubbo Rust 功能完备性的评估和任务拆解。

上图中都是 Dubbo Rust 核心设计的重要组件，保证 Dubbo Rust 具备微服务框架中完整的 RPC 通信能力以及服务治理能力。

• Protocol、Filter、Listener、Connector 等组件都是 RPC 通信核心能力
• 服务注册发现、负载均衡、Cluster、Metadata 为后续服务治理能力做铺垫

除了上图列出的模块以外，还有一些非功能需求也需要支持，例如：

• Dubbo 多语言框架之间相互通信测试
• 性能验证与持续的 benchmark 机制
• 整体架构的持续优化，如核心配置简化以及相应的文档完善

6 参与到 Dubbo Rust 社区

和 Rust 语言一经发布就受到了开发者的热捧一样，Dubbo Rust 当前也是一个非常有活力、非常前沿的社区；另一方面，依赖 Apache Dubbo 社区背后庞大的开发者群体和企业用户，Dubbo Rust 有着非常深厚的用户基础和发展潜力。Dubbo Rust 的快速发展期待社区贡献者的加入。
参与 Dubbo Rust 社区可以收获

• 见证 Rust 语言社区微服务开源项目的发展
• 在大型项目中实际使用 Rust 语言，加深对 Rust 语言的理解
• 获得提名为 Apache Dubbo Committer、PMC 的机会
• 与 Dubbo 社区及知名企业技术专家面对面的交流机会