php使用 Redis 队列,存取日志
- 场景需求
- 存入队列
- 队列中取数据
场景需求
做的一个教育系统,每天会生成很多操作日志,比如新增排课,比如删除学员等等……,那么这些操作记录,如果实时的写入数据库,必然对数据库的其他业务产生压力,由于这些日志不要求及时性,因此可以使用以下方式的消息模式.
存入队列
addLog.php 文件中内容示例如下:
$data = [];
$data[‘uid’] = 1;
$data[‘type’] = 4;
$data[‘content’] = “新增排课”;
//TODO 此处, 强烈建议使用 序列化 ,不要使用json_encode(),如果是本地文件缓存的形式,可以使用json_encode()
data = serialize($data);
//存入队列的尾部,如果key不存在,则创建key,存入value
$redis = new \Redis();
$result = redis−> connect ( redis->connect(redis−>connect(host,$port);
//如果redis设置了密码,注意验证!!!
$result = redis−>rpush(′newOrgLogs′,data);
队列中取数据
insertDb.php文件内容示例:
此处,有2种方式可以实现。
一、可以使用定时任务,比如每隔2分钟,执行一次 insertDb.php
二、可以使用守护进程解决
try{
//连接 mysql数据库
$conn = new mysqli($DB_HOST, $DB_USER, $DB_PWD, $DB_NAME);
if(! $conn )
{
die(‘连接失败: ‘ . mysqli_error($conn));
}
mysqli_query($conn, “set names utf8”);
}catch( Exception $e){
//系统异常,邮件报警
$ message = “<h1>mysql数据库连接失败</h1>”;
$message .= “<p>insertDb.php</p>”;
$message .= “<p>”.$e-> getMessage ().”</p>”;
$data = array(
’email’ => ‘test@qq.com’,
‘subject’ => ‘日志接口’,
‘content’ => $message
);
curl($MAIL_URL, $data);
echo “sorry,error was happend.”.$e->getMessage();
exit();
}
//这里是主逻辑
while(true){
$cacheData = $redis->lpop(‘newOrgLogs’);
if$cacheData!=”){
//一定要反序列化
$cacheData = @unserialize($cacheData);
if ($cacheData){
$sql = “INSERT INTO {$DB_PREFIX}organization_log
(organizationId,uid,type,content,create_at,cardId,planId,registerType)
VALUES
({$cacheData[‘organizationId’]},{$cacheData[‘uid’]}, {$cacheData[‘type’]},'{$cacheData[‘content’]}’,{$cacheData[‘create_at’]},{$cacheData[‘cardId’]},{$cacheData[‘planId’]},{$cacheData[‘registerType’]})”;
$res = mysqli_query($conn, $sql);
}
}
}
最后,在linux 中 执行 nohup php insertDb.php & 命令。此命令类似开启守护进程(ctrl+c也不退出)
至于nohup 与 & 命令功能 请自行百度