Java多线程导致的的一个事物性问题

业务场景

我们现在有一个类似于文件上传的功能,各个子站点接受业务,业务上传文件,各个子站点的文件需要提交到总站点保存,文件是按批次提交到总站点的,也就是说,一个批次下面约有几百个文件。

考虑到白天提交这么多文件会影响到子站点其他系统带宽,我们将分站点的文件提交到总站点这个操作过程独立出来,放到晚上来做,具体时间是晚上7:00到早上7:00。

这个操作过程我们暂且称作“排程”。 排程在运行之后,先获取所有需要上传到总站点的批次信息,拿到批次信息之后,将这个批次表的状态置为正在同步数据,这个时候,如果这个批次再有业务人员上传文件,发现批次正在同步,就会返回操作失败。

现在产生的问题:

1,排程获取到批次,准备将批次表状态置为正在同步,注意这时候批次表还没有改成正在同步。

2,业务人员对这个批次提交100张文件,由于批次表状态还没改成正在同步,所以校验通过,准备插入数据到数据库,注意这时候文件信息还没插入到数据库,只是准备插入。

3,排程将批次表信息置为正在同步,并且获取到批次下面所有文件信息保存到内存,准备一个一个上传文件。

4,业务人员上传的文件信息成功保存到数据库。

这种情况下,就会导致,第四步保存到数据库中的文件信息并没有提交到总站点。

分析:

大家没看懂上面的业务信息,没关系,我们可以以一种更通俗的方式来描述:

我们去电影院看3D电影, 假如电影是在9:00开播, 9:00之后演播大厅关门,然后服务人员给所有坐在位子上的人发一个滤光眼镜,这时候就会有一个问题,那些正在走向位子上的人怎么办? 这就是我们现在的问题。

我们想到2种解决方案:

1: 我们关上门之后等待一段时间,让所有的人都走到位子上,之后服务人员再发眼镜。

2:服务人员每隔一段时间就检测下,有没有坐在位子上的人没有眼镜,没有眼镜就发一个。

注意:业务场景看电影的人是没办法主动要眼镜的 J

如果使用第二种方法,我们几十个分站点会频繁访问总站点查询数据,这个查询是全表扫描,这对数据库性能影响太大。考虑到这个排程进程是后台进程,第一种方法虽然处理慢点,但是对系统影响更小,而且在一定程度上会减缓服务器的CPU压力,最终我们选择了第一种方案。

希望能对你有帮助。

Java多线程导致的的一个事物性问题

时间: 2024-10-31 05:07:02

Java多线程导致的的一个事物性问题的相关文章

java多线程并发去调用一个类的静态方法安全性探讨

java多线程并发去调用一个类的静态方法安全性探讨 转自:http://blog.csdn.net/weibin_6388/article/details/50750035 这篇文章主要讲多线程对静态方法访问的数据安全性 总结如下: 1,java在执行静态方法时,会在内存中拷贝一份,如果静态方法所在的类里面没有静态的变量,那么线程访问就是安全的,比如在javaee中服务器必然会多线程的处理请求此时如果设计全局需要调用的静态方法,可用此种设计. 2,java在执行静态方法时,如果使用静态变量,同时

java多线程下如何调用一个共同的内存单元(调用同一个对象)

1 /* 2 * 关于线程下共享相同的内存单元(包括代码与数据) 3 * ,并利用这些共享单元来实现数据交换,实时通信与必要的同步操作. 4 * 对于Thread(Runnable target)构造方法创建的线程,轮到它来享用CPU资源时. 5 * 目标对象就会自动调用接口中的run()方法 6 * */ 7 8 /* ----------------举例子------------------- */ 9 10 /* 11 * 使用Thread类创建两个模拟猫和狗的线程,猫和狗共享房屋中的一桶

java多线程编程--如何开始一个线程

如何开始一个线程 1. java多线程的实现方式 1.1 继承Thread类 定义类如下: public SubThread extends Thread { @override public void run() { ... } } 使用时: Thread subThread = new SubThread(); subThread.start(); 可以使用Thread类已有的函数进行操作. 1.2 实现Runnable接口 定义类如下: public SubThread implement

java多线程很好的一个实例

java中的多线程 在java中要想实现多线程有两种手段一种是继续Thread类另外一种是实现Runable接口. 对于直接继承Thread的类来说代码大致框架是 ? 1 2 3 4 5 6 7 8 9 10 11 12 class 类名extends Thread{ 方法1; 方法2 … public void run(){ // other code… } 属性1 属性2 … } 先看一个简单的例子 ? 1 2 3 4 5 6 7 8 9 1 0 1 1 1 2 1 3 1

java多线程编程--如何终止一个线程

1. Thread.stop()函数 stop()函数终止线程就像是强行拔掉电源线关机一样,可能会带来未知风险,因此目前不再推荐使用这种方式.请忘记它吧~~ 2. 改变标志变量状态 通常我们会在线程中使用一个标志变量来控制线程的运行,如: public class TestCallable implements Runnable { private boolean running = true; public void stop() { this.running = false; } publi

Java多线程产生死锁的一个简单案例

synchronized是Java中的关键字,是一种同步锁.它修饰的对象有以下几种: 1. 修饰一个代码块,被修饰的代码块称为同步语句块,其作用的范围是大括号{}括起来的代码,作用的对象是调用这个代码块的对象:2. 修饰一个方法,被修饰的方法称为同步方法,其作用的范围是整个方法,作用的对象是调用这个方法的对象:3. 修改一个静态方法,其作用的范围是整个静态方法,作用的对象是这个类的所有对象:4. 修改一个类,其作用的范围是synchronized后面括号括起来的部分,作用主的对象是这个类的所有对

java多线程(六)深入理解volitale关键字

转载请注明出处:http://blog.csdn.net/xingjiarong/article/details/47945849 我们继续来讨论java的多线程编程,今天我们一起来学习一下java多线程中的另一个关键字--volitale. 一.java内存模型与多线程编程中的三个感念 1.原子性 原子性是指一些操作或者全都执行,要么或者全都不执行,整个操作作为一个整体是不可分割的,例如,一个银行中有两个账户A,B,现在要从A账户中转账500元到B账户,那么一共可以分为两个步骤: 1.从A账户

Java多线程的同步机制(synchronized)

一段synchronized的代码被一个线程执行之前,他要先拿到执行这段代码的权限,在 java里边就是拿到某个同步对象的锁(一个对象只有一把锁): 如果这个时候同步对象的锁被其他线程拿走了,他(这个线程)就只能等了(线程阻塞在锁池 等待队列中). 取到锁后,他就开始执行同步代码(被synchronized修饰的代码):线程执行完同步代码后马上就把锁还给同步对象,其他在锁池中 等待的某个线程就可以拿到锁执行同步代码了.这样就保证了同步代码在统一时刻只有一个线程在执行. 众所周知,在Java多线程

关于JAVA多线程的那些事__初心者

前言 其实事情的经过也许会复杂了点,这事还得从两个月前开始说.那天,我果断不干IT支援.那天,我立志要做一个真正的程序猿.那天,我26岁11个月.那天,我开始看Android.那天,我一边叨念着有朋自远方来,一边投身了JAVA的怀抱.那天,一切将会改变. 好吧,反正总的来说就是时隔4年半,我又开始搞JAVA了.Eclipse还是Eclipse:NetBeans还是NetBeans:Java被收之后已经来到了7,现在是8:在入手了几本JAVA的书籍后发现<JAVA编程思想>还是这么伟大:开始了新