并发控制 集群 分布式
并发事务的定义:多个事务同时发生,会产生5中并发问题(3个读,两个更新),但其实在数据库的某一个时刻,只会执行一个sql,但一个事务可能包含多个步骤(sql),这样可能多个事务的多个步骤交叉执行,而产生并发问题。
并发一般可以采取锁和隔离级别进行处理。
那锁和隔离级别的区别在于哪里:
隔离级别----解决看的问题--select
锁----解决更新的问题。
例如spring的事务就可以配置隔离级别,不同的隔离级别会影响事务在select时所查询的结果。
不过我们一般很少使用,一般使用数据库默认的隔离级别ReadCommitted,即只能查看已经提交的事务的数据。
锁一般可以分为:共享锁,独占锁。
按记录分又分为:表锁,行锁
我们在select时即取的是表的共享锁,那么独占锁,使用select...forupdate实现
如果一个事务取得了独占锁,那么其他事务必须等待,等待那个事务提交后释放独占锁才能继续执行。
我们常见的锁解决方案如乐观锁:解决多个事务修改相同资源造成的不可重复读和第二类更新丢失。如hibernate的version或timestamp
那么如果在如下场景,比如有golf场地,每个预订可以选择一个时间段,那么场地的可用要受时间的影响,在每次预订前,都要检查在该时间段是否有可用场地。在多线程情况下,控制这样并发insert乐观锁是做不到的,只能使用悲观锁,控制事务的并发。
如何使用悲观锁呢?
可以使用hibernate的Session的Objectload(ClasstheClass,Serializableid,LockOptionslockOptions);方法,新建一个T_LOCKS表,用来实现悲观锁,
XXXServiceImpl.java
lockDao.getLock(); //一系列dao操作 .......
hibernate的Query和Criteria都支持锁:
Criteria criteria = session.createCriteria(TLock.class); criteria.add(Restrictions.eq("lockName", "facilitylock")); criteria.setLockMode(LockMode.UPGRADE); criteria.uniqueResult() ; Query query = session.createQuery("from TLock where lockName= :lockName"); query.setParameter("lockName", "facilitylock"); query.setLockOptions(LockOptions.UPGRADE); query.uniqueResult();
注意:select...fromtableNameforupdate必须保证一定能查到记录,不然,不会有独占锁。因此,可以专门设计一张表t_locks用来存储各个需要使用独占锁的情况下去取对应的记录行的独占锁
个人感觉,数据库悲观锁类似于java的同步synchronized概念和作用,但在集群环境下java的synchronized不行,可以使用数据库悲观锁代替。
但是经使用发现mysql的并发处理性能在线程数到达100-200的时候明显降低,对于这种情况使用分布式锁,比如zookeeper是非常好的一个解决方案,zookeeper的应用场景之一就是分布式锁,而且性能经验证比mysql强很多。
分布式锁是同一进程内所有的线程共享的,所以分布式锁是用来控制集群环境中各节点的访问;
java的Synchronized是线程同步锁,只能允许一个进程的一个线程访问;
因此在分布是环境中,要控制同步,要加两个锁:一个是分布式锁,一个是线程锁(java的Synchronize方法就可以)。
Curator是zoookeeper客户端框架,提供zookeeper的各种应用场景的封装API.