EJB 调用原理及原因

ttsiangogole

浏览: 72161 次

最近访客更多访客>>

tianbrave

东方微微亮

muyuan

落叶换新叶

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

java
EJB 调用原理及原因

EJB 调用原理及原因 java 工作

这里就结合WebSphere来讲讲各个类的调用关系吧。
 
假定我们要创建一个读取User信息的SessionBean，需要我们写的有3个文件：
 
1. UserServiceHome.java
 
Home接口
 
2. UserService.java
 
Remote接口
 
3. UserServiceBean.java
 
Bean实现
 
WSAD最终会生成10个class。其它7个是什么呢？我们一个一个数过来：
 
4. _UserServiceHome_Stub.java
 
这个当然就是Home接口在Client端(动态加载)的Stub类了，它implements UserServiceHome。
 
5. _EJSRemoteStatelessUserServiceHome_a940aa04_Tie.java
 
Home接口在Server端的Skeleton类，"a940aa04"应该是随机生成的，所有其他的相关class名里都会有这个标志串，Tie是Corba对Skeleton的叫法。
 
6. EJSRemoteStatelessUserServiceHome_a940aa04.java
 
Home接口在Server端的实现，当然，它也implements UserServiceHome。
 
7. EJSStatelessUserServiceHomeBean_a940aa04.java
 
由#6调用，create _UserService_Stub。(为什么#6不能直接create _UserService_Stub呢？后面再讲。)
 
8. _UserService_Stub.java
 
Remote接口在Client端(动态加载)的Stub类。它implements UserService。
 
9. _EJSRemoteStatelessUserService_a940aa04_Tie.java
 
Remote接口在Server端的Skeleton类。
 
10. EJSRemoteStatelessUserService_a940aa04.java
 
Remote接口在Server端的实现，当然，它也implements UserService。并且，它负责调用UserServiceBean——也就是我们所写的Bean实现类——里面的business method。
 
那么，各个类之间的调用关系到底是怎么样的呢？简单的说，就是两次RMI循环。


?

先来看看Client端的程序是怎么写的：
 

<div class="dp-highlighter">
<div class="bar">
<div class="tools">Java代码 ?<a title="收藏这段代码"><img class="star" src="http://www.iteye.com/images/icon_star.png" alt="收藏代码"></a>

<ol class="dp-j">
<li>
try
?{??

</li>
<li>
????InitialContext?ctx?=?new
?InitialContext();;??

</li>
<li>
??
</li>
<li>
????//第一步
??

</li>
<li>
????UserServiceHome?home?=??
</li>
<li>
????????(UserServiceHome);?PortableRemoteObject.narrow(??
</li>
<li>
????????????ctx.lookup(JNDIString);,??
</li>
<li>
????????????UserServiceHome.class
);;??

</li>
<li>
??
</li>
<li>
????//home:?_UserServiceHome_Stub
??

</li>
<li>
????System.out.println(home.toString(););;??
</li>
<li>
??
</li>
<li>
????//第二步
??

</li>
<li>
????UserService?object?=?home.create();;??
</li>
<li>
??
</li>
<li>
????//ojbect:?_UserService_Stub
??

</li>
<li>
????System.out.println(object.toString(););;??
</li>
<li>
??
</li>
<li>
????//第三步
??

</li>
<li>
????int
?userId?=?
1
;??

</li>
<li>
????UserInfo?ui?=?object.getUserInfo(userId);;??
</li>
<li>
}??
</li>
</ol>

 
在第一步之后，我们得到了一个UserServiceHome(interface)定义的对象home，那么，home到底是哪个class的instance呢？用debug看一下，知道了home原来就是_UserServiceHome_Stub的实例。
 
从第二步开始，就是我们的关注所在，虽然只有简单的一行代码，
 
UserService object = home.create();
 
但是他背后的系统是怎么运做的呢？我们进入代码来看吧：
 
1. 调用home.create()

<div class="dp-highlighter">
<div class="bar">
<div class="tools">Java代码 ?<a title="收藏这段代码"><img class="star" src="http://www.iteye.com/images/icon_star.png" alt="收藏代码"></a>

<ol class="dp-j">
<li>
UserServiceHome?home;??

</li>
<li>
UserService?obj?=?home.create();;??
</li>
</ol>

 
2. 实际是调用_UserServiceHome_Stub.create()，在这个方法里面，Stub向Skeleton发送了一个create的字串：

<div class="dp-highlighter">
<div class="bar">
<div class="tools">Java代码 ?<a title="收藏这段代码"><img class="star" src="http://www.iteye.com/images/icon_star.png" alt="收藏代码"></a>

<ol class="dp-j">
<li>
org.omg.CORBA.portable.OutputStream?out?=?_request(
"create"
,?
true
);;??

</li>
<li>
in?=?(org.omg.CORBA_2_3.portable.InputStream);_invoke(out);;??
</li>
</ol>

 
3. Server端的Skeleton接收Stub发来的request，并调用相应的方法：

