hiberante入门（十五）：事务相关-悲观乐观锁

cfeers

浏览: 140292 次
性别:
来自: 杭州

最近访客更多访客>>

hezhenhuam

xiajingcheng

dj2437

今宵多珍重

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

Hibernate

Hibernate 配置管理 MVC JDBC Oracle

1.事务引发的三层架构MVC讨论：
在前面的程序代码中多次用到了事务：
Transaction tx = s.beginTransaction();
对应的jdbc代码：connection. setAutoCommit(false);

.....

.....数据处理
.....
tx.commit();
对应的jdbc代码：connection.commit();

tx.rollback();

对应的jdbc代码：connection.rollback();

以上的三处事务相关的代码统称为“事务边界”。其实hibernate的事务本质是依赖jdbc的事务来实现，其实对于事务而言，它是应该由业务逻辑层来实现，但是事务所依赖的对象又出现在Model层，所以想严格按照MVC的原理来实现将相当难（在前面我们所写的代码中事务的处理是不符合mvc模式得），但是利用推出的EJB,SPRING这些框架将能达到此目的，下图展示了三层架构，与原始的MVC相比，多了一个持久层。

持外层

2.模拟session context:

>>步骤一，重写工具类，核心代码如下：

Java代码

package com.asm.hibernate.utils;
public class HibernateUtilOSV {
private static SessionFactory sf;
private static ThreadLocal session = new ThreadLocal();
private HibernateUtilOSV() {
}
public static Session getThreadLocalSession() {
Session s = (Session) session.get();
if (s == null) {
s = getSession();
session.set(s);
}
return s;
}
public static void closeSession() {
Session s = (Session) session.get();
if (s != null) {
s.close();
session.set(null);
}
}
static {
Configuration cf = new Configuration();
cf.configure();
sf = cf.buildSessionFactory();
}
public static SessionFactory getSessionFactory() {
return sf;
}
public static Session getSession() {
return sf.openSession();
}
}

package com.asm.hibernate.utils;
public class HibernateUtilOSV {
	private static SessionFactory sf;
	private static ThreadLocal session = new ThreadLocal();
	private HibernateUtilOSV() {
	}
	public static Session getThreadLocalSession() {
		Session s = (Session) session.get();
		if (s == null) {
			s = getSession();
			session.set(s);
		}
		return s;
	}
	public static void closeSession() {
		Session s = (Session) session.get();
		if (s != null) {
			s.close();
			session.set(null);
		}
	}
	static {
		Configuration cf = new Configuration();
		cf.configure();
		sf = cf.buildSessionFactory();
	}
	public static SessionFactory getSessionFactory() {
		return sf;
	}
	public static Session getSession() {
		return sf.openSession();
	}
}

>>步骤二、导入servlet包，使用Filter. 内容如下：

Java代码

package com.asm.hibernate.osv;
public class OpenSessionViewFilter implements Filter {
public void destroy() {
// TODO Auto-generated method stub
}
public void doFilter(ServletRequest arg0, ServletResponse arg1,
FilterChain arg2) throws IOException, ServletException {
Session s = null;
Transaction tx = null;
try {
s = HibernateUtilOSV.getThreadLocalSession();
tx = s.beginTransaction();
arg2.doFilter(arg0, arg1);
tx.commit();
} catch (Exception e) {
if (tx != null)
tx.rollback();
} finally {
HibernateUtilOSV.closeSession();
}
}
public void init(FilterConfig arg0) throws ServletException {
// TODO Auto-generated method stub
}
}

package com.asm.hibernate.osv;
public class OpenSessionViewFilter implements Filter {
	public void destroy() {
		// TODO Auto-generated method stub
	}
	public void doFilter(ServletRequest arg0, ServletResponse arg1,
			FilterChain arg2) throws IOException, ServletException {
		Session s = null;
		Transaction tx = null;
		try {
			s = HibernateUtilOSV.getThreadLocalSession();
			tx = s.beginTransaction();

			arg2.doFilter(arg0, arg1);
			tx.commit();
		} catch (Exception e) {
			if (tx != null)
				tx.rollback();
		} finally {
			HibernateUtilOSV.closeSession();
		}
	}
	public void init(FilterConfig arg0) throws ServletException {
		// TODO Auto-generated method stub
	}
}

>>步骤三、Userdao：

Java代码

package com.asm.hibernate.osv;
public class UserDao {
static void addUseDao(User user) {
HibernateUtilOSV.getThreadLocalSession().save(user);
}
}

package com.asm.hibernate.osv;
public class UserDao {
	static void addUseDao(User user) {
		HibernateUtilOSV.getThreadLocalSession().save(user);
	}
}

