DB2 Q 復制實戰：單向佇列複製從 DB2 到 DB2 完整指南

簡介

IBM DB2 Q 復制是一種高性能的數據庫複製技術，利用 WebSphere MQ 作為傳輸層，以壓縮消息形式在網絡間高效移動數據。本文詳細記錄在單機環境下模擬雙遠程數據庫之間的單向（One-way/Unidirectional）Q 復制配置過程，涵蓋 WebSphere MQ 隊列管理器、隊列、通道的創建，DB2 控制表的建立，Q Capture/Q Apply 程序的設置，以及復制隊列映射與 Q 訂閱的配置。所有操作基於 DB2 Express-C V9.5.2 和 WebSphere MQ V6.0 在 Windows XP (VMware Fusion) 環境下完成，旨在為生產環境部署提供可參考的完整步驟。

實驗環境

• 宿主機：MacBook Mac OS X 10.5.6，Core 2 Duo 2.1GHz，4GB DDR667
• 虛擬機：VMware Fusion 運行 Windows XP SP3
• 軟件：WebSphere MQ V6.0，DB2 Express-C V9.5.2
• 網絡：單機模擬雙系統，IP 172.16.157.128，分別監聽端口 1450、1451

核心步驟概覽

1. 創建並配置 WebSphere MQ 隊列管理器、本地/遠程隊列、傳輸隊列、通道
2. 準備源端與目標端 DB2 數據庫，建立 Q 復制所需的控制表空間與控制表
3. 配置 Q Capture（源端）與 Q Apply（目標端）參數表
4. 定義發送隊列映射與接收隊列映射，建立源目連接
5. 創建 Q 訂閱，將源表 XUJM.EMPLOYEE 映射至目標表 XUJM.TGT_EMPLOYEE
6. 啟動監聽器與通道，驗證通道狀態為 RUNNING

詳細實施過程

1. WebSphere MQ 基礎設施搭建

1.1 創建隊列管理器

crtmqm SRC_QM
crtmqm TGT_QM
strmqm SRC_QM
strmqm TGT_QM

1.2 定義源端隊列 (SRC_QM)

runmqsc SRC_QM
define qlocal('ADMINQ') DEFPSIST(YES)
define ql('RESTARTQ') defpsist(YES)
define QL('TGT_QM') USAGE(XMITQ) DEFPSIST(YES)
define qremote('SENDQ') RNAME('RECVQ') RQMNAME('TGT_QM') XMITQ('TGT_QM') DEFPSIST(YES)

1.3 定義目標端隊列 (TGT_QM)

runmqsc TGT_QM
define ql('recvq') defpsist(yes)
DEFINE QLOCAL('SRC_QM') USAGE(XMITQ) DEFPSIST(YES)
DEFINE QREMOTE('ADMINQ') RNAME('ADMINQ') RQMNAME('SRC_QM') XMITQ('SRC_QM') DEFPSIST(YES)
DEFINE QMODEL('IBMQREP.SPILL.MODELQ') DEFSOPT(SHARED) MSGDLVSQ(FIFO) DEFTYPE(PERMDYN)

1.4 配置雙向通道

源端發送通道 + 目標端接收通道：

runmqsc SRC_QM
DEFINE CHL ('SRC_QM.TO.TGT_QM') CHLTYPE(SDR) TRPTYPE(TCP) CONNAME ('172.16.157.128(1450)') XMITQ('TGT_QM') DISCINT(0)
DEFINE CHL ('TGT_QM.TO.SRC_QM') CHLTYPE(RCVR) TRPTYPE(TCP)

目標端發送通道 + 源端接收通道：

runmqsc TGT_QM
DEFINE CHL ('TGT_QM.TO.SRC_QM') CHLTYPE(SDR) TRPTYPE(TCP) CONNAME('172.16.157.128(1451)') XMITQ('SRC_QM') DISCINT(0)
DEFINE CHL ('SRC_QM.TO.TGT_QM') CHLTYPE(RCVR) TRPTYPE(TCP)

2. DB2 控制表與復制環境初始化

2.1 源端數據庫 (SAMPLE) 建立 Q Capture 控制對象

