PL/SQL 多進程通信技術深度解析：DBMS_PIPE 與 DBMS_ALERT 實戰指南

背景動機

PL/SQL 設計初衷為強化 SQL 功能，原生不支援多執行緒/多進程。但在高併發批次處理、非同步作業協調、外部程式 (Pro*C、Java) 互動等場景，需實現會話間通信。Oracle 提供兩大內建套件：

• DBMS_PIPE：管道通信，支援雙向、異步、任意資料型別 (經打包)
• DBMS_ALERT：事件通知，支援廣播、同步 (Commit 觸發)、純文字訊息

DBMS_PIPE：管道通信機制

核心 API

雙會話通信完整範例

發送端 (Session A)

DECLARE
  v_pipename  VARCHAR2(30) := 'order_pipe';
  v_status    NUMBER;
  v_order_id  NUMBER := 12345;
  v_amount    NUMBER := 999.50;
  v_note      VARCHAR2(200) := 'Urgent VIP order';
BEGIN
  DBMS_PIPE.PACK_MESSAGE(v_order_id);
  DBMS_PIPE.PACK_MESSAGE(v_amount);
  DBMS_PIPE.PACK_MESSAGE(v_note);
  v_status := DBMS_PIPE.SEND_MESSAGE(v_pipename, 10);  -- 10 秒逾時
  IF v_status != 0 THEN
    DBMS_OUTPUT.PUT_LINE('發送失敗，代碼: ' || v_status);
  ELSE
    DBMS_OUTPUT.PUT_LINE('訂單 ' || v_order_id ' 已送入管道');
  END IF;
END;
/

接收端 (Session B)

DECLARE
  v_pipename  VARCHAR2(30) := 'order_pipe';
  v_status    NUMBER;
  v_order_id  NUMBER;
  v_amount    NUMBER;
  v_note      VARCHAR2(200);
BEGIN
  LOOP
    v_status := DBMS_PIPE.RECEIVE_MESSAGE(v_pipename, 30);  -- 等待 30 秒
    EXIT WHEN v_status != 0;  -- 逾時或錯誤跳出
    DBMS_PIPE.UNPACK_MESSAGE(v_order_id);
    DBMS_PIPE.UNPACK_MESSAGE(v_amount);
    DBMS_PIPE.UNPACK_MESSAGE(v_note);
    DBMS_OUTPUT.PUT_LINE('處理訂單: ' || v_order_id || ', 金額: ' || v_amount || ', 備註: ' || v_note);
    -- 實際業務邏輯: INSERT INTO orders ...; COMMIT;
  END LOOP;
  IF v_status = 1 THEN
    DBMS_OUTPUT.PUT_LINE('等待逾時，無新訊息');
  ELSIF v_status > 1 THEN
    DBMS_OUTPUT.PUT_LINE('接收錯誤: ' || v_status);
  END IF;
END;
/

進階用法：多資料型別、RAW、物件傳遞

-- 發送複雜結構
DBMS_PIPE.PACK_MESSAGE('HEADER');           -- 標識
DBMS_PIPE.PACK_MESSAGE(123);                -- NUMBER
DBMS_PIPE.PACK_MESSAGE(SYSDATE);            -- DATE
DBMS_PIPE.PACK_MESSAGE(UTL_RAW.CAST_TO_RAW('binary data')); -- RAW
DBMS_PIPE.PACK_MESSAGE(my_obj_type(1, 'test')); -- 物件型別 (需先定義 TYPE)

-- 接收端需按相同順序 UNPACK，並用 NEXT_ITEM_TYPE 防禦性檢查

DBMS_ALERT：事件通知機制

核心 API

警報通知範例

發送端

DECLARE
  v_alert_name VARCHAR2(30) := 'inventory_alert';
BEGIN
  -- 業務邏輯: 扣減庫存
  UPDATE inventory SET qty = qty - 10 WHERE sku = 'ABC123';
  IF SQL%ROWCOUNT = 0 THEN
    DBMS_ALERT.SIGNAL(v_alert_name, 'SKU ABC123 庫存不足或不存在');
  ELSIF (SELECT qty FROM inventory WHERE sku = 'ABC123') < 50 THEN
    DBMS_ALERT.SIGNAL(v_alert_name, 'SKU ABC123 低庫存預警，剩餘: ' || 
                       (SELECT qty FROM inventory WHERE sku = 'ABC123'));
  END IF;
  COMMIT;  -- 必須 COMMIT，SIGNAL 才會真正廣播
END;
/

接收端 (監聽程式，常駐後台)

DECLARE
  v_alert_name VARCHAR2(30) := 'inventory_alert';
  v_message    VARCHAR2(1800);
  v_status     NUMBER;
BEGIN
  DBMS_ALERT.REGISTER(v_alert_name);
  DBMS_ALERT.SET_DEFAULTS(5);  -- 每 5 秒輪詢一次
  LOOP
    DBMS_ALERT.WAITONE(v_alert_name, v_message, v_status, 60);  -- 最長等 60 秒
    IF v_status = 0 THEN
      DBMS_OUTPUT.PUT_LINE('收到警報: ' || v_message);
      -- 發送 Email、寫入日誌表、呼叫外部 API 等
      -- 例如: UTL_MAIL.SEND(...); INSERT INTO alert_log VALUES (v_message, SYSDATE);
    ELSIF v_status = 1 THEN
      DBMS_OUTPUT.PUT_LINE('等待逾時，繼續監聽...');
    ELSE
      DBMS_OUTPUT.PUT_LINE('異常狀態: ' || v_status);
    END IF;
  END LOOP;
EXCEPTION
  WHEN OTHERS THEN
    DBMS_ALERT.REMOVEALL;
    RAISE;
END;
/

DBMS_PIPE vs DBMS_ALERT 關鍵差異比較

實務應用場景選型指南

效能與限制注意事項

• 管道大小限制：預設 8KB，可建立時指定 MAXPIPESIZE (最大 32MB)，訊息總長不可超過
• SGA 記憶體佔用：管道與警報訊息佔用 Shared Pool，大量併發需監控 V$SGASTAT 中 'pipe'、'alert' 區域
• 逾時設計：SEND/RECEIVE/WAIT 必須設定合理逾時，避免會話無限期阻塞
• 異常處理：接收迴圈需捕獲例外並 REMOVE_PIPE/REMOVEALL 清理資源
• 權限管理：GRANT EXECUTE ON DBMS_PIPE TO app_user; 最小權限原則
• RAC 環境：DBMS_ALERT 自動跨實例，DBMS_PIPE 預設僅實例本地，跨實例需共享磁碟或自行實作

現代替代方案對比

總結

DBMS_PIPE 與 DBMS_ALERT 是 PL/SQL 實現進程間通信的兩大基石，前者適合雙向、異步、結構化資料交換；後者適合事件驅動、廣播通知、Commit 語義綁定。選型時依據通信模式、資料複雜度、可靠性需求決定。現代系統建議逐步遷移至 Advanced Queuing 或外部訊息佇列，獲得更豐富的企業級特性與運維工具支援。