如何通过Java监听SQL Server变更事件？现有方案仅适用于.NET

你提到的SQL Server Query Notifications确实是.NET生态的专属方案，依赖ADO.NET组件，无法直接在Java环境中使用。以下是几种适配Java的实现方案：

1. 基于SQL Server Change Tracking的轮询方案 #

SQL Server内置的Change Tracking功能可以轻量记录数据的增删改变更，Java程序可以通过JDBC定期查询变更日志来获取数据变化。

配置步骤： #

• 先开启目标数据库和表的Change Tracking：

ALTER DATABASE YourDatabase SET CHANGE_TRACKING = ON (CHANGE_RETENTION = 2 DAYS, AUTO_CLEANUP = ON);
ALTER TABLE YourTable ENABLE CHANGE_TRACKING WITH (TRACK_COLUMNS_UPDATED = ON);

Java代码示例： #

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class ChangeTrackingListener {
    public static void main(String[] args) throws Exception {
        String url = "jdbc:sqlserver://your-server:1433;databaseName=YourDatabase;encrypt=true;trustServerCertificate=true;";
        String user = "your-user";
        String password = "your-password";
        
        try (Connection conn = DriverManager.getConnection(url, user, password);
             Statement stmt = conn.createStatement()) {
            // 获取上次同步的版本号（可存在本地或数据库中）
            long lastSyncVersion = getLastSyncVersion();
            
            // 查询变更数据
            String query = String.format(
                "SELECT * FROM CHANGETABLE(CHANGES YourTable, %d) AS CT " +
                "JOIN YourTable T ON CT.id = T.id",
                lastSyncVersion
            );
            try (ResultSet rs = stmt.executeQuery(query)) {
                while (rs.next()) {
                    // 处理变更数据，比如打印变更类型和记录
                    String operation = rs.getString("SYS_CHANGE_OPERATION");
                    System.out.printf("变更类型：%s，记录ID：%d%n", operation, rs.getInt("id"));
                }
            }
            
            // 更新同步版本号为当前数据库的最新变更版本
            updateLastSyncVersion(getCurrentChangeVersion(conn));
        }
    }
    
    private static long getLastSyncVersion() {
        // 从本地文件或数据库读取上次的同步版本，初始为0
        return 0;
    }
    
    private static void updateLastSyncVersion(long newVersion) {
        // 将新的版本号保存到本地或数据库
    }
    
    private static long getCurrentChangeVersion(Connection conn) throws Exception {
        try (Statement stmt = conn.createStatement();
             ResultSet rs = stmt.executeQuery("SELECT CHANGE_TRACKING_CURRENT_VERSION()")) {
            rs.next();
            return rs.getLong(1);
        }
    }
}

2. 基于SQL Server Service Broker的异步消息方案 #

Service Broker是SQL Server的消息队列组件，可以在数据变更时触发消息推送，Java程序通过JDBC监听队列实现异步通知。

配置步骤： #

1. 开启数据库的Service Broker：

ALTER DATABASE YourDatabase SET ENABLE_BROKER;

2. 创建消息类型、契约、队列和存储过程，用于在数据变更时发送消息（具体配置可参考SQL Server官方文档）。

Java代码示例（监听队列）： #

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class ServiceBrokerListener {
    public static void main(String[] args) throws Exception {
        String url = "jdbc:sqlserver://your-server:1433;databaseName=YourDatabase;encrypt=true;trustServerCertificate=true;";
        String user = "your-user";
        String password = "your-password";
        
        try (Connection conn = DriverManager.getConnection(url, user, password)) {
            conn.setAutoCommit(false);
            Statement stmt = conn.createStatement();
            
            while (true) {
                // 从队列接收消息
                String receiveQuery = "RECEIVE TOP(1) * FROM YourQueue";
                ResultSet rs = stmt.executeQuery(receiveQuery);
                
                if (rs.next()) {
                    // 解析消息内容
                    String messageBody = rs.getString("message_body");
                    System.out.printf("收到变更通知：%s%n", messageBody);
                    conn.commit();
                } else {
                    // 无消息时短暂休眠
                    Thread.sleep(1000);
                    conn.rollback();
                }
                rs.close();
            }
        }
    }
}

3. 基于Debezium的CDC实时捕获方案 #

Debezium是一款开源的CDC（Change Data Capture）工具，支持SQL Server，可以实时捕获数据变更并通过Kafka等消息中间件推送，Java程序可以通过消费Kafka消息获取变更通知。

核心优势： #

• 无需轮询，实时推送变更
• 支持全量快照和增量变更捕获
• 无需修改业务表结构

简单配置示例（Debezium SQL Server连接器）： #

name=sqlserver-connector
connector.class=io.debezium.connector.sqlserver.SqlServerConnector
database.hostname=your-server
database.port=1433
database.user=your-user
database.password=your-password
database.dbname=YourDatabase
database.server.name=sqlserver-db
table.include.list=dbo.YourTable

Java程序可以使用Kafka客户端消费Debezium推送的变更消息，解析消息中的变更内容进行处理。

内容的提问来源于stack exchange，提问作者wlaem