<div class="dp-highlighter">
<div class="bar">
<div class="tools">Java代码 ?<a title="收藏这段代码"><img class="star" src="http://www.iteye.com/images/icon_star.png" alt="收藏代码"></a>

<ol class="dp-j">
<li>
_EJSRemoteStatelessUserServiceHome_a940aa04_Tie._invoke();?{??

</li>
<li>
????......??
</li>
<li>
????switch
?(method.length(););?{??

</li>
<li>
????????case
?
6
:??

</li>
<li>
????????????if
?(method.equals(
"create"
););?{??

</li>
<li>
????????????????return
?create(in,?reply);;??

</li>
<li>
????????????}??
</li>
<li>
????????......??
</li>
<li>
????}??
</li>
<li>
}??
</li>
</ol>

 

<div class="dp-highlighter">
<div class="bar">
<div class="tools">Java代码 ?<a title="收藏这段代码"><img class="star" src="http://www.iteye.com/images/icon_star.png" alt="收藏代码"></a>

<ol class="dp-j">
<li>
_EJSRemoteStatelessUserServiceHome_a940aa04_Tie.create();?{??

</li>
<li>
????EJSRemoteStatelessUserServiceHome_a940aa04?target?=?null
;??

</li>
<li>
????result?=?target.create();;??
</li>
<li>
????org.omg.CORBA.portable.OutputStream?out?=?reply.createReply();;??
</li>
<li>
????Util.writeRemoteObject(out,result);;??
</li>
<li>
????return
?out;??

</li>
<li>
}??
</li>
</ol>

 
4. Skeleton调用的是UserServiceHome的Server端实现类的create方法

<div class="dp-highlighter">
<div class="bar">
<div class="tools">Java代码 ?<a title="收藏这段代码"><img class="star" src="http://www.iteye.com/images/icon_star.png" alt="收藏代码"></a>

<ol class="dp-j">
<li>
EJSRemoteStatelessUserServiceHome_a940aa04.create();?{??

</li>
<li>
????UserService?_EJS_result;??
</li>
<li>
????_EJS_result?=?EJSStatelessUserServiceHomeBean_a940aa04.create();;??
</li>
<li>
}??
</li>
</ol>

 
5. #4又调用EJSStatelessUserServiceHomeBean_a940aa04.create()

<div class="dp-highlighter">
<div class="bar">
<div class="tools">Java代码 ?<a title="收藏这段代码"><img class="star" src="http://www.iteye.com/images/icon_star.png" alt="收藏代码"></a>

<ol class="dp-j">
<li>
UserService?result?=?
super
.createWrapper(
new
?BeanId(
this
,?
null
););;??

</li>
</ol>

 
至此，我们终于结束了第一个RMI循环，并得到了Remote接口UserService的Stub类_UserService_Stub，就是#5里面的result。
 
这里有一个问题，为什么#4不直接create _UserService_Stub，而又转了一道#5的手呢？因为#4 extends
from EJSWrapper，它没有能力create Stub，因此必须借助#5，which extends from
EJSHome，这样才可以生成一个Stub。如果不是为了生成这个Stub，应该可以不走#5这一步。


?

OK, now we got the object which is instanceOf _UserService_Stub, and implements UserService
 
现在我们的Client端走到第三步了：
 
UserInfo ui = object.getUserInfo(userId);
 
继续看代码，开始第二个RMI循环：
 
1. 调用object.getUserInfo()

<div class="dp-highlighter">
<div class="bar">
<div class="tools">Java代码 ?<a title="收藏这段代码"><img class="star" src="http://www.iteye.com/images/icon_star.png" alt="收藏代码"></a>

<ol class="dp-j">
<li>
UserService?object;??

</li>
<li>
object.getUserInfo(userId);;??
</li>
</ol>

 
2. 实际是调用_UserService_Stub.getUserInfo(int arg0)，在这个方法里面，Stub向Skeleton发送了一个getUserInfo的字串和arg0这个参数：
 

<div class="dp-highlighter">
<div class="bar">
<div class="tools">Java代码 ?<a title="收藏这段代码"><img class="star" src="http://www.iteye.com/images/icon_star.png" alt="收藏代码"></a>

<ol class="dp-j">
<li>
org.omg.CORBA.portable.OutputStream?out?=?_request(
"getUserInfo"
,?
true
);;??

</li>
<li>
out.write_long(arg0);;??
</li>
<li>
in?=?(org.omg.CORBA_2_3.portable.InputStream);_invoke(out);;??
</li>
</ol>

 
3. Server端的Skeleton接收Stub发来的request，并调用相应的方法：

<div class="dp-highlighter">
<div class="bar">
<div class="tools">Java代码 ?<a title="收藏这段代码"><img class="star" src="http://www.iteye.com/images/icon_star.png" alt="收藏代码"></a>

