因网络延迟造成数据库插入相同记录,如何解决.

时间:2022-01-29 17:12:37

因网络延迟造成相同数据重复插入到数据库中,查询报sqlMap[] result tomany

场景再现:接手了一个项目,注册模块对于不可重复注册功能,使用的是java代码控制,即在注册之前,先查询数据库中用户表有没有存在这个用户,有就提示“该用户已经注册”;没有,就插入当前用户到数据库中,提示“注册成功”。    这个逻辑是普遍做法,一般不会出现什么问题。但我们现在碰到了问题,有一个新用户,在不同设备上几乎同时点击注册,即便这样也会存在毫秒级的时间差距,理论上是可以通过上述逻辑限制重复注册。但如果网络出现了延迟,会出现两条插入语句同时插入到了数据库中,我们不是有代码判断吗?为什么还会出现这样的情况,答案就在“延迟”,万恶的延迟。     仔细剖析:第一次注册,注册信息已经插入到数据库中,本应该返回主键,以判断是否插入成功,然后再插入下一条信息;但此时由于是在两台设备上几乎同时点击注册,那么就是开启了两条线程,分别同时执行插入数据的sql操作,查询语句来不及对第一次注册的结果进行查询,第二次就已经插入进去了,所以会出查询结构too many错误,对于注册模块来说,就出现了逻辑上的错误,这样的特例几乎不会发生,但在大用户量、某些高并发操作的时候,就会出现这样的问题,一旦出现就会严重影响客户的使用体验,这是要坚决杜绝的错误。 解决方案: 1.对某一字段添加唯一索引,如账号 userName、手机 mobilePhone,在插入时如果存在有相同的userName或mobilePhone,则忽略,不会报错;不存在,则插入。 以ibatis为例
<insert id="insertUser" paramClass="java.utill.map" resultClass="java.lang.Integer">
insert ingore into user_info (userName,mobilePhone,passWord,sex)values(#userName#,#mobilePhone#,#passWord#,#sex#);
<selectKey keyPropety="userInfoId" resultClass="java.lang.Integer">
<![CDATA[
     select LAST_INSERT_ID() AS userInfoId
 ]]>
<selectKey>
</insert>
2.不添加唯一索引,在sql中,查找是否存在相同记录,存在返回错误;不存在,则插入;
<insert id="insertUser" paramClass="java.utill.map" resultClass="java.lang.Integer">
insert into userInfo(userName,mobilePhone,passWord,sex)select #userName#,#mobilePhone#,#passWord#,#sex# from dual
 where notEXISTS(SELECT userName,mobilePhone from userInfo where userName=#userName# and mobilePhone=#mobilePhone# )    
<selectKey keyPropety="userInfoId" resultClass="java.lang.Integer">
<![CDATA[
select LAST_INSERT_ID() AS userInfoId
 ]]>
</selectKey>
</insert>
3.对http请求序列化,将几乎同时发过来的请求做排序,等第一个请求完成之后,再放出第二个请求。