基於WebLogic FutureResponseServlet的異步Servlet實現AJAX長連接多路複用

AJAX模式的興起徹底改變了Web交互范式：從「用戶填表→提交→跳轉」的同步請求響應，轉向「豐富客戶端持續異步交互」。這帶來極佳用戶體驗的同時，也給服務端擴展性帶來嚴峻挑戰——典型AJAX應用的併發連接數是傳統Web的3-4倍，每個HTTP請求佔用一個執行線程，頻繁的輪詢請求極易耗盡線程池。

WebLogic異步Servlet方案：FutureResponseServlet

WebLogic自6.1版本起提供weblogic.servlet.FutureResponseServlet，支持真正的異步服務端推送，無需客戶端輪詢、無需服務端佔用持久執行線程。核心機制：

• 請求到達時，Servlet註冊客戶端連接到共享緩衝區，立即釋放執行線程。
• 專用單線程（或線程池）異步處理業務邏輯，事件就緒時寫入響應並flush()。
• 長連接保持開啟，單線程可管理成千上萬並發客戶端，實現Socket多路複用。

核心實現代碼解析

public class AsynchronousServerResponseServlet extends FutureResponseServlet {
    private final Notifier notifier;

    public AsynchronousServerResponseServlet() {
        this.notifier = new Notifier();
        this.notifier.start(); // 啟動單一異步處理線程
    }

    public void service(HttpServletRequest request, FutureServletResponse response)
            throws IOException, ServletException {
        // 將客戶端請求推入緩衝區，立即返回，不佔用執行線程
        notifier.poll(request, response);
    }

    class Notifier extends Thread {
        private static Stack<Client> clients = new Stack<>();

        void poll(HttpServletRequest request, FutureServletResponse response) {
            clients.push(new Client(request, response));
        }

        public void run() {
            while (!clients.empty()) {
                Client client = null;
                try {
                    client = clients.pop();
                    PrintWriter pw = client.response.getWriter();
                    for (int j = 0; j < 10; j++) {
                        pw.println("Time is: " + new Date() + "<br>");
                        pw.flush(); // 關鍵：立即推送到客戶端
                    }
                    pw.close();
                } catch (Throwable t) {
                    t.printStackTrace();
                } finally {
                    try { client.response.send(); } catch (IOException ioe) { ioe.printStackTrace(); }
                }
            }
        }
    }

    class Client {
        private HttpServletRequest request;
        private FutureServletResponse response;
        private Client(HttpServletRequest request, FutureServletResponse response) {
            this.request = request;
            this.response = response;
        }
    }
}

關鍵設計要點

1. 單線程多路複用：Notifier線程循環處理所有客戶端，避免「一連接一線程」模式的線程爆炸。
2. FutureServletResponse：WebLogic專用包裝類，允許在異步線程中獲取PrintWriter並分批flush()，最終調用send()提交響應。
3. 適用場景：長耗時任務狀態推送、即時通訊、股票行情、監控大屏等「服務端主動推送、客戶端被動接收」場景。
4. 擴展建議：生產環境建議引入線程池處理業務邏輯，Notifier僅負責分發；引入心跳機制檢測死連接；集成消息隊列（Kafka/RocketMQ）解耦事件產生與推送。

對比Servlet 3.0+ 標準異步

Servlet 3.0引入request.startAsync()標準化異步處理，現代容器（Tomcat 7+、Jetty 8+、WebLogic 12c+）均支持。新項目優先採用標準API，避免廠商鎖定；維護WebLogic舊系統時，FutureResponseServlet仍是可靠選擇。

異步Servlet模式是高併發實時Web應用的基石，掌握其「線程解耦、連接複用、事件驅動」核心思想，比具體API更具價值。