对云岛业务结构的公司来说，云平台属于公司内部、完全可控的局域网，而岛端则是有自己安全网络策略的独立内部网络。需要云岛通信时，会基于需求，按客户要求走流程开通一些端口，这个过程需要一定的成本且不完全可控。业务上，如果这种跨网需求增多，则会逐渐变成痛点。如果可以搭建一个透明的跨网传输网络，配合良好的顶层设计，就可以在业务支撑、安全管控和运维成本中寻求较好的平衡。

本文将介绍政采云基于 Dubbo 的跨网方案落地过程中面临的技术挑战、社区合作以及更深层次抽象的一些思考。在政采云这种政企业务场景中的数据跨网，与业界公有云、自建私有云的公司相比，既有共性又有自己的特点，希望能为大家提供新的思路或者启发。

前言

稳定、高效、可靠的基础设施是互联网企业应对业务高峰流量的底层基石。作为政采云的基础技术平台，基础平台部一直致力于通过业内前沿技术的落地，保障公司内部所有业务在线生产系统所依赖的基础技术平台能稳定、安全、低成本、可持续地运行与发展。

由于公司对 Dubbo 框架的重度使用，跨网数据传输系统一般基于 Dubbo 特性开发，在政采云内部就有多个版本的实现。

早在几年前，政采云就上线了基于 Dubbo Filter 转发的方案，它解决了岛到云的单向数据传输，安全认证等问题。另外，业务部门也有按照自己的需求，推出网状点对点的方案，实现了一定程度的透明传输。

结合前两年的探索实践以及业界相关领域技术的成熟度，2022 年下半年，我们对各跨岛方案，进行了整合升级，也就是现在的高速公路方案，保障跨岛标准化同时，解决了之前方案实践过程中面临的很多业务痛点，包括：

单向传输：因为架构原因，如需双向需要对等重新部署一套，成本较大。
白名单开通成本高：点对点的网状架构，需要两两开通白名单，因为政企网络特殊性，开通流程复杂且慢。
平台维护成本高：业务各自一套数据传输平台，重复建设且运维成本高。
公共功能的缺失：核心功能，业务可以按需开发，但是数据审计、链路追踪、可观测性等公共特性，往往没有足够投入。

跨网数据传输系统演进

1.1 历史架构

图一

自左向右、自下而上进行模块介绍：

业务 Web：业务 Web 作为数据发送方，调本地集群 Provider 时，携带跨岛信息过去（Dubbo 上下文）。
岛业务 Center：本地虚拟 Provider，通过 Filter 拦截跨岛请求，通过 http 传送到云平台 Dubbo 网关，返回数据后反序列化返回岛业务 web。
Dubbo 网关：接收 Http 请求，通过泛化调用云端 Provider，处理数据后返回业务 Center。
云业务 Center：普通 Dubbo Provider。

1.2 高速公路架构

图二

1.2.1 隧道机制

隧道技术是一种通过使用互联网络的基础设施在网络之间传递数据的方式。使用隧道传递的数据 (或负载) 可以是不同协议的数据帧或包。

高速公路架构中，使用了隧道这个概念。两端（业务层）是 Dubbo 私有协议，跨网传输过程中，则使用了 http 协议，http 协议可以更好的被中间设备、网关识别转发。这个机制的最大便利在于对业务的低侵入性。对于业务集群的应用完全不需要修改。

图三

除了路由标记，出口 / 入口 Dubbo 协议字节流没有任何业务外信息，所以可以路由任何 Dubbo 请求。

图四

1.2.2 主要节点

客户端 Sdk：不改变用户使用 Dubbo 的方式，多种形式提供 Dubbo 的路由。
Dubbo 出口网关 ：代理 Dubbo 流量出口。
Dubbo 入口网关 ：代理 Dubbo 流量入口。
统一网关 ：基于 Apisix，代理跨网间所有流量，可以扩展鉴权、审计、限流等特性。

挑战与应对之策

如前言中所述，已有的几个方案设计上存在了一些问题，落地后也限制了使用了场景。在架构上，我们提出了高速公路方案，选择了全双工的对等网络传输框架。角色上，云平台定位一个特殊的岛端应用，遵循 P2P 实施原则。而对用户而言，高速公路是一个通往岛端的隧道，遵循对用户透明原则。我们可以先来看下在搭建平台的过程中面临的一些挑战以及解法。

2.1 技术挑战

结合当下跨网数据传输系统面临的处境，并对业界 Dubbo 跨网方案做过一番调研后，在平台搭建上确定了如下三期目标：

