正文

[转]OpenSessionInView模式

IP云
IP云V管理员/2 阅读
11/30
提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示
OpenSessionInView模式解决的问题：
* hibernate事物边界问题

* 因session关闭导致hibernate延迟加载例外的问题

事物边界：

一个事物的完成应该是在业务层完成的，但是事物的创建却是在数据层来做，这样必定造成业务层和数据层耦合性增强。

延迟加载例外：


如你所知，延迟加载使用了动态代理机制，只有在真正使用这个对象的时候才会去访问数据库，但是如果在数据层进行了事物提交，session关闭，再去访问
数据就会导致延迟加载例外异常，所以我们必须加大session的生命周期，在访问数据之后关闭session。

因此我们可以通过OpenSessionInView模式来解决上面的问题

OpenSessionInView模式需要用到一个非常重要的一个类：ThreadLocal

OpenSessionInView模式：

* 需要构建一个过滤器，把事物的创建及提交放在过滤器里进行。

* 加大session的有效范围，把session放在当前线程里（ThreadLocal），使session在当前线程内有效，并且在当前线程内访问的是同一个session。

OpenSessionInView模式缺点：

*并发性减弱

*内存消耗加大

1.实体类：

  1. package com.yx.zzg.pojo;
  2. import java.util.Date;
  3. public class User {
  4. private String id;
  5. private String username;
  6. private String password;
  7. private Date createTime;
  8. private Date endTime;
  9. public String getId() {
  10. return id;
  11. }
  12. public void setId(String id) {
  13. this.id = id;
  14. }
  15. public String getUsername() {
  16. return username;
  17. }
  18. public void setUsername(String username) {
  19. this.username = username;
  20. }
  21. public String getPassword() {
  22. return password;
  23. }
  24. public void setPassword(String password) {
  25. this.password = password;
  26. }
  27. public Date getCreateTime() {
  28. return createTime;
  29. }
  30. public void setCreateTime(Date createTime) {
  31. this.createTime = createTime;
  32. }
  33. public Date getEndTime() {
  34. return endTime;
  35. }
  36. public void setEndTime(Date endTime) {
  37. this.endTime = endTime;
  38. }
  39. }

2.映射文件：

  1. <?xml version="1.0"?>
  2. <!DOCTYPE hibernate-mapping PUBLIC
  3. "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
  4. "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
  5. <hibernate-mapping package="com.yx.zzg.pojo">
  6. <class name="User" table="t_user">
  7. <id name="id">
  8. <!-- 指定主键生成策略 -->
  9. <generator class="uuid" />
  10. </id>
  11. <property name="username" unique-key="true" />
  12. <property name="password" />
  13. <property name="createTime" />
  14. <property name="endTime" />
  15. </class>
  16. </hibernate-mapping>

3.提供一个过滤器：

  1. package com.yx.zzg.servelt;
  2. import java.io.IOException;
  3. import javax.servlet.Filter;
  4. import javax.servlet.FilterChain;
  5. import javax.servlet.FilterConfig;
  6. import javax.servlet.ServletException;
  7. import javax.servlet.ServletRequest;
  8. import javax.servlet.ServletResponse;
  9. import org.hibernate.Session;
  10. import org.hibernate.Transaction;
  11. import com.yx.zzg.util.HibernateUtil;
  12. public class OpenSessionInView implements Filter {
  13. public void destroy() {
  14. }
  15. public void doFilter(ServletRequest request, ServletResponse response,
  16. FilterChain filter) throws IOException, ServletException {
  17. Transaction tx = null;
  18. Session session = null;
  19. try {
  20. session = HibernateUtil.getThreadLocalSession();
  21. tx = session.beginTransaction();
  22. filter.doFilter(request, response);
  23. tx.commit();
  24. } catch (Exception e) {
  25. if (tx != null) {
  26. tx.rollback();
  27. throw new RuntimeException(e.getMessage(),e);
  28. }
  29. } finally {
  30. HibernateUtil.colseSession();
  31. }
  32. }
  33. public void init(FilterConfig arg0) throws ServletException {
  34. }
  35. }

4.web.xml中配置过滤器

  1. <filter>
  2. <filter-name>OpenSessionInView</filter-name>
  3. <filter-class>com.yx.zzg.servelt.OpenSessionInView</filter-class>
  4. </filter>
  5. <filter-mapping>
  6. <filter-name>OpenSessionInView</filter-name>
  7. <url-pattern>/*</url-pattern>
  8. </filter-mapping>

5.HibernateUtil类：

  1. package com.yx.zzg.util;
  2. import org.hibernate.Session;
  3. import org.hibernate.SessionFactory;
  4. import org.hibernate.cfg.Configuration;
  5. public class HibernateUtil {
  6. private static SessionFactory sessionFactory;
  7. //创建一个ThreadLocal对象
  8. private static ThreadLocal threadSession = new ThreadLocal();
  9. private HibernateUtil() {
  10. }
  11. static {
  12. Configuration cfg = new Configuration().configure();
  13. sessionFactory = cfg.buildSessionFactory();
  14. }
  15. /**
  16. * 从当前线程中获取session，如果没有，则得到session，并将此session放入当前线程中
  17. * @return
  18. */
  19. public static Session getThreadLocalSession() {
  20. Session session = (Session) threadSession.get();
  21. if (session == null) {
  22. session = getSession();
  23. threadSession.set(session);
  24. }
  25. return session;
  26. }
  27. /**
  28. * 关闭session，并将当前线程中的session设置为null
  29. */
  30. public static void colseSession() {
  31. Session session = (Session) threadSession.get();
  32. if (session != null) {
  33. session.close();
  34. threadSession.set(null);
  35. }
  36. }
  37. public static Session getSession() {
  38. return sessionFactory.openSession();
  39. }
  40. }

6.数据层方法：

  1. public User findUserById(String id) {
  2. User user = (User) HibernateUtil.getThreadLocalSession().load(
  3. User.class, id);
  4. return user;
  5. }

相关阅读

目录[+]