PHP如何避免高并发下insert into 重复入库

Stella981
• 阅读 181

场景:用户签到/分享功能,每天只能签到一次或分享一次

数据库:id   user_id   add_time  

逻辑分析:用户每天进行分享或签到,得到积分,数据库通过以上字段进行记录,同一时间不可插入多条,一天只能有一条记录,插入前判断是否当天已插入过

问题点:用户连点、并发请求等会导致同时插入多条记录,导致积分异常

解决方案:使用文件锁,经过以下调整后,golang 30条并发测试只能插入一条。期间也想过用其他方法,比如add_time和user_id作为联合唯一索引。这样也能解决当下的问题,但有一个弊端就是批量插入数据的时候会有问题

$fileName = __DIR__ . '/temp/' . $user_id . '-' . date('Y-m-d') . '.txt';

        $fp = fopen($fileName, 'w+');
        // 创建临时文件
        if (!is_dir('temp')) {
            @mkdir('temp', 0777);
        }
        // 当天的文件
        if (!file_exists($fileName)) {
            @file_put_contents($fileName, '');
        }
        // 使用非阻塞的文件排他锁,防止高并发插入多条数据
        if (!flock($fp, LOCK_EX | LOCK_NB)) {  //flock() 函数锁定或释放文件。
            return false;
        }

        $sql = "INSERT INTO log ....";
        $GLOBALS['db']->query($sql);
        flock($fp,LOCK_UN);//释放锁
点赞
收藏
评论区
推荐文章
风斗 风斗
1年前
MySQL8.0 json 使用 类型 查询 函数_denglei的博客
一,对记录的操作1.创建有json字段的表 创建表CREATE TABLE t_json(id INT PRIMARY KEY, sname VARCHAR(20) , info JSON);2.插入记录 插入含有json数组的记录 INSERT INTO t_json(id,sname,info) VAL
Wesley13 Wesley13
1年前
mysql存在则更新,不存在则插入
INSERT INTO ON DUPLICATE KEY UPDATE 与 REPLACE INTO,两个命令可以处理重复键值问题,在实际上它之间有什么区别呢? 前提条件是这个表必须有一个 唯一索引或主键。 unique 1、REPLACE发现重复的先删除再插入,如果记录有多个字段,在插入的时候如果有的字段没有赋值,那么新插入的记录这些字段
Wesley13 Wesley13
1年前
mysql数据库先update后insert死锁分析
先update再insert的并发死锁问题分析。 背景 -- “如果库里有对应记录,就更新,没有就插入” 很简单的一个逻辑,相信很多人都会遇到。 最近看一个工程里实现代码是这样的,mysql数据库走的是默认的事务级别:可重复读。包在一个事务中执行: if update更新结果>0 then return "成功"; el
Wesley13 Wesley13
1年前
Mysql_项目1:group by和having的使用(删除重复的电子邮箱)
**项目1:查找重复的电子邮箱** 创建 email表,并插入如下三行数据 **\-- 创建表** CREATE TABLE email( id INT NOT NULL auto_increment, email VARCHAR(20) NOT NULL, PRIMARY KEY(id)); **\-- 插入数据**
Stella981 Stella981
1年前
Mybatisd对MySQL批量插入、批量更新及批量删除语句
1、批量插入 `<insert id="insertBatch" parameterType="java.util.List"> insert into t_student(name, age, class) values <forea
Wesley13 Wesley13
1年前
Mysql 插入记录时检查记录是否已经存在,存在则更新,不存在则插入记录SQL
我们在开发数据库相关的逻辑过程中, 经常检查表中是否已经存在这样的一条记录, 如果存在则更新或者不做操作, 如果没有存在记录,则需要插入一条新的记录。 这样的逻辑固然可以通过两条sql语句完成。 SELECT COUNT(*) FROM xxx WHERE ID=xxx; if (x == 0) INSERT I
Wesley13 Wesley13
1年前
MySQL 24小时入门笔记(3),插入和删除,删库到跑路
MySQL 24小时入门笔记 ============== 插入 -- ### INSERT `INSERT`用法非常简单。现在我们有表`students`如下。 列名 类型 约束 id int primary key name char(16) NOT NULL 向里面插入一条学号为`1`,姓名为`学姐`的学生,只需要写如下`SQ
Stella981 Stella981
1年前
Node.js 使用 MongoDB 的 ObjectId 作为查询条件
当往MongoDB中插入一条数据时,会自动生成ObjectId作为数据的主键。 那么如何通过ObjectId来做数据的唯一查询呢? 在MongoDB中插入一条数据 --------------- 在MongoDB中插入一条如下结构的数据: { _id: 5d6a32389c825e24106624e4, title: '
Stella981 Stella981
1年前
DataSourceTransactionManager进行事务管理
  最近在做报表excel导入插入数据的时候,插入数据之前要清除当前用户和报告期下的数据,删除后执行错误导致删除运行,接口报错, redis中获取的数据没有刷新,导致再次执行其他操作时报错。   在这里用到DataSourceTransactionManager进行事务管理,可能需要多条sql完成对数据库的操作,比如账户登录,需要匹配用户名和密码,然后要
Easter79 Easter79
1年前
sql注入
反引号是个比较特别的字符,下面记录下怎么利用 0x00 SQL注入 ---------- 反引号可利用在分隔符及注释作用,不过使用范围只于表名、数据库名、字段名、起别名这些场景,下面具体说下 1)表名 payload:select \* from \`users\` where user\_id=1 limit 0,1; ![](https://o