kapok

http://blog.csdn.net/stripbolt/archive/2004/10/24/149705.aspx

JBoss是一個(gè)非常優(yōu)秀的J2EE的Application Server,研究
它的源代碼有助于我們更好的理解J2EE的各種技術(shù)。
本系列擬從四個(gè)方面分析Jboss源碼：
1.EJB Container實(shí)現(xiàn)
2.Transaction實(shí)現(xiàn)
3.Persistence Mapping
4.Client到Server端的Invocation

-------------------------------------------------------------------
先說(shuō)第1點(diǎn):EJB Container實(shí)現(xiàn)。
1.1 EJB Pool
我們知道，EJB Container 會(huì)維護(hù)一個(gè)EJB池，
在多個(gè)client間共享，避免頻繁創(chuàng)建銷毀對(duì)象的開銷。
讓我們來(lái)看看Jboss實(shí)現(xiàn)的Pool:
EJB分EntityBean,MDB,Stateless/Stateful Session Bean,
而Jboss中也對(duì)應(yīng)的有EntityInstancePool，MessageDrivenInstancePool,
StatefulSessionInstancePool,StatelessSessionInstancePool.
讓我們先從這4個(gè)類的共同基類AbstractInstancePool看起：
class AbstractInstancePool實(shí)現(xiàn)了接口InstancePool，該接口有以下幾個(gè)方法：
EnterpriseContext get() throws Exception;
void free(EnterpriseContext ctx);
void discard(EnterpriseContext ctx);
int getCurrentSize();
public int getMaxSize();
--------------------------------------------------------------------
先對(duì)EnterpriseContext作番說(shuō)明。EnterpriseContext的作用
就是把具體的EJB instance和它的metadata聯(lián)系起來(lái)。
該類簽名為：
public abstract class EnterpriseContext，
有4個(gè)子類，EntityEnterpriseContext，MessageDrivenEnterpriseContext，
StatefulSessionEnterpriseContext，StatelessSessionEnterpriseContext。
分別對(duì)應(yīng)4種類型的EJB。
EnterpriseContext中有幾個(gè)重要的成員變量。
/** The EJB instance */
Object instance;
/** The container using this context */
Container con; //Container這個(gè)類是JBoss用來(lái)代表對(duì)EJB提供Transaction,Security，Pool等服務(wù)的類，我們回頭還會(huì)再說(shuō)。
/** Only StatelessSession beans have no Id, stateful and entity do */
Object id;

/** The transaction associated with the instance */
Transaction transaction; //Transaction，我們下節(jié)再說(shuō).

// Constructors --------------------------------------------------

public EnterpriseContext(Object instance, Container con)
{
this.instance = instance;
this.con = con;
}

public Object getInstance()
{
return instance;
}
public Container getContainer() {
return con;
}

public void setId(Object id) {
this.id = id;
}

public Object getId() {
return id;
}

public void setTransaction(Transaction transaction) {
this.transaction = transaction;
}

public Transaction getTransaction() {
return transaction;
}

/**
* Get the EJBContext object
*/
public abstract EJBContext getEJBContext(); //由子類實(shí)現(xiàn)

//返回javax.ejb.EJBContext，注意這個(gè)EJBContext是
EJB規(guī)范要求提供給EJB的Context,與JBoss自己實(shí)現(xiàn)類EnterpriseContext沒(méi)有關(guān)系。

/** The instance is being used. This locks it\'s state */
int locked = 0;
public void lock()
{
locked ++;
}

public void unlock() {
locked --;
}

public boolean isLocked() {
return locked != 0;
}
//lock這個(gè)成員變量表示當(dāng)前這個(gè)EJB instance有沒(méi)人在用。
//這個(gè)變量用來(lái)給Reentrance,以及canPassviate用.
/**
* before reusing this context we clear it of previous state called
* by pool.free()
* 從pool里取出來(lái)的時(shí)候沒(méi)有關(guān)聯(lián)任何EJB instance和Transaction信息
* 在返還pool的時(shí)候把這些信息清掉。
*/
public void clear() {
this.id = null;
this.locked = 0;
this.transaction = null;
}
//-------------------------------------------------------------------------------------
protected boolean isContainerManagedTx()
{
BeanMetaData md = (BeanMetaData)con.getBeanMetaData();
return md.isContainerManagedTx();
}
//從關(guān)聯(lián)的container拿出對(duì)應(yīng)的metadata,判斷是否CMT.
//注意這里con是Container成員變量，可不是什么連接，連接一般縮寫為conn,
//我一開始就搞混了:)
//BeanMetaData這些MetaData的子類都是從xml配置里頭讀出來(lái)的Metadata構(gòu)造的,
//沒(méi)什么神秘的.
這個(gè)類里頭還有兩個(gè)inner class,EJBContextImpl implements EJBContext,
UserTransactionImpl implements UserTransaction。EJBContextImpl等
講解過(guò)Container再說(shuō)，UserTransaction等下節(jié)再說(shuō)。

現(xiàn)在讓我們來(lái)看看EnterpriseContext的幾個(gè)子類：
首先類比一下幾個(gè)子類的成員變量：
EntityEnterpriseContext：
private EJBObject ejbObject;
private EJBLocalObject ejbLocalObject;
private EntityContext ctx;

StatefulSessionEnterpriseContext
private EJBObject ejbObject;
private EJBLocalObject ejbLocalObject;
private SessionContext ctx;

