kapok

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

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

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

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

// 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(); //由子類實現

//返回javax.ejb.EJBContext，注意這個EJBContext是
EJB規(guī)范要求提供給EJB的Context,與JBoss自己實現類EnterpriseContext沒有關系。

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

現在讓我們來看看EnterpriseContext的幾個子類：
首先類比一下幾個子類的成員變量：
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;
看來除了MDB沒有對應的EJBObject/EJBLocalObject,其他統(tǒng)統(tǒng)都有：）
學過EJB的人都知道，在語法上EJB instance 是implements
EntityBean/SessionBean/MessageDrivenBean (這3個interface有一個共同的
interface: public interface EnterpriseBean extends Serializable,
EnterpriseBean 是個Marker接口,里頭什么都沒有，好像Serializable接口一樣，只說明
實現它的是個EJB.而EntityBean/SessionBean/MessageDrivenBean 有對應的
void ejbActivate() throws EJBException, RemoteException;
void ejbLoad() throws EJBException, RemoteException;
一些方法需要實現。（雖然常常是空實現：），由容器作了很多事)
至于EJBObject/EJBLocalObject 在語法上都是非直接實現的，代表EJB instance暴露出的Remote/Local 接口。既然這些EJB instance非直接實現這些接口，那么這些接口如何與具體的EJB instance相關聯(lián)，我們講到Container類時就知道了。
----------------------------------------------------------------------------------


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

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

/**
* 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還有個free方法：
public void free(EnterpriseContext ctx) {
ctx.clear();//記得ctx只是清掉id,transaction等，返回pool,準備復用么？
//discard是在發(fā)生錯誤的時候，不希望擴大影響，于是discard掉，
//而對應get()的free方法只是把EnterpriseContext返還給pool.
}
----------------------------------------------------------------------------------

專門對于Stateful....Context有設置EJB instance的函數
/**
* 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
多了個implements Serializable,(其他都沒有),
這是為了支持Activation/Passviation,Passviation的時候
把EJB Instance寫到文件中。
在StatefulSessionEnterpriseContext中有這樣兩個方法
private void writeObject(ObjectOutputStream out)
throws IOException, ClassNotFoundException
{
// do nothing
}

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