• 創建表空間 QCASN3
• 建立 ASN.IBMQREP_CAPPARMS、IBMQREP_SENDQUEUES、IBMQREP_SUBS 等核心控制表
• 插入 Capture 參數：INSERT INTO ASN.IBMQREP_CAPPARMS (qmgr, restartq, adminq, ...) VALUES ('SRC_QM', 'RESTARTQ', 'ADMINQ', ...)

2.2 目標端數據庫 (TARGET) 建立 Q Apply 控制對象

• 創建表空間 QAASN2
• 建立 ASN.IBMQREP_APPLYPARMS、IBMQREP_RECVQUEUES、IBMQREP_TARGETS 等控制表
• 插入 Apply 參數：INSERT INTO ASN.IBMQREP_APPLYPARMS (qmgr, ...) VALUES ('TGT_QM', ...)

3. 隊列映射與訂閱配置

3.1 發送隊列映射 (源端)

INSERT INTO ASN.IBMQREP_SENDQUEUES
(pubqmapname, sendq, recvq, apply_server, apply_schema, ...)
VALUES ('EMPLOYEE_QMAP', 'SENDQ', 'recvq', 'TARGET', 'ASN', ...);

3.2 接收隊列映射 (目標端)

INSERT INTO ASN.IBMQREP_RECVQUEUES
(repqmapname, recvq, sendq, adminq, capture_server, capture_schema, ...)
VALUES ('EMPLOYEE_QMAP', 'recvq', 'SENDQ', 'ADMINQ', 'SAMPLE', 'ASN', ...);

3.3 啟用源表數據捕獲

ALTER TABLE XUJM.EMPLOYEE DATA CAPTURE CHANGES INCLUDE LONGVAR COLUMNS;

3.4 創建 Q 訂閱 (源端)

INSERT INTO ASN.IBMQREP_SUBS
(subname, source_owner, source_name, sendq, target_server, target_owner, target_name, ...)
VALUES ('EMPLOYEE0001', 'XUJM', 'EMPLOYEE', 'SENDQ', 'TARGET', 'XUJM', 'TGT_EMPLOYEE', ...);

並為每個列插入 IBMQREP_SRC_COLS 記錄，指定主鍵 EMPNO。

3.5 目標端創建目標表與目標訂閱

• 建立表空間 TSEMPLOYEE 及表 XUJM.TGT_EMPLOYEE（結構與源表一致）
• 插入 IBMQREP_TARGETS 與 IBMQREP_TRG_COLS，完成列級映射

4. 啟動驗證

4.1 啟動監聽器

runmqlsr -t tcp -m SRC_QM -p 1451
runmqlsr -t tcp -m TGT_QM -p 1450

4.2 啟動通道並檢查狀態

runmqsc SRC_QM
start channel (SRC_QM.TO.TGT_QM)

runmqsc TGT_QM
start channel (TGT_QM.TO.SRC_QM)
DISPLAY CHSTATUS (TGT_QM.TO.SRC_QM)
# 顯示 STATUS(RUNNING) 即為成功

關鍵點總結

• 單機模擬雙系統時，兩個隊列管理器需使用不同端口（1450/1451），通道 CONNAME 指向同一 IP 不同端口。
• 遠程隊列定義中 RNAME 對應對端本地隊列名，RQMNAME 對應對端隊列管理器名，XMITQ 指向本地傳輸隊列。
• Q 復制控制表必須置於專用表空間，並正確設置 ARCH_LEVEL、COMPATIBILITY 等版本參數。
• 訂閱創建前，源表必須執行 ALTER TABLE ... DATA CAPTURE CHANGES。
• 通道狀態為 RUNNING 且 SUBSTATE(MQGET) 表示傳輸層已就緒，後續可啟動 Q Capture/Q Apply 程序進行實際數據同步。

後續擴展

生產環境部署時，建議：

1. 使用 Replication Center 圖形化工具簡化配置與監控。
2. 啟用 SSL/TLS 加密通道傳輸。
3. 配置心跳間隔、最大消息大小、錯誤重試策略等高級參數。
4. 建立監控告警，監視 IBMQREP_CAPMON、IBMQREP_APPLYMON 等監控表的延遲指標。