下面我們將會(huì )深入一些Struts中的內容，看看如何以Plugin的方式將Hibernate與Struts（也可以說(shuō)是Web應用，由其是帶有Servlet的Web應用）完整的結合起來(lái)。
溫習往事
我們之前寫(xiě)了一個(gè)HibernateUitl的類(lèi)，專(zhuān)門(mén)用于Hibernate Session的維護，它的代碼如下：
package com.huangdong.demo.util;
import net.sf.hibernate.HibernateException;
import net.sf.hibernate.Session;
import net.sf.hibernate.SessionFactory;
import net.sf.hibernate.cfg.Configuration;
public class HibernateUtil {
private static final SessionFactory sessionFactory;
static {
try {
sessionFactory =
new Configuration().configure().buildSessionFactory();
} catch (HibernateException ex) {
throw new RuntimeException(
"Exception building SessionFactory: " + ex.getMessage(),
ex);
}
}
public static final ThreadLocal session = new ThreadLocal();
public static Session currentSession() throws HibernateException {
Session s = (Session) session.get();
// Open a new Session, if this Thread has none yet
if (s == null) {
s = sessionFactory.openSession();
session.set(s);
}
return s;
}
public static void closeSession() throws HibernateException {
Session s = (Session) session.get();
session.set(null);
if (s != null)
s.close();
}
}
下面我們對這段代碼中我們需要關(guān)注的內容進(jìn)行細致的說(shuō)明。首先，這個(gè)類(lèi)的目標有兩個(gè)：
單一實(shí)例：在系統中全局使用一個(gè)唯一的SessionFactory實(shí)例。主要的原因一是Factory只需要一個(gè)實(shí)例可以調用方法就可以；另一方面取得SessionFActory需要的時(shí)間太久，每次都實(shí)例化，會(huì )過(guò)分浪費系統CPU資源。
每個(gè)線(xiàn)和使用自身對應的數據庫連接session：這里是為每個(gè)線(xiàn)程建立了一個(gè)局部的變量來(lái)達到這個(gè)目的。
需要Plugin所做的事
單一實(shí)例的實(shí)線(xiàn)是依靠下面的代碼：
private static final SessionFactory sessionFactory;
static {
try {
sessionFactory =
new Configuration().configure().buildSessionFactory();
} catch (HibernateException ex) {
throw new RuntimeException(
"Exception building SessionFactory: " + ex.getMessage(),
ex);
}
}
一個(gè)局部靜態(tài)變量sessionFactory是整個(gè)application使用的唯一的一個(gè)實(shí)例，它在類(lèi)第一次調入內存時(shí)通過(guò)
sessionFactory = new Configuration().configure().buildSessionFactory();
將自己實(shí)例化。這個(gè)實(shí)例化的過(guò)程比較漫長(cháng)。很顯然，這個(gè)操作與通常我們使用Servlet時(shí)要在Servlet調入內存時(shí)初始化的init()方法所能做到的事很相似。在Struts中提供了Plugin這么一個(gè)機制來(lái)擴充Struts的基礎功能，其實(shí)Plugin的實(shí)現也是基于Servlet的init方法和destory方法的。
總結起來(lái)，就是在Web應用這個(gè)特殊的環(huán)境中，由其是Struts中（因為它使用的Servlet只是一個(gè)，或說(shuō)只是一個(gè)類(lèi)及該類(lèi)的子類(lèi)）我們完全可以利用Servlet的init/destory機制（也就是Plugin機制）來(lái)完成在Web應用啟動(dòng)時(shí)的SessionFactory初始化和Web應用停止時(shí)SessionFactory的清除工作。
但是同時(shí)也會(huì )發(fā)現，如果在Plugin中對SessionFactory進(jìn)行實(shí)例化后，無(wú)法將該實(shí)例傳輸給使用者，但是Web應用環(huán)境中也給我們可以使用以下解決辦法：
JNDI
Plugin的靜態(tài)方法/變量
ServletContext的Attribute
下面我們以使用JNDI為主說(shuō)明這些SessionFactory使用的模式。
Plugin To JNDI
通過(guò)JNDI完成SessionFactory的初始化的思路基本上是這樣的：
在一個(gè)Plugin的init方法中初始化SessionFactory的實(shí)例
初始化完成后將SessionFactory的實(shí)例bind到JNDI目錄樹(shù)的一個(gè)節點(diǎn)上
返回init方法
在所有要使用SessionFactory的地方通過(guò)JNDI lookup出sessionFactory的實(shí)例得到具體的session進(jìn)行數據庫操作
在Plugin的destory方法是unbind節點(diǎn)，并將SessionFactory的實(shí)例清除
以下是具體的代碼片段，首先我們看看Plugin中的相關(guān)代碼：
/*
* 創(chuàng )建日期 2003-12-26
*/
package com.huangdong.demo.plugin;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.servlet.ServletException;
import net.sf.hibernate.HibernateException;
import net.sf.hibernate.SessionFactory;
import net.sf.hibernate.cfg.Configuration;
import org.apache.struts.action.ActionServlet;
import org.apache.struts.action.PlugIn;
import org.apache.struts.config.ModuleConfig;
/**
* @author HD
*/
public class InitHibernate implements PlugIn {
private Context ctx;
private SessionFactory sessionFactory;
/*
* 插件銷(xiāo)毀方法
*/
public void destroy() {
if (ctx != null) {
try {
// unbind JNDI 節點(diǎn)
ctx.unbind("HibernateSessionFactory");
} catch (NamingException e) {
e.printStackTrace();
}
}
if (sessionFactory != null) {
try {
// 關(guān)閉sessionFactory
sessionFactory.close();
} catch (HibernateException e) {
e.printStackTrace();
}
sessionFactory = null;
}
}
/*
* 插件初始化方法
*/
public void init(ActionServlet servlet, ModuleConfig config)
throws ServletException {
try {
// 獲取SessionFactory的實(shí)例
sessionFactory =
new Configuration().configure().buildSessionFactory();
} catch (HibernateException ex) {
throw new RuntimeException(
"Exception building SessionFactory: " + ex.getMessage(),
ex);
}
try {
// 取得容器上下文
ctx = new InitialContext();
// 將sessionFactory bind到JND樹(shù)中
ctx.bind("HibernateSessionFactory", sessionFactory);
} catch (NamingException ex) {
throw new RuntimeException(
"Exception binding SessionFactory to JNDI: " + ex.getMessage(),
ex);
}
}
}
接下來(lái)我們改造一下原來(lái)的HibernateUitl類(lèi)，我們新建一個(gè)HibernateUtilPlus類(lèi)：
/*
* 創(chuàng )建日期 2003-12-28
*
*/
package com.huangdong.demo.util;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import net.sf.hibernate.HibernateException;
import net.sf.hibernate.Session;
import net.sf.hibernate.SessionFactory;
/**
* @author HD
*/
public class HibernateUtilPlus {
private static SessionFactory sessionFactory = null;
public static final ThreadLocal session = new ThreadLocal();
public static Session currentSession() throws HibernateException {
if (sessionFactory == null) {
// 如果sessionFactory實(shí)例為null則從JNDI中獲取
if (getSystemSessionFactory() == false) {
throw new HibernateException("Exception geting SessionFactory from JNDI ");
}
}
Session s = (Session) session.get();
// Open a new Session, if this Thread has none yet
if (s == null) {
s = sessionFactory.openSession();
session.set(s);
}
return s;
}
public static void closeSession() throws HibernateException {
Session s = (Session) session.get();
session.set(null);
if (s != null)
s.close();
}
private static boolean getSystemSessionFactory() {
try {
//從JNDI中取得SessionFactory的實(shí)例，如果出錯返回false
Context inttex = new InitialContext();
sessionFactory =
(SessionFactory) inttex.lookup("HibernateSessionFactory");
} catch (NamingException e) {
return false;
}
return true;
}
}
這里有一個(gè)getSystemSessionFactory方法專(zhuān)門(mén)從JNDI中獲取SessionFactory的實(shí)例。
我們還是使用之前的TestServlet來(lái)測試，改過(guò)之后的TestServlet類(lèi)如下：
/*
* 創(chuàng )建日期 2003-12-26
*
*/
package com.huangdong.demo.bean;
import java.util.Calendar;
import net.sf.hibernate.HibernateException;
import net.sf.hibernate.Session;
import net.sf.hibernate.Transaction;
import com.huangdong.demo.dao.SysUser;
import com.huangdong.demo.util.HibernateUtilPlus;
/**
* @author HD
*/
public class TestHibernate {
public TestHibernate() {
}
public boolean TestAdd() {
try {
Session session = HibernateUtilPlus.currentSession();
Transaction tx = session.beginTransaction();
SysUser user = new SysUser();
user.setUsername("丫丫2");
user.setUserpasword("uhkuhkqepdwqi");
user.setLastlogin(Calendar.getInstance());
session.save(user);
tx.commit();
HibernateUtilPlus.closeSession();
} catch (HibernateException e) {
e.printStackTrace();
return false;
}
return true;
}
}
這里使用HibernateUtilPlus類(lèi)來(lái)獲取session。
最后我們需要將寫(xiě)好的Plugin配置到Struts中去，以讓?xiě)梅?wù)器啟動(dòng)時(shí)識別到這個(gè)Plugin的存在以初始化相關(guān)的內容。在WEB-INF文件夾下有一個(gè)名為struts-config.xml的配置文件，在其中加入Plugin的配置：
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE struts-config PUBLIC "-//Apache Software Foundation//DTD Struts Configuration 1.1//EN" "‘ target=_blank>http://jakarta.apache.org/struts/dtds/struts-config_1_1.dtd">
<struts-config>
<data-sources />
<form-beans >
</form-beans>
<global-exceptions />
<global-forwards />
<action-mappings >
</action-mappings>
<controller />
<message-resources parameter="com.huangdong.demo.ApplicationResources" />
<!--加入Plugin的配置，使用plug-in元素進(jìn)行說(shuō)明-->
<plug-in className="com.huangdong.demo.plugin.InitHibernate" />
</struts-config>
再次運行Tomcat，進(jìn)行測試?？梢栽谶@里下載通過(guò)JNDI Plugin的Eclipse示例。
另兩種方法的探索
在文章的最開(kāi)始，我們提到了三種方法，除了上面仔細提到的還有另外兩種：
Plugin的靜態(tài)方法/變量
ServletContext的Attribute
這里我們簡(jiǎn)單說(shuō)明這兩種方法實(shí)現的原理，就不實(shí)際的完成具體代碼了。具體的代碼與測試還請讀者自己完成。
Plugin的靜態(tài)方法和變量
使用這種方法與使用原有的HibernateUtil類(lèi)的原理類(lèi)似，但是可以將SessionFaction的實(shí)例化放在init方法中。如下：
/*
* 創(chuàng )建日期 2003-12-26
*/
package com.huangdong.demo.plugin;
import javax.servlet.ServletException;
import net.sf.hibernate.HibernateException;
import net.sf.hibernate.SessionFactory;
import net.sf.hibernate.cfg.Configuration;
import org.apache.struts.action.ActionServlet;
import org.apache.struts.action.PlugIn;
import org.apache.struts.config.ModuleConfig;
/**
* @author HD
*/
public class InitHibernate implements PlugIn {
public static final SessionFactory sessionFactory;
/*
* 插件銷(xiāo)毀方法
*/
public void destroy() {
sessionFactory = null;
}
}
/*
* 插件初始化方法
*/
public void init(ActionServlet servlet, ModuleConfig config)
throws ServletException {
try {
// 獲取SessionFactory的實(shí)例
sessionFactory =
new Configuration().configure().buildSessionFactory();
} catch (HibernateException ex) {
throw new RuntimeException(
"Exception building SessionFactory: " + ex.getMessage(),
ex);
}
}
}
這段plugin代碼很簡(jiǎn)單，在使用時(shí)也就直接使用這個(gè)Plugin的public變量來(lái)取得sessionFactroy實(shí)例了。
ServletContext的Attribute
這個(gè)方法的原理基于對Servlet的使用，在Struts中的使用會(huì )麻煩。它的原理是這樣的：
首先在plugin中初始化好sessionFactory實(shí)例，使用這兩句話(huà)將其放入servlet的context中：
ServletContext context = servlet.getServletContext();
context.setAttribute("SESSIONFACTORY", sessionFactory);
使用的方法很簡(jiǎn)單了，就是擴展一個(gè)自定義的ActionServlet，在提交具體的Action前，將SessionFactory提取出來(lái)，放入調用Action的execute方法的參數request的屬性中。代碼如下：
ServletContext context = servlet.getServletContext();
context.getAttribute("SESSIONFACTORY", sessionFactory);
request.setAttribute("SESSIONFACTORY", sessionFactory);
這樣在具體的execute方法里可以通過(guò)：
request.getAttribute("SESSIONFACTORY", sessionFactory);
來(lái)取到正確的SessionFactory。
這里的實(shí)現方法都是原理性的，具體還需要大家仔細了解Struts的實(shí)現方法來(lái)總結出自己最為習慣的使用策略。
留在最后話(huà)
本文中的所有代碼在以下環(huán)境中由作者實(shí)際測試完全沒(méi)有問(wèn)題：
Eclipse 2.1.2
Struts 1.1
Hibernate 2.1.1
Tomcat 4.1.29/Jetty 4.2.15/Orion 2.0.2
com.tanghan.plugin_0.1.0.12.21
JDK 1.4.2_02 For Windows/FreeBSD 4.8/FreeBSD 4.9
FreeBSD 4.8/FreeBSD 4.9/Windows 2000/Windows XP
Oracle 9.2.0.1.0
聯(lián)系客服
