当前位置：首页 > news >正文

mysql处理并发简单示例

news 2025/8/22 2:23:34

处理并发的基本思路是使用锁来控制对共享资源的访问。在MySQL中，可以使用事务和行级锁来处理并发。

具体处理方式如下：

创建一个用于存储并发任务的MySQL表，该表包含一个自增的ID字段和任务名称字段。
设置一个最大并发数量，用来限制同时执行的任务数量。
创建一个处理函数，用于执行并发任务的逻辑。
在主程序中，创建多个子进程，每个子进程执行处理函数。
在处理函数中，循环执行并发任务的逻辑，包括获取锁、执行任务、释放锁。
判断当前并发数量是否超过最大并发数量，如果未超过，则执行任务并更新数据库；否则等待一段时间后重新检查。
子进程执行完毕后退出。

下面是详细的示例代码，其中包含了注释来解释每一步的操作：

<?php
// 连接到 MySQL 数据库
$servername = "localhost";
$username = "username";
$password = "password";
$dbname = "database";$conn = new mysqli($servername, $username, $password, $dbname);
if ($conn->connect_error) {die("连接失败: " . $conn->connect_error);
}// 创建并发处理任务的表
$createTableQuery = "CREATE TABLE IF NOT EXISTS concurrent_tasks (id INT AUTO_INCREMENT PRIMARY KEY,task_name VARCHAR(255) NOT NULL)";
$conn->query($createTableQuery);// 设置最大并发数量
$maxConcurrency = 5;// 并发处理函数
function concurrentProcess($processId, $maxConcurrency) {global $conn;echo "进程 $processId 开始执行\n";// 循环执行并发处理while (true) {// 获取当前并发数量$countQuery = "SELECT COUNT(*) AS count FROM concurrent_tasks";$result = $conn->query($countQuery);$row = $result->fetch_assoc();$currentConcurrency = $row['count'];// 判断当前并发数量是否超过最大并发数量if ($currentConcurrency < $maxConcurrency) {// 获取锁$conn->query("START TRANSACTION");// 执行并发任务$concurrentTask = "任务 $processId";$insertQuery = "INSERT INTO concurrent_tasks (task_name) VALUES ('$concurrentTask')";$conn->query($insertQuery);echo "进程 $processId 执行任务：$concurrentTask\n";// 模拟实际任务执行时间sleep(rand(1, 5));// 释放锁$conn->query("COMMIT");// 任务完成后，从数据库中删除任务$deleteQuery = "DELETE FROM concurrent_tasks WHERE task_name = '$concurrentTask'";$conn->query($deleteQuery);echo "进程 $processId 完成任务：$concurrentTask\n";} else {// 若当前并发量已满，则等待一段时间再继续检查sleep(1);}}
}// 创建并发处理进程
$processes = [];
for ($i = 1; $i <= $maxConcurrency; $i++) {// 执行并发处理函数的子进程$processes[$i] = popen("php -r 'require(\"concurrent_process.php\"); concurrentProcess($i, $maxConcurrency);'", 'r');
}// 主进程等待子进程执行完毕
foreach ($processes as $process) {pclose($process);
}// 关闭数据库连接
$conn->close();
?>