Java+SQL Server遗留系统：无需轮询监控表新增记录方案咨询

针对你的Java遗留系统+SQL Server架构，以下几种方案无需定时轮询，也不用引入Kafka等消息队列，适合现有系统的低侵入改造：

方案1：SQL Server 查询通知（Query Notifications） #

这是最轻量化的方案之一，利用SQL Server原生的通知机制结合JDBC驱动实现主动推送，完全避免轮询。

• 实施步骤：
  1. 先开启SQL Server的Service Broker（通知依赖此组件）：

     ALTER DATABASE YourDatabaseName SET ENABLE_BROKER;
     

  2. 给数据库用户授予通知权限：

     GRANT SUBSCRIBE QUERY NOTIFICATIONS TO YourDBUser;
     

  3. Java端代码实现：
     使用SQL Server官方JDBC驱动，注册监控查询并监听通知。注意监控查询要符合SQL Server的规则（不能用*、TOP等，这里用一个永远返回空的查询来注册表的监控）：

     String dbUrl = "jdbc:sqlserver://localhost:1433;databaseName=YourDatabaseName;";
     String user = "YourDBUser";
     String pwd = "YourDBPwd";
     
     try (SQLServerConnection conn = (SQLServerConnection) DriverManager.getConnection(dbUrl, user, pwd)) {
         String monitorQuery = "SELECT id FROM dbo.YourTargetTable WHERE 1=0";
         SQLServerStatement stmt = (SQLServerStatement) conn.createStatement();
         // 注册通知规则：监听表的INSERT事件
         stmt.setQueryNotification("service=TableInsertNotification;local database=YourDatabaseName");
         stmt.execute(monitorQuery);
     
         // 注册通知处理器
         conn.registerNotificationHandler(new SQLServerNotificationHandler() {
             @Override
             public void onNotification(SQLServerNotificationArgs args) {
                 if (args.getEventType() == SQLServerNotificationEventType.Insert) {
                     // 触发新插入逻辑，这里可以查询最新记录
                     System.out.println("检测到新记录插入");
                     // 可重新执行查询获取新增数据
                 }
             }
         });
     
         // 保持连接存活，可结合线程阻塞逻辑
         Thread.currentThread().join();
     } catch (Exception e) {
         e.printStackTrace();
     }
     

• 注意：如果连接断开，需要重新注册通知；监控查询的语法有严格限制，需确保合规。

方案2：SQL Server Change Data Capture (CDC) + 阻塞式读取 #

CDC是SQL Server内置的变更捕获功能，会自动把表的INSERT/UPDATE/DELETE操作记录到专用的变更表，我们可以通过阻塞式查询来等待新的变更，避免空轮询。

• 实施步骤：
  1. 开启数据库和目标表的CDC：

     -- 开启数据库级CDC
     EXEC sys.sp_cdc_enable_db;
     -- 开启目标表的CDC（指定要捕获的列，这里选id和你需要的字段）
     EXEC sys.sp_cdc_enable_table
         @source_schema = N'dbo',
         @source_name = N'YourTargetTable',
         @role_name = NULL,
         @captured_column_list = N'id, column1, column2';
     

  2. Java端实现阻塞式读取：
     使用WAITFOR语法让查询一直等待，直到有新的INSERT变更（__$operation=2代表INSERT操作）：

     String dbUrl = "jdbc:sqlserver://localhost:1433;databaseName=YourDatabaseName;";
     String user = "YourDBUser";
     String pwd = "YourDBPwd";
     
     while (true) {
         try (Connection conn = DriverManager.getConnection(dbUrl, user, pwd);
              Statement stmt = conn.createStatement()) {
             // 阻塞等待新的INSERT记录
             String query = "WAITFOR (SELECT __$operation, id, column1 FROM cdc.dbo_YourTargetTable_CT WHERE __$operation = 2)";
             ResultSet rs = stmt.executeQuery(query);
             while (rs.next()) {
                 // 处理新增记录
                 int newId = rs.getInt("id");
                 String col1 = rs.getString("column1");
                 System.out.println("新插入记录ID：" + newId + "，column1：" + col1);
             }
         } catch (SQLException e) {
             // 连接异常时重试，避免死循环
             try {
                 Thread.sleep(5000);
             } catch (InterruptedException ie) {
                 Thread.currentThread().interrupt();
             }
         }
     }
     

• 注意：CDC会占用数据库存储空间，需要定期清理旧的变更记录（可通过sys.sp_cdc_cleanup_change_table存储过程）；阻塞式查询要处理连接中断的重试逻辑。

方案3：SQL Server触发器 + 本地IPC通信 #

如果上面两种方案受限（比如无法开启Service Broker或CDC），可以用触发器结合本地进程间通信的方式，当有新记录插入时，触发器主动通知Java程序。

• 实施步骤：
  1. 开启SQL Server的CLR集成（如果用CLR存储过程发消息）：

     sp_configure 'show advanced options', 1;
     RECONFIGURE;
     sp_configure 'clr enabled', 1;
     RECONFIGURE;
     

  2. 编写CLR存储过程（C#），通过Socket发送消息到Java程序的监听端口，然后部署到SQL Server。
  3. 创建INSERT触发器：

     CREATE TRIGGER trg_YourTargetTable_Insert ON dbo.YourTargetTable
     AFTER INSERT
     AS
     BEGIN
         SET NOCOUNT ON;
         DECLARE @newId INT;
         SELECT @newId = id FROM inserted;
         -- 调用CLR存储过程发送通知
         EXEC dbo.SendInsertNotification @newId;
     END
     

  4. Java端启动Socket服务器监听：

     try (ServerSocket serverSocket = new ServerSocket(9999)) {
         while (true) {
             Socket clientSocket = serverSocket.accept();
             BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
             String newIdStr = in.readLine();
             System.out.println("收到新插入记录ID：" + newIdStr);
             // 根据ID查询完整记录进行处理
             clientSocket.close();
         }
     } catch (IOException e) {
         e.printStackTrace();
     }
     

• 注意：触发器逻辑要尽量轻量化，避免影响原系统的插入性能；CLR存储过程的部署要符合SQL Server的安全策略，也可以用扩展存储过程替代CLR（但扩展存储过程安全性较低）。

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