kapok

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

JBoss是一个非常优秀的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间共享，避免频繁创建销毁对象的开销。
让我们来看看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联系起来。
该类签名为：
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，我们下节再说.

// 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规范要求提供给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里取出来的时候没有关联任何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();
}
//从关联的container拿出对应的metadata,判断是否CMT.
//注意这里con是Container成员变量，可不是什么连接，连接一般缩写为conn,
//我一开始就搞混了:)
//BeanMetaData这些MetaData的子类都是从xml配置里头读出来的Metadata构造的,
//没什么神秘的.
这个类里头还有两个inner class,EJBContextImpl implements EJBContext,
UserTransactionImpl implements UserTransaction。EJBContextImpl等
讲解过Container再说，UserTransaction等下节再说。

现在让我们来看看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,其他统统都有：）
学过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相关联，我们讲到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是在发生错误的时候，不希望扩大影响，于是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本身不需要
写出什么状态，只有对应的EJB instance才需要写出状态。