多个定时脚本同一时间执行时，clickhouse爆内存异常

ae7c54573860b201fb38353548b2f5b.png

解决方式：利用redis进行加锁，同一时间内，只能先执行一个脚本

<?php

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

$lockKey = 'my_lock_key';
$timeout = 10; // 锁超时时间

// 加锁
function acquireLock($redis, $lockKey, $timeout) {
    $identifier = uniqid(); // 生成唯一标识符
    $end = time() + $timeout;
    while (time() < $end) {
        if ($redis->set($lockKey, $identifier, ['NX', 'EX' => $timeout])) {
            return $identifier;
        } else if ($redis->ttl($lockKey) == -1) {
            // 防止锁没有正常释放而导致的死锁情况
            $redis->expire($lockKey, $timeout);
        }
        usleep(100000); // 等待100毫秒
    }
    return false;
}

// 释放锁
function releaseLock($redis, $lockKey, $identifier) {
    $script = "
        if redis.call('get', KEYS[1]) == ARGV[1] then
            return redis.call('del', KEYS[1])
        else
            return 0
        end
    ";
    $redis->eval($script, [$lockKey, $identifier], 1);
}

// 使用示例
$identifier = acquireLock($redis, $lockKey, $timeout);
if ($identifier) {
    try {
        // 在这里执行需要加锁的操作
        echo "成功获取锁，进行任务处理\n";
        sleep(5);
    } finally {
        releaseLock($redis, $lockKey, $identifier);
        echo "释放锁\n";
    }
} else {
    echo "未能获取锁，任务正在执行中\n";
}