J2EE Web 服務質量監控：服務端 Tie 類注入統計代碼實現調用計數

背景：Sun ONE Studio 生成的 Web 服務包結構

• Web 模塊選擇 EJB 方法 → 自動生成 Web 服務包
• 核心類：<ServiceName>ServantInterface_Tie — 服務端頂層堆棧
• Tie 將 SOAP 調用綁定到底層 EJB 組件

監控需求：業務方法調用計數

修改 Tie 類中對應 EJB 業務方法的 invoke_<MethodName>() 方法，植入統計邏輯。

實戰：修改 invoke_SubmitWork()

// 原生成代碼片段
private void invoke_SubmitWork(StreamingHandlerState state) throws Exception {
    // ... 反序列化請求參數 ...
    java.lang.String result = ((XactServiceServantInterface) getTarget())
            .SubmitWork(requestStruct.getString_1());
    // ... 序列化響應 ...
}

植入統計代碼 (單行)

// 在方法開頭添加
import com.example.monitoring.PayloadSerializer; // 自定義統計工具

// 在業務調用前插入
PayloadSerializer.queueFirstAttachmentText(state.getMessageContext());
// 或更通用：
MonitoringService.incrementCounter("SubmitWork");
MonitoringService.recordRequestSize(state.getMessageContext());

完整修改後方法骨架

private void invoke_SubmitWork(StreamingHandlerState state) throws Exception {
    // 【統計植入點 1】請求接收
    MonitoringService.onRequestReceived("SubmitWork", state.getMessageContext());

    TransactionService.XactServiceGenServer.XactServiceServantInterface_SubmitWork_RequestStruct req = null;
    Object reqObj = state.getRequest().getBody().getValue();

    if (reqObj instanceof SOAPDeserializationState) {
        req = (RequestStruct) ((SOAPDeserializationState) reqObj).getInstance();
    } else {
        req = (RequestStruct) reqObj;
    }

    // 【統計植入點 2】業務調用前
    long startNs = System.nanoTime();
    try {
        String result = ((XactServiceServantInterface) getTarget()).SubmitWork(req.getString_1());
        // 【統計植入點 3】成功
        MonitoringService.onSuccess("SubmitWork", System.nanoTime() - startNs);
        // 構建響應...
    } catch (Exception e) {
        // 【統計植入點 4】失敗
        MonitoringService.onError("SubmitWork", e, System.nanoTime() - startNs);
        throw e;
    }
}

設計原則

1. 最小侵入：只修改 invoke_* 方法，不動生成框架代碼
2. 關注點分離：統計邏輯委託獨立 MonitoringService，Tie 僅委派
3. 非阻塞：統計採用異步隊列/無鎖計數器，不影響業務延遲
4. 維度豐富：計數、耗時分位數、錯誤率、請求/響應大小、租戶/用戶標識

生產級替代方案

• Handler/Interceptor 鏈：JAX-WS SOAPHandler、CXF Interceptor、Axis2 Module — 無需修改生成代碼
• APM 探針：SkyWalking、Pinpoint、Zipkin — 字節碼增強零侵入
• 微服務網關：Spring Cloud Gateway、Envoy — 統一觀測

在生成代碼中植入統計是「不得已而為之」的戰術手段。戰略上，應遷移至標準攔截器鏈或 APM 基礎設施，實現業務與觀測徹底解耦。