在使用 PHP 和 Redis 实现队列功能时，代码逻辑有哪些需要改进的地方？

<?php

$config = include('./config.php');

$redis = new Redis();
$connect_retries = 3; // 重试连接次数
$retry_delay = 2; // 重试间隔 (秒)

function connectToRedis(Redis $redis, array $config): bool {
    try {
        $redis->connect($config['redis']['host'], $config['redis']['port']);
        return true;
    } catch (RedisException $e) {
        error_log("Redis connection failed: " . $e->getMessage());
        return false;
    }
}

if (!connectToRedis($redis, $config)) {
    die("Failed to connect to Redis.");
}


while (true) {
    try {
        $result = $redis->brpop($config['task_msg_key'], 1); // 设置超时时间为1秒

        if ($result) {
            // 处理消息
            list($queue, $message) = $result;
            // ... your message processing logic ...
            //  考虑使用事务保证消息处理的原子性
        } else {
            // 没有消息，短暂休眠
            sleep(1);
        }

    } catch (RedisException $e) {
        error_log("Redis operation failed: " . $e->getMessage());
        // 重试连接
        if (--$connect_retries > 0) {
            sleep($retry_delay);
            if (!connectToRedis($redis, $config)) {
                continue; // 继续重试
            }
        } else {
            die("Failed to connect to Redis after multiple retries.");
        }
    }
}