Forest RPC 框架用戶指南：基於 Netty 的高性能分布式 RPC 服務治理

框架簡介

Forest 是基於 Java 開發的輕量級 RPC 框架，除點對點調用外，還提供服務治理：節點自動發現/摘除、高可用、負載均衡。架構包含三大角色：

• Server (RPC Server)：提供服務，向 Registry 註冊並發送心跳。
• Client (RPC Client)：消費服務，向 Registry 訂閱，建立連接發起調用。
• Registry：服務註冊中心，同步變更通知 Client 更新本地列表。

模組劃分

• forest-common：基礎工具
• forest-rpc：核心 RPC 實現
• forest-demo：示例代碼

配置體系：註解 < Spring XML < 代碼構造

基於註解配置

• @ServiceProvider（接口類）：服務名、HA 策略、負載均衡、連接超時。
• @MethodProvider（接口方法）：方法名、序列化、壓縮、超時時間。
• @ServiceExport（實現類）：發布端口（默認/隔離業務用不同端口）。
• @MethodExport（實現方法）：發布方法，可結合 Jersey 註解暴露 RESTful。

Spring XML 覆蓋配置

<bean id="methodConfig" class="...MethodConfig">
    <property name="compressType" value="None"/>
    <property name="serializeType" value="Fastjson"/>
    <property name="timeout" value="5000"/>
</bean>
<bean id="sampleServiceProxy" class="...ForestProxyFactoryBean">
    <property name="serviceInterface" value="...SampleService"/>
    <property name="methodConfigMap">
        <map>
            <entry key="echo" value-ref="methodConfig"/>
            <entry key="say" value-ref="methodConfig"/>
        </map>
    </property>
</bean>

代碼構造 API

SampleService service = Forest.from(SampleService.class,
    ServiceProviderConfig.Builder.newBuilder()
        .withMethodConfig("say", MethodConfig.Builder.newBuilder()
            .withCompressType(CompressType.None)
            .withSerializeType(SerializeType.Fastjson).build())
        .withMethodConfig("echo", ...).build());

核心功能特性

• 壓縮：gzip、snappy
• 序列化：Hessian2、Fastjson、Kyro
• 負載均衡：RANDOM、ROBBIN、HASH
• 容錯：FAIL_FAST、FAIL_OVER
• 客戶端隔離：錯誤閾值自動熔斷、定時恢復
• 內置連接池：基於 commons-pool2，無需額外構建

第三方整合

Hystrix 服務降級

@HystrixCommand(groupKey="ExampleGroup", commandKey="HelloWorld",
    threadPoolKey="HelloWorldPool", fallbackMethod="sayFallback")
public String say(String str) { return remoteServiceRef.say(str); }
public String sayFallback(String str) { return "sayFallBack:" + str; }

Jersey RESTful 支持

啟用 http.server.start=true，即可在方法上使用 @Path、@GET、@Produces 等註解暴露 HTTP 端點。

性能測試數據

Hessian2 序列化下，Win64 8G 內存達 8 萬+ TPS，其他場景均 3 萬+ TPS。尚有優化空間。

源碼地址：forest，歡迎貢獻。