设计产品网站推荐_十大禁用黄台免费入口_澎湃新闻_全网自媒体平台大全

1、数据存入 Rides

/*------------------------data数据存入rides数据库-----------------------------*/
function _setByTj4($data)
{global $redis4;if (!$redis4) {$redis4 = new Redis();$redis4->connect('127.0.0.1');// 选择数据库，例如数据库3$redis4->select(4);}$jsonString = json_encode($data, true);$redis4->rPush('sqlQueue', $jsonString);
}

2、读取并删除Rides对应读取内容
 

// 连接到 Redis
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$redis->select(4);// 从头部删除并返回指定数量的元素
function popLeftElements($listName, $count)
{global $redis;// 获取列表的前 count 个元素$elements = $redis->lRange($listName, 0, $count - 1);// 删除这些元素$redis->lTrim($listName, $count, -1);return $elements;
}// 删除并返回前2000个元素
$removedElements = popLeftElements('sqlQueue', 2000);$result = array_map(function ($json) {return json_decode($json, true); // 将 JSON 字符串转换为数组
}, $removedElements);// 构建批量插入SQL语句
$sql = "INSERT INTO access_records (member_id,ip,url,headers,source,addTime,wxopenid) VALUES ";$valuesArr = [];
foreach ($result as $row) {$member_id = $row['member_id'] ? $row['member_id'] : 0;$ip = $row['ip'] ? $row['ip'] : '';$url = $row['url'] ? $row['url'] : '';$headers = $row['headers'] ? $row['headers'] : '';$source = $row['source'] ? $row['source'] : '';$addTime = $row['addTime'];$wxopenid = $row['wxopenid'] ? $row['wxopenid'] : '';$valuesArr[] = "('{$member_id}', '{$ip}', '{$url}', '{$headers}', '{$source}', '{$addTime}', '{$wxopenid}')";
}
$sql .= implode(", ", $valuesArr);
_query($sql);
echo '执行成功' . count($result) . '条';