PHP与阿里云短信接口对接实际案例中的效率优化与并发处理方法

// 使用Redis作为缓存
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// 查询缓存中是否已发送过相同短信
if ($redis->get($smsContent . $phoneNumber)) {
    echo '该短信已发送过';
    return;
} else {
    // 发送短信...
    $result = sendSms($smsContent, $phoneNumber);
    
    // 发送成功，则存储到缓存中
    if ($result['code'] == 200) {
        $redis->set($smsContent . $phoneNumber, 1);
        $redis->expire($smsContent . $phoneNumber, 3600);
        echo '短信发送成功';
    } else {
        echo '短信发送失败';
    }
}

$phoneNumbers = array('13811111111', '13911111111', '13711111111');

// 创建多个子进程，每个子进程发送短信给一个手机号码
foreach ($phoneNumbers as $phoneNumber) {
    $pid = pcntl_fork();
    
    if ($pid == -1) {
        // 创建子进程失败
        exit('创建子进程失败');
    } elseif ($pid == 0) {
        // 子进程发送短信
        $result = sendSms($smsContent, $phoneNumber);
        
        if ($result['code'] == 200) {
            echo $phoneNumber . '：短信发送成功' . PHP_EOL;
        } else {
            echo $phoneNumber . '：短信发送失败' . PHP_EOL;
        }
        
        // 子进程退出
        exit();
    }
}

// 等待子进程结束
while (pcntl_waitpid(0, $status) != -1);

echo '所有短信发送完毕';

// 生产者进程
function producer($smsContent, $phoneNumber) {
    // 存储短信发送请求到消息队列中
    $messageQueue = msg_get_queue(123456);
    $message = $smsContent . '|' . $phoneNumber;
    msg_send($messageQueue, 1, $message);
}

// 消费者进程
function consumer() {
    $messageQueue = msg_get_queue(123456);
    while (true) {
        // 从消息队列中获取短信发送请求
        msg_receive($messageQueue, 0, $msgType, 1024, $message);
        list($smsContent, $phoneNumber) = explode('|', $message);
        
        // 发送短信...
        $result = sendSms($smsContent, $phoneNumber);
        
        if ($result['code'] == 200) {
            echo $phoneNumber . '：短信发送成功' . PHP_EOL;
        } else {
            echo $phoneNumber . '：短信发送失败' . PHP_EOL;
        }
    }
}

// 创建多个消费者进程
for ($i = 0; $i < 5; $i++) {
    $pid = pcntl_fork();
    
    if ($pid == -1) {
        // 创建子进程失败
        exit('创建子进程失败');
    } elseif ($pid == 0) {
        // 消费者进程
        consumer();
        exit();
    }
}

// 主进程作为生产者进程
$phoneNumbers = array('13811111111', '13911111111', '13711111111');
foreach ($phoneNumbers as $phoneNumber) {
    producer($smsContent, $phoneNumber);
}

// 等待所有子进程结束
while (pcntl_waitpid(0, $status) != -1);

echo '所有短信发送完毕';