美女 小说,朝三暮四的故事,查价狗
业务背景：
基本业务场景是这样的，请求数据（车辆vin信息）进入到接口中，需要先判断其在数据库中的状态，如果库中不存在该vin，或者该vin状态位为“1（已完成）”，则执行一些检查操作后，将数据插入到数据库中，此时新增vin状态为0，调用人工处理接口，十分钟后返回结果，将状态置为1。如果其状态位为“0（正在处理）”则驳回操作，返回提示信息。
在单线程环境下，这样的业务没有问题，然而当并发访问接口时，会出现同时进入两条vin相同的请求ab，正常情况应该插入一条a，驳回一条b。然而并发环境下，b执行检查状态时a还没有插入，因此ab都进入到了数据库中，数据就错误了。
解决方案一：
首先想到的是使用sql处理，对数据库对应字段加唯一索引，保证一致性。如果插入重复的数据，则catch该异常，做出提示。
alter tablename add unique [indexname] on (tablecolumns(length))
但是由于业务限制，vin在库中是可以重复的，多条重复数据查询最新，所以不能再vin上添加唯一索引。
解决方案二：
使用mysql事务操作，将检查是否存在和插入作为一个事务进行处理，当检查失败的时候，不进行插入。从网上搜索了一下，大致思路如下：
我要评论
public static void starttransaction(connection con, string[] sqls) throws exception {
try {
// 事务开始
con.setautocommit(false); // 设置连接不自动提交，即用该连接进行的操作都不更新到数据库
sm = con.createstatement(); // 创建statement对象
//依次执行传入的sql语句
for (int i = 0; i < sqls.length; i++) {
sm.execute(sqls[i]);// 执行添加事物的语句
}
con.commit(); // 提交给数据库处理
// 事务结束
//捕获执行sql语句组中的异常
} catch (sqlexception e) {
try {
system.out.println("事务执行失败，进行回滚！\n");
con.rollback(); // 若前面某条语句出现异常时，进行回滚，取消前面执行的所有操作
} catch (sqlexception e1) {
e1.printstacktrace();
}
} finally {
sm.close();
}
}
但是这样实际上还是没有解决并发的问题，这样只是把两个操作变成了一个原子的sql操作，可以用于同时插入两条数据一致性的情况，但并不适合需求。
既然sql层面没有解决问题，就考虑从java的并发编程方向解决。
解决方案三：
java解决并发问题，首先想到的是使用内置锁或者可重入锁，基本语法如下：
·内置锁：
由于是在servlet中进行的处理，因此使用synchronized(this)直接处理业务代码，使得并发情况下，只能有一个线程访问到该段业务代码：
synchronized(this){
//todo1:检查vin是否存在
//todo2:如果不存在插入vin
}
·可重入锁：
相当于更灵活的内置锁，在这里与内置锁基本相同
public class dashengcallback extends httpservlet {
private static reentrantlock lock= new reentrantlock();
protected void doget(httpservletrequest request, httpservletresponse response){
lock.lock();
try{
//todo1:检查vin是否存在
//todo2:如果不存在插入vin
}finally{
lock.unlock();
}
}
}
经过测试，这个方案是可行的，最终没有采用的原因是因为直接使用这种方式加锁，加锁的代码太多，影响效率。
解决方案四：
设置一个查询map，插入前存储数据，插入后删除数据，代码如下：
concurrenthashmap<string, string> vinmap=new concurrenthashmap<string,string>();
if(vinmap.containskey(vin)){
// todo1: vin 请求完毕后, 从vininrequestmap里删掉这个vinno
// todo2: 返回正在查询
}
vinmap.put(vin, "");
//todo3:插入vin到数据库
vinmap.remove(vin);
}
这个方案基本满足了业务需求，唯一的问题是要求接口的更新时间要与业务时间错开，否则更新接口会清空vinmap，导致库中数据混乱，出现错误。
以上就是本文的全部内容，希望对大家的学习有所帮助。
如对本文有疑问，请在下面进行留言讨论，广大热心网友会与你互动！！ 点击进行留言回复
小白安装登录mysql-8.0.19-winx64的教程图解(新手必看)
Navicat连接MySQL时报10060、1045错误及my.ini位置问题
网友评论