原理流程分析：当有被Filter监测的请求到达此Filter时，Filter会利用工具类来获得一个Session,并用这个session打开事务，然后再把请求传给下一个Filter.当所有操作执行完成后再返回到这个Filter,如果没有任何异常便可以提交事务，否则回滚事务。这样便可以有效保证事务的完整性，而且有利于懒加载，因为在整个请求的过程中，Session一直未关闭，所以在filter不断向下传递的过程中可以放心的使用session来完成懒加载，这也是解决懒加载的一种方式。其实OpenSessionInView主要解决了两个问题：一是实现事务在逻辑层控制，二是利于懒加载的实现。下面再来看看工具类：此工具类主要完成了两个工作：一是生成一个线程级的Session,即是说在一个线程的事务开启到事务结束，一直用的是同一个Session,这样有利于保证事务的完整性，而工具类主要借助了ThradLocal来生成这个线程级的Session。二是完成Session的关闭。

3.使用Hibernate自带的SessionContext

>>步骤一、在主配置文件中增加如下内容：

<property name="current_session_context_class">thread</property>以支持事务边界。说明：它实质也是利用ThreadLocal来管理Session实现多个操作共享一个Session,避免反复获取Session,并控制事务边界。需要注意的是，当我们打开此功能后再通过SessionFactory.getCurrentSession()来获取一个Session，这个Session不能调用close方法，因为当我们提交事务或者回滚事务都会引起这个Session关闭，而通常的事务最会被提交或回滚，所以我们永远不要在这样的Session中调用close方法。同样的它的一个重要作用就是在生成页面时保持Session打开（即OpenSessionInView），因此为懒加载提供了方便。除了配置为thread外还可以配置值为“jta” ，配置成jta后主要JTA事务管理器来管理事务，jta事务管理器主要用在有多个数据库的情况

>>步骤二、重写工具类：核心代码如下：

Java代码

package com.asm.hibernate.utils;
public class HibernateUtilSelf {
private static SessionFactory sf;
private HibernateUtilSelf() {
}
public static Session getThreadLocalSession() {
Session s = sf.getCurrentSession();
if (s == null) {
s = getSession();
}
return s;
}
static {
Configuration cf = new Configuration();
cf.configure();
sf = cf.buildSessionFactory();
}
public static SessionFactory getSessionFactory() {
return sf;
}
public static Session getSession() {
return sf.openSession();
}
}

package com.asm.hibernate.utils;
public class HibernateUtilSelf {
	private static SessionFactory sf;
	private HibernateUtilSelf() {
	}
	public static Session getThreadLocalSession() {
		Session s = sf.getCurrentSession();
		if (s == null) {
			s = getSession();
		}
		return s;
	}
	static {
		Configuration cf = new Configuration();
		cf.configure();
		sf = cf.buildSessionFactory();
	}
	public static SessionFactory getSessionFactory() {
		return sf;
	}
	public static Session getSession() {
		return sf.openSession();
	}	
}

>>编写测试类：

Java代码

package com.asm.hibernate.osv;
public class UserTest {
public static void main(String[] args) {
User user = new User();
user.setName("richie");
user.setDate(new Date());
addUser(user);
}
static void addUser(User user) {
Session s = null;
Transaction ts = null;
try {
s = HibernateUtilSelf.getThreadLocalSession();
ts = s.beginTransaction();
s.save(user);
ts.commit();
} catch (HibernateException e) {
if (ts != null)
ts.rollback();
throw e;
} finally {
if (s != null)
// s.close(); //注意这里不能使用close,并注意下面的打印结果
System.out.println("s=" + s);
}
}
}

package com.asm.hibernate.osv;
public class UserTest {
	public static void main(String[] args) {
		User user = new User();
		user.setName("richie");
		user.setDate(new Date());
		addUser(user);
	}
	static void addUser(User user) {
		Session s = null;
		Transaction ts = null;
		try {
			s = HibernateUtilSelf.getThreadLocalSession();
			ts = s.beginTransaction();
			s.save(user);
			ts.commit();
		} catch (HibernateException e) {
			if (ts != null)
				ts.rollback();
			throw e;
		} finally {
			if (s != null)
				// s.close(); //注意这里不能使用close,并注意下面的打印结果
				System.out.println("s=" + s);
		}
	}
}

执行后的结果为：s=SessionImpl(<closed>)

4.悲观锁：

悲观地认为每个事务在操纵数据时，肯定会有其它的事务同时访问该数据资源，当前事务为防止自身受到影响，先将相关数据资源锁定，直到事务结束后释放锁定。

实现方式一：利用LockMode实现数据锁；原理是使用带有LockMode参数的load方法来实现数据加锁，LockMode主要有以下几种锁定方式：

锁定方式	功能
LockMode.NONE	Hibernate的默认值，首先到缓存中检索，检测不到时连数据库
LockMode.READ	不管缓存，直接到数据库中加载。如果在实体配置文件中配置了版本元素，则比较缓存中的版本与数据库中的版本是否一致
LockMode.UPGRADE	在READ的基础上，如果数据库支持悲观锁，则执行select...for update,否则执行变通的select语句。
UPGRADE_NOWAIT	主要是针对Oracle数据库，在UPGRADE的基础上，如果执行select语句不能获得锁，则会抛出锁定异常

