如何解决Ignite客户端执行Insert时因Drop表导致的持续等待问题

问题根源 #

当执行DROP TABLE时，Ignite/GridGain会销毁对应的底层缓存（Cache），持续执行Insert的客户端：

• 多数场景下，因缓存已停止，请求会抛出CacheStoppedException但可能因未设置超时导致卡住；
• 偶发场景下，服务端缓存元数据已被清理，但仍收到Insert请求，引发未注册消息处理器及NullPointerException异常。

具体解决方案 #

1. 给Insert请求设置超时，强制终止卡住的操作

在执行Insert的SQL查询时显式设置超时时间，确保请求不会无限等待，同时捕获异常后及时终止Insert循环：

SqlFieldsQuery insertQuery = new SqlFieldsQuery("INSERT INTO PRODUCT(id, name) VALUES(?, ?)");
insertQuery.setTimeout(5000); // 5秒超时，可根据业务调整

while (/* 循环条件 */) {
    try {
        client.query(insertQuery).getAll();
    } catch (IgniteException e) {
        // 识别缓存停止异常，终止循环
        if (e.hasCause(CacheStoppedException.class)) {
            break;
        }
        // 处理其他异常
        e.printStackTrace();
    }
}

2. 监听缓存销毁事件，主动停止Insert

通过监听对应SQL表的缓存销毁事件，在表被删除时立刻终止Insert操作：

// 获取PRODUCT表对应的缓存（默认SQL表缓存命名规则：SQL_<SCHEMA>_<TABLE>，默认SCHEMA为PUBLIC）
IgniteCache<?, ?> productCache = client.cache("SQL_PUBLIC_PRODUCT");
AtomicBoolean stopInsert = new AtomicBoolean(false);

// 注册缓存销毁事件监听器
productCache.listen(evt -> {
    if (evt.type() == EVT_CACHE_DESTROYED) {
        stopInsert.set(true);
        return false; // 触发后取消监听
    }
    return true;
});

// Insert循环逻辑
while (!stopInsert.get()) {
    // 执行Insert操作
}

3. 升级版本修复偶发服务端异常

你使用的8.8.9版本存在已知的元数据清理与请求处理的并发问题，升级到Ignite 2.15+或GridGain 8.8.20+的稳定版本，可直接解决服务端未注册消息处理器及NullPointerException的偶发现象。

4. 业务层添加并发控制（适用于生产/测试场景）

通过Ignite分布式锁协调Insert与Drop操作，避免两者同时执行：

// Insert客户端
IgniteLock tableLock = client.reentrantLock("PRODUCT_TABLE_LOCK", true, true, true);
try {
    while (/* 循环条件 */) {
        // 执行Insert
    }
} finally {
    tableLock.unlock();
}

// Drop客户端
IgniteLock dropLock = client.reentrantLock("PRODUCT_TABLE_LOCK", true, true, true);
try {
    client.query(new SqlFieldsQuery("DROP TABLE PRODUCT")).getAll();
} finally {
    dropLock.unlock();
}

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