<ol class="dp-j">
<li>
_EJSRemoteStatelessUserService_a940aa04_Tie._invoke();?{??

</li>
<li>
????switch
?(method.charAt(
5
););??

</li>
<li>
????{??
</li>
<li>
????????case
?
83
:??

</li>
<li>
????????????if
?(method.equals(
"getUserInfo"
););?{??

</li>
<li>
????????????????return
?getUserInfo(in,?reply);;??

</li>
<li>
????????????}??
</li>
<li>
????????......??
</li>
<li>
????}??
</li>
<li>
}??
</li>
<li>
??
</li>
<li>
_EJSRemoteStatelessUserService_a940aa04_Tie.getUserInfo();?{??
</li>
<li>
????EJSRemoteStatelessUserService_a940aa04?target?=?null
;??

</li>
<li>
????int
?arg0?=?in.read_long();;??

</li>
<li>
????UserDTO?result?=?target.getUserInfo(arg0);;??
</li>
<li>
????org.omg.CORBA_2_3.portable.OutputStream?out?=?reply.createReply();;??
</li>
<li>
????out.write_value(result,UserDTO.class
);;??

</li>
<li>
????return
?out;??

</li>
<li>
}??
</li>
</ol>

 
4. Skeleton调用的是UserService的Server端实现类的getUserInfo方法

<div class="dp-highlighter">
<div class="bar">
<div class="tools">Java代码 ?<a title="收藏这段代码"><img class="star" src="http://www.iteye.com/images/icon_star.png" alt="收藏代码"></a>

<ol class="dp-j">
<li>
EJSRemoteStatelessUserService_a940aa04.getUserInfo();?{??

</li>
<li>
????UserServiceBean?_EJS_beanRef?=?container.preInvoke(this
,?
0
,?_EJS_s);;??

</li>
<li>
????_EJS_result?=?_EJS_beanRef.getUserInfo(id);;??
</li>
<li>
}??
</li>
</ol>

 
最后的最后，#4终于调用了我们写的UserServiceBean里的getUserInfo方法，这才是我们真正想要去做的事情。
 
至此，第二个RMI循环也终于结束了。


?

回顾一下上面的分析，可以很清晰的看到两次RMI循环的过程，下图(见链接)描述了整个流程：
 http://www.pbase.com/image/27229257
 
黄色的1，6，10是程序员要写的，其余是系统生成的。
 
#1是Home interface, #2和#4都implements 了它。
 
#6是Remote interface, #7和#9都implements 了它。
 
#10是Bean实现。

?

?

?

[size=medium;]why?????
[/size]

简单讲，就是为了适应分布式开发的需要。
 
首先，回到我最后给出的流程图。
 
Client端最原始的冲动，肯定是能直接调用#10.UserServiceBean就爽了。那么第一个问题来了，
 Client和Server不在一个JVM里
。
 
这好办，我们不是有RMI吗，好，这个问题就这么解决了：
 
1. UserServiceBeanInterface.getUserInfo()
 
2. UserServiceBeanStub
 
3. UserServiceBeanSkeleton
 
4. UserServiceBean
 
用着用着，第二个问题来了，
 UserServiceBean只有人用，没人管理，transaction logic, security logic, bean instance pooling logic这些不得不考虑的问题浮出水面了
。
 
OK，我们想到用一个delegate，EJBObject，来进行所有这些logic的管理。client和EJBObject打交道，EJBObject调用UserServiceBean。
 
注意，这个EJBObject也是一个Interface，#6.UserService这个interface正是从它extends而来。并且EJBObject所管理的这些logic，正是AppServer的一部分。
 
现在的流程变为了：
 
EJBObject
 
1. UserService.getUserInfo()
 
2. UserServiceStub
 
3. UserServiceSkeleton
 
4. UserServiceImp
 
5. UserServiceBean
 
这已经和整幅图里的#6, #7, #8, #9, #10一一对应了。
 
现在能满足我们的需求了吗？不，第三个问题又来了：
 既然是分布式开发，那么我当然没理由只用一个Specified Server，我可能需要用到好几个不同的Server，而且EJBObject也需要管理呀
 
OK，为了适应你的需要，我们还得加再一个HomeObject，首先它来决定用哪个Server(当然，是由你用JNDI String设定的)，其次，它来管理EJBObject。
 
注意，这个EJBHome也是一个Interface，#1.UserServiceHome这个interface正是从它extends而来。并且EJBHome管理EJBObject的logic，也是AppServer的一部分。
 
现在的调用次序是
 
1. EJBHome.create()
 
2. EJBHomeStub
 
3. EJBHomeSkeleton
 
4. EJBHomeImp(EJSWrapper)
 
5. EJSHome
 
得到EJBObject
 
6. UserService.getUserInfo()
 
7. UserServiceStub
 
8. UserServiceSkeleton
 
9. UserServiceImp
 
10. UserServiceBean
 
现在已经完全和流程图的调用顺序一致了。
 
综上所述，EJB的调用确实很麻烦，但是搞的这么麻烦，确实是有搞的麻烦的道理，实在是不得不为也。

0
顶

1
踩

分享到：

域名选择的那些事

2012-02-04 15:03
浏览 1076
评论(0)
查看更多

发表评论

您还没有登录,请您登录后再发表评论

最近访客更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论