一期目标：网络能力建设，简单来说是搭建基于 Dubbo 的传输通道，上层功能先维持不变。
二期目标：业务上，找业务先行试点，基于反馈，小步快跑，快速迭代；技术上，寻求 Dubbo 社区协作，增强对 Dubbo 相关技术风险的把控，同时抽离通用特性，反馈社区。
三期目标：抽象出更通用的网络框架，从而使语言层，传输协议层、及中间件层独立扩展，一键切换。

在上述三期目标基本落地后，高速公路系统不仅可以跑起来，同时拥有非常强大的扩展性，更好的承接业务需求及共建。在这过程中，我们需要解决不少技术问题。

2.1.1 客户端路由

如前面历史方案所述，其场景被限制为岛到云的单向数据传输，特点如下：

客户端无路由能力：Consumer 端只能指定是否路由到云平台，而不能指定其他岛端。
基于 filter 的扩展：Dubbo 的 Filter 并不是为路由设计的，在此基础上较难扩展。
需要本地 Provider 角色：Consumer 端发出的请求，必须由一个注册在 Zookeeper 下的 Provider 兜住，然后 Filter 根据上下文决定是否转发，这就限制了业务方必须部署一个本地 Provider 应用（哪怕是空应用），才能做到跨网访问。

我们要解决的问题之一，就是打破单向传输瓶颈，客户端可以更自由的路由到目标云 / 岛。我们设计了以下几种路由方式：

注解方式：使用 @DubboReference 提供的通用 parameters 参数，设置路由目标，可以达到方法粒度的路由。

@DubboReference(check = false, parameters = {"ENV_SHANGHAI", "ALL"}) //all表示所有方法，可以单独指定
private DemoService demoService;

配置中心指定：把以上 parameters = {"ENV_SHANGHAI", "ALL"} 信息，在配置中心配置，达到同样的效果，这种方式对代码完全无侵入。
线程指定：这种方式最灵活。

AddressZoneSpecify.setAddress(Enviroment.SHANGHAI);
demoService.play();

无论哪种路由方式，基于“用户透明“的原则，都不改变用户使用 dubbo 的方式。

2.1.2 Dubbo 请求地址切换

客户端路由最小限度地侵入业务代码，达到了透明调用远程服务的目标。但是，用户仍旧需要部署一套虚拟 Provider 应用，接收请求后按规则进行路由。

为了避免部署多余的应用，我们需要有一定的机制，直接把 dubbo 流量切换到远程。

图五

解决了切换问题后，本地的 APP2 不再需要，甚至 zk 也可以移除。当然，如果业务同时有本地和远程的调用需要，也可以继续存在。

图四原先，我们准备通过 Dubbo 的 Route 自定义扩展，去实现动态切换地址的能力。查阅资料后，发现 Dubbo 已经提供了类似能力。

https://cn.dubbo.apache.org/zh-cn/docs3-v2/java-sdk/advanced-features-and-usage/service/specify-ip/

该特性放在 Dubbo 的子工程 dubbo-spi-extensions 中，同样以 Route 扩展形式实现。

但在实际使用过程中，我们遇到如下问题：

不支持 Dubbo2：使用 Dubbo2 时，直接以异常的形式提醒暂不支持。
NPE 异常：某些场景下调用出现了 NPE 异常。
丢失部分信息：Router 下构建新 Invocation 时，丢失了 version、group 等信息。
重试异常：远程 Provider 如果发生了异常，客户端在重试的时候，选择了本地集群 Provider 调用，造成错误。

作为一个尝鲜新特性，我们理解功能存在不稳定的情况。但这个功能作为我们跨网方案的技术要点，又必须解决。所以，我们通过 PR 的形式，把相应补丁提交到 Dubbo 社区。这个过程中，我们联系到了 Dubbo PMC 远云大佬，一起讨论和完善 PR，直到解决所有已知问题。

2.1.3 出口网关的实现

在图 4 中，通过切换地址，我们似乎可以直接访问远程应用，并且架构非常简单。但是遗憾的是，存在几个难以解决的问题：

网关组件的限制：在云岛 / 岛岛间，存在一系列网关组件，来提供转发、负载均衡的功能，比如 SLB、NGINX、WAF。这些组件并不能识别私有的 Dubbo 流量并转发。
ip 白名单开通成本高：类似 P2P 方案，需要点对点开通 IP 白名单，成本巨大。
升级维护复杂：客户端通过集成 SDK 的形式转发，后续如需要劫持流量进行扩展，需要同时对每个接入应用进行升级。