实现方式二、通过逻辑实现锁定数据；原理是在实体类的数据库表中设定一个boolean的字段，当这个字段为true,表示该数据正在被访问，此时记录被锁定。如果为false,则表示可以访问。过程：(1)当访问的数据为false时，表示可以访问，此时修改字段为true,以避免其它对象访问,操作完成后再设此字段为false,以让等待的对象访问 (2)当访问数据据为true，表示不可被访问。

5.乐观锁：

乐观地认为每个事务在操纵数据时，很少有或者不会其它事务同时访问数据资源，因而不会在数据库层锁定，而是通过逻辑来实现版本控制。

实现方式一：<version>方式：为了方便操作新建一个名为OptimizeLock的项目.

>>步骤一，拷贝以前的User类及相应的实体配置文件等相关文件。
>>步骤二，在User类中增加private int version;及相应的get/set方法。Version名字可以随意取。

>>步骤三、修改配置文件：增加<version name="version"></version>属性，并注意在<class>元素中使用optimistic-lock="version"属性，这也是官方推荐使用的属性值。但不能使用none，因为它不支持乐观锁，也可这样说，即使我们为乐观锁做好了一切准备，但我们不想在某个实体对象中使用时，只需要配置optimistic-lock为none即可。
>>步骤四、编写测试类

Java代码

package com.asm.hibernate.test;
public class VersionUserTest {
public static void main(String[] args) {
addUser();
update(1);
}
static void update(int id) {
Session s1 = null;
Session s2 = null;
Transaction tx1 = null;
Transaction tx2 = null;
try {
s1 = HibernateUtil.getSession();
tx1 = s1.beginTransaction();
User user1 = (User) s1.get(User.class, id);
System.out.println(user1.getName());
s2 = HibernateUtil.getSession();
tx2 = s2.beginTransaction();
User user2 = (User) s2.get(User.class, id);
user1.setName("user1Name");
user2.setName("user2Name");
tx1.commit();
tx2.commit();
} catch (HibernateException e) {
....
} finally {
....
}
}
static void addUser() {
...主要作用是增加一条记录以实现操作。
}
}

package com.asm.hibernate.test;

public class VersionUserTest {

    public static void main(String[] args) {

       addUser();

       update(1);

    }

    static void update(int id) {

       Session s1 = null;

       Session s2 = null;

       Transaction tx1 = null;

       Transaction tx2 = null;

       try {

           s1 = HibernateUtil.getSession();

           tx1 = s1.beginTransaction();

           User user1 = (User) s1.get(User.class, id);

           System.out.println(user1.getName());

           s2 = HibernateUtil.getSession();

           tx2 = s2.beginTransaction();

           User user2 = (User) s2.get(User.class, id);



           user1.setName("user1Name");

           user2.setName("user2Name");

 

           tx1.commit();

           tx2.commit();

       } catch (HibernateException e) {

           ....

       } finally {

           ....

       }

    }

    static void addUser() {

       ...主要作用是增加一条记录以实现操作。

    }

}

分析：在进行分析前，先提下笔者曾范的一个测试错误，由于是复制以前的代码，由于以前在User的配置文件中配置了二级缓存的“<cache usage="read-only"/>” ，这样执行时总是报“Can't write to a readonly object” 。由这点大家可以再细想下悲观锁的更多细节问题。下面来谈version,当我们向数据表中添加一个version字段，hibernate会控制此字段，当访问一条记录时，同时访问此记录的版本信息，如果对该记录做了修改，在提交事务时，hibernate会将访问时的版本信息与数据库中的版本信息进行对比，如果一致则提交修改并将原版本信息加1，否则撤销本次修改。上面的两个session并分别有开启了两个事务，当提交第一个事务时，符合要求进行了提交。但我们再来提交第二个事务时，由于第一个事务修改了版本信息，尽管user1和user2最初获得的版本是一样得，但由于第一个事务提交修改了数据库中版本信息，所以第二个事务将不能被提交（如不能明白，请仔细阅读本段中的黑体字部份）。请这样测试：执行完后(会报“Transaction not successfully started”异常)查数据表，然后再交换以上两个事务提交的顺序再执行，再查数据表。另请不要深究异常处理。

实现方式二、<timestamp>

基本和方式一相同，只是在User类中增加一个Date类型的属性，同时在实体配置文件配置如下内容: <timestamp name="实体类的中Date类型的属性"></timestamp>

分享到：

hiberante入门（十六）：一些细节理论 | hiberante入门（十四）：缓存2

2010-08-26 11:25
浏览 1163
评论(0)
分类:企业架构
查看更多

发表评论

您还没有登录,请您登录后再发表评论

最近访客更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论