基於 Java RMI 的企業級分布式應用架構設計與實現

前言：分布式計算的 Java 原生解決方案

隨著電力企業信息化深入，跨網絡、跨平台、跨部門的數據交換與業務協同需求激增。RMI (Remote Method Invocation) 作為 **Java 平台內建的分布式對象調用機制**，提供了透明的遠程方法調用語義，是構建企業級分布式應用的基石技術之一。本文系統闡述 RMI 架構原理、核心組件、實現步驟、與 CORBA/Web Services 對比，並給出生產級部署建議。

一、為什麼選擇 RMI？對比 Socket 與 CORBA

結論：在**純 Java 技術棧**內部服務調用，RMI 開發效率最高、類型最安全、維護成本最低。跨語言場景選 gRPC/Thrift/REST。

二、RMI 核心架構四大組件

+----------------+       1. 綁定/查找        +------------------+
|    Client      | <---------------------> |  RMI Registry    |
| (Stub 代理)    |       (Naming/Context)   |  (命名服務)      |
+----------------+                          +------------------+
        |                                           ^
        | 2. 遠程調用 (JRMP/RMI-IIOP)               | 3. 啟動註冊遠程物件
        v                                           |
+----------------+                          +------------------+
|    Server      | ----------------------> |  Remote Object   |
| (Skeleton/Impl)|      導出/註冊            |  (實作類)        |
+----------------+                          +------------------+

1. Remote Interface：繼承 java.rmi.Remote，方法拋 RemoteException，定義服務契約。
2. Remote Implementation：實作介面，繼承 UnicastRemoteObject (自動導出) 或手動 exportObject()。
3. RMI Registry：命名服務 (預設埠 1099)，Naming.bind/rebind/lookup 或 JNDI Context 操作。
4. Stub / Skeleton：客戶端 Stub (代理) 序列化參數、發送請求、反序列化結果；伺服器端 Skeleton (JDK 1.2+ 內建於運行時) 接收請求、調用實作、返回結果。**JRMP (Java Remote Method Protocol)** 為預設傳輸協議。

三、完整實現步驟 (含代碼範例)

1. 定義遠程介面

package com.power.grid.rmi;

import java.rmi.Remote;
import java.rmi.RemoteException;
import java.util.List;

public interface MeterDataService extends Remote {
    List getReadings(String meterId, long startTime, long endTime) throws RemoteException;
    void submitReading(MeterReading reading) throws RemoteException;
}

2. 實作遠程物件 (伺服器端)

package com.power.grid.rmi.server;

import com.power.grid.rmi.MeterDataService;
import com.power.grid.model.MeterReading;
import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;

public class MeterDataServiceImpl extends UnicastRemoteObject implements MeterDataService {
    private final Map> storage = new ConcurrentHashMap<>();

    protected MeterDataServiceImpl() throws RemoteException {
        super(); // 自動導出，監聽匿名埠口
    }

    @Override
    public List getReadings(String meterId, long startTime, long endTime) throws RemoteException {
        return storage.getOrDefault(meterId, Collections.emptyList())
                .stream()
                .filter(r -> r.getTimestamp() >= startTime && r.getTimestamp() <= endTime)
                .toList();
    }

    @Override
    public void submitReading(MeterReading reading) throws RemoteException {
        storage.computeIfAbsent(reading.getMeterId(), k -> Collections.synchronizedList(new ArrayList<>()))
               .add(reading);
    }
}

3. 啟動伺服器並註冊 (Server Main)

package com.power.grid.rmi.server;

import com.power.grid.rmi.MeterDataService;
import java.rmi.Naming;
import java.rmi.registry.LocateRegistry;

public class RmiServer {
    public static void main(String[] args) {
        try {
            // 1. 建立/獲取 RMI Registry (JVM 內建，預設埠 1099)
            LocateRegistry.createRegistry(1099); // 或確保外部 registry 已啟動

            // 2. 實例化遠程物件
            MeterDataService service = new MeterDataServiceImpl();

            // 3. 綁定名稱 (rmi://host:port/name)
            String url = "rmi://localhost:1099/MeterDataService";
            Naming.rebind(url, service); // rebind 覆蓋舊綁定

            System.out.println("RMI Server started. Service bound to: " + url);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

4. 客戶端調用

package com.power.grid.rmi.client;

import com.power.grid.rmi.MeterDataService;
import com.power.grid.model.MeterReading;
import java.rmi.Naming;
import java.time.Instant;
import java.util.List;

public class RmiClient {
    public static void main(String[] args) {
        try {
            String url = "rmi://localhost:1099/MeterDataService";
            MeterDataService service = (MeterDataService) Naming.lookup(url);

            // 測試提交
            MeterReading reading = new MeterReading("METER-001", Instant.now().toEpochMilli(), 1250.5);
            service.submitReading(reading);
            System.out.println("Submitted: " + reading);

            // 測試查詢
            List readings = service.getReadings("METER-001", 0, System.currentTimeMillis());
            System.out.println("Readings count: " + readings.size());
            readings.forEach(System.out::println);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

四、生產級關鍵配置與優化

五、RMI 在現代架構中的定位

• EJB 遠程介面：EJB 3.x `@Remote` 底層即 RMI (或 RMI-IIOP)。
• JMX 遠程管理：JMXConnectorServer 使用 RMI 連接器暴露 MBean。
• Spring RmiServiceExporter / RmiProxyFactoryBean：透明暴露/消費 Spring Bean 為 RMI 服務。
• 遷移建議：新專案優先選 **gRPC (HTTP/2 + Protobuf)** 或 **Spring Cloud (REST/Feign/WebClient) + 註冊中心**。RMI 維護既有系統、JMX 管理、內部低延遲 Java 節點通訊仍有價值。

結語

RMI 以**「透明遠程調用、內建序列化、命名服務、分散式 GC」**解決了 Java 內部服務調用的核心難題。掌握其架構原理、Stub/Skeleton 機制、序列化陷阱、安全與部署細節，是理解 Java 分布式計算演進史 (RMI → EJB → Web Services → REST/gRPC → Service Mesh) 的必修課。雖新專鮮少直接用 RMI，但其設計哲學 — **位置透明、介面契約、序列化邊界** — 永遠值得學習。