图六

针对以上问题，我们的设计中，需要加入 Dubbo 网关的角色，来实现以下目标。

① 两端 ip 收敛

显著减少网关长连接数量
弱化服务注册发现流程（每个环境只有一个 Dubbo 网关，直接配置即可互相发现）
简化鉴权、认证流程。一条链路可以使用白名单，一群则只能配置较复杂的鉴权

② 两端功能收敛

客户端的 SDK 专注路由功能，基本不用升级
扩展功能放在 Dubbo-Proxy，统一升级，业务端无感知

Dubbo-Proxy 作为业务网关，可以减轻对业务端的侵入，起到类似分布式运行时（Dapr）作用。但是，在引入之前，需要解决一些现实的技术问题。其中，最重要的问题是如何接收陌生的 Dubbo 流量，然后进行转发。做了一些相关调研后，有两个方案可用：

通用 Provider

直接在 Dubbo-Proxy 注册一个普通的通用 Service，客户端的 SDK 利用 Filter，劫持流量，直接调用通用 Service 后处理数据返回。

注册虚拟节点

该方案来源于远云。客户端在本地 zk 订阅远程节点时，通知 Proxy，Proxy 获取订阅的信息后（预先订阅所有 zk 变更），主动注册相应虚拟 Service（对 zk 来说，注册一个节点的参数只是字符串）到 zk 上。这样，可以把客户端的远程流量“骗”到 Proxy ，Proxy 再使用服务端泛化，接收请求并转发。

以上两种方案，都可以实现出口网关。但是，在设计上，角色间需要多次交互，才能达到目的。那么，是否有更简洁的方式，直接支持这种接收和转发呢？

首先，我们对 Dubbo 源码进行了调研，看 Provider 接收到陌生流量（无相应 Service）后会如何处理，是否有扩展点可以拦截。发现在 Byte 流解析阶段，Dubbo 即对 Service 进行了检查，不存在直接抛异常返回。

图七

在 Provider 处理的生命周期中，Decode 出于非常早期的阶段，几乎没有什么扩展点可以拦截处理。因为快速失败的理念，早期的检测确实可以避免后面无谓的代码执行消耗。但是，对比 Spring ，Dubbo 在扩展性上是有不足的，即对于一个通用的异常，却没有相应的扩展机制。

我们决定在 decode 的基础上，加上对这个异常的扩展。主要思路是，在 decode 被调用处，catch 住这块异常，通过 SPI 的形式，获取扩展实现，可以定制异常信息，也可以控制 decode 流程重试。这块修改难度并不大，私有版本上顺利通过测试，同时提交 PR 到社区。这个过程中，远云大佬帮忙发现了一个并发安全的 bug，并给了不少减少风险的建议。

//解码结束后，无论是否异常，都将进入这个方法
void handleRequest(final ExchangeChannel channel, Request req) throws RemotingException {
        if (req.error != null) {
            // Give ExceptionProcessors a chance to retry request handle or custom exception information.
            String exPs = System.getProperty(EXCEPTION_PROCESSOR_KEY);
            if (StringUtils.isNotBlank(exPs)) {
                ExtensionLoader<ExceptionProcessor> extensionLoader = channel.getUrl().getOrDefaultFrameworkModel().getExtensionLoader(ExceptionProcessor.class);
                ExceptionProcessor expProcessor = extensionLoader.getOrDefaultExtension(exPs);
                boolean handleError = expProcessor.shouldHandleError(error);
                if (handleError) {
                    //获取异常扩展，执行wrapAndHandleException操作，需要重试的场景可以抛出retry异常
                    msg = Optional.ofNullable(expProcessor.wrapAndHandleException(channel, req)).orElse(msg);
                }
            }
        }
        res.setErrorMessage("Fail to decode request due to: " + msg);
        res.setStatus(Response.BAD_REQUEST);
        channel.send(res);
    }
}
 //handleRequest过程中的retry控制
 public void received(Channel channel, Object message) throws RemotingException {
       //解码 
       decode(message);
        try {
            handler.handleRequest(channel, message);
        } catch (RetryHandleException e) {
            if (message instanceof Request) {
                ErrorData errorData = (ErrorData) ((Request) message).getData();
                //有定制，进行重试
                retry(errorData.getData());
            } else {
                // Retry only once, and only Request will throw an RetryHandleException
                throw new RemotingException(channel, "Unknown error encountered when retry handle: " + e.getMessage());
            }
            handler.received(channel, message);
        }
    }