StatelessSessionEnterpriseContext
EJBObject ejbObject;
EJBLocalObject ejbLocalObject;
SessionContext ctx;

MessageDrivenEnterpriseContext：
private MessageDrivenContext ctx;
看來(lái)除了MDB沒(méi)有對(duì)應(yīng)的EJBObject/EJBLocalObject,其他統(tǒng)統(tǒng)都有：）
學(xué)過(guò)EJB的人都知道，在語(yǔ)法上EJB instance 是implements
EntityBean/SessionBean/MessageDrivenBean (這3個(gè)interface有一個(gè)共同的
interface: public interface EnterpriseBean extends Serializable,
EnterpriseBean 是個(gè)Marker接口,里頭什么都沒(méi)有，好像Serializable接口一樣，只說(shuō)明
實(shí)現(xiàn)它的是個(gè)EJB.而EntityBean/SessionBean/MessageDrivenBean 有對(duì)應(yīng)的
void ejbActivate() throws EJBException, RemoteException;
void ejbLoad() throws EJBException, RemoteException;
一些方法需要實(shí)現(xiàn)。（雖然常常是空實(shí)現(xiàn)：），由容器作了很多事)
至于EJBObject/EJBLocalObject 在語(yǔ)法上都是非直接實(shí)現(xiàn)的，代表EJB instance暴露出的Remote/Local 接口。既然這些EJB instance非直接實(shí)現(xiàn)這些接口，那么這些接口如何與具體的EJB instance相關(guān)聯(lián)，我們講到Container類時(shí)就知道了。
----------------------------------------------------------------------------------


EnterpriseContext的子類EntityEnterpriseContext的構(gòu)造函數(shù)
public EntityEnterpriseContext(Object instance, Container con)
throws RemoteException
{
super(instance, con);
ctx = new EntityContextImpl(); //這是EJBContextImpl的子類，不急著說(shuō):)
((EntityBean)instance).setEntityContext(ctx);//看看，原來(lái)set...Context是在這里調(diào)用的//其它instance實(shí)現(xiàn)的什么ejbCreate(),EJBLoad,EJBActive()到底是什么時(shí)候
調(diào)用的呢？接下來(lái)我們慢慢找，這可散布在各地呢：）
}
//其他幾個(gè)子類的構(gòu)造函數(shù)前3行也都如此，是類似的。
對(duì)于StatelessSessionEnterpriseContext和MessageDrivenEnterpriseContext,緊接的是

Method ejbCreate = instance.getClass().getMethod(\"ejbCreate\", new Class[0]);
ejbCreate.invoke(instance, new Object[0]);
//看看，來(lái)了一個(gè)ejbCreate:),對(duì)于StatelessSessionBean，一上來(lái)就ejbCreate()了~
接下來(lái)看點(diǎn)簡(jiǎn)單的：對(duì)于EnterpriseContext,
有public abstract void discard() throws RemoteException;
對(duì)于MessageDriven...的
public void discard() throws RemoteException
{
((MessageDrivenBean)instance).ejbRemove();
}
對(duì)于StatelessSession的
public void discard() throws RemoteException
{
((SessionBean)instance).ejbRemove();
}
對(duì)于StatefulSession...的
public void discard() throws RemoteException
{
// Do nothing
}
對(duì)于Entity....
public void discard() throws RemoteException
{
((EntityBean)instance).unsetEntityContext();
}
//discard 是在AbstractInstancePool中的
void discard(EnterpriseContext ctx);調(diào)用的

/**
* Discard an anonymous instance after invocation.
* This is called if the instance should not be reused, perhaps due to some
* exception being thrown from it.
*
* @param ctx The context to discard.
*/
public void discard(EnterpriseContext ctx)
{
ctx.discard();
}
AbstractInstancePool還有個(gè)free方法：
public void free(EnterpriseContext ctx) {
ctx.clear();//記得ctx只是清掉id,transaction等，返回pool,準(zhǔn)備復(fù)用么？
//discard是在發(fā)生錯(cuò)誤的時(shí)候，不希望擴(kuò)大影響，于是discard掉，
//而對(duì)應(yīng)get()的free方法只是把EnterpriseContext返還給pool.
}
----------------------------------------------------------------------------------

專門對(duì)于Stateful....Context有設(shè)置EJB instance的函數(shù)
/**
* During activation of stateful session beans we replace the instance
* by the one read from the file.
*/
public void setInstance(Object instance)
{
this.instance = instance;
((SessionBean)instance).setSessionContext(ctx);
}
注意在4種...Context中，只有Stateful...Context簽名
public class StatefulSessionEnterpriseContext
extends EnterpriseContext
implements Serializable
多了個(gè)implements Serializable,(其他都沒(méi)有),
這是為了支持Activation/Passviation,Passviation的時(shí)候
把EJB Instance寫到文件中。
在StatefulSessionEnterpriseContext中有這樣兩個(gè)方法
private void writeObject(ObjectOutputStream out)
throws IOException, ClassNotFoundException
{
// do nothing
}

private void readObject(ObjectInputStream in)
throws IOException, ClassNotFoundException
{
// do nothing
}
//說(shuō)明序列化的時(shí)候StatefulSessionEnterpriseContext本身不需要
寫出什么狀態(tài)，只有對(duì)應(yīng)的EJB instance才需要寫出狀態(tài)。