EJB工作原理
[align=left][font=宋体][size=10.5pt]首先，我想先说说RMI的工作原理，因为EJB毕竟是基于RMI的嘛。废话就不多讲了，RMI的本质就是实现在不同JVM之间的调用，工作原理图如下：[/size][/font][/align][align=left][attach]46745[/attach][/align][align=left][font=宋体][size=10.5pt][/size][/font][/align]
[align=left][font=宋体][size=10.5pt]它的实现方法就是在两个JVM中各开一个Stub和Skeleton，二者通过socket通信来实现参数和返回值的传递。[/size][/font][/align]
[align=left][font=宋体][size=10.5pt]有关RMI的例子代码网上可以找到不少，但绝大部分都是通过extend the interface java.rmi.Remote实现，已经封装的很完善了，不免使人有雾里看花的感觉。下面的例子是我在《Enterprise JavaBeans》里看到的，虽然很粗糙，但很直观，利于很快了解它的工作原理。[/size][/font][/align]
[align=left][font=宋体][size=10.5pt]1. [/size][/font][font=宋体][size=10.5pt]定义一个Person的接口，其中有两个business method, getAge() 和getName()[/size][/font][/align]
[align=left][font=宋体][size=10.5pt]代码[/size][/font][/align]
[list=1][*][font=宋体][size=10.5pt]public interface Person { [/size][/font][*][font=宋体][size=10.5pt] public int getAge() throws Throwable; [/size][/font][*][font=宋体][size=10.5pt] public String getName() throws Throwable; [/size][/font][*][font=宋体][size=10.5pt]} [/size][/font][/list][align=left][font=宋体][size=10.5pt]2. Person[/size][/font][font=宋体][size=10.5pt]的实现PersonServer类 [/size][/font][/align]
[align=left][font=宋体][size=10.5pt]代码[/size][/font][/align]
[list=1][*][font=宋体][size=10.5pt]public class PersonServer implements Person { [/size][/font][*][font=宋体][size=10.5pt] int age; [/size][/font][*][font=宋体][size=10.5pt] String name; [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] public PersonServer(String name, int age) { [/size][/font][*][font=宋体][size=10.5pt] this.age = age; [/size][/font][*][font=宋体][size=10.5pt] this.name = name; [/size][/font][*][font=宋体][size=10.5pt] } [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] public int getAge() { [/size][/font][*][font=宋体][size=10.5pt] return age; [/size][/font][*][font=宋体][size=10.5pt] } [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] public String getName() { [/size][/font][*][font=宋体][size=10.5pt] return name; [/size][/font][*][font=宋体][size=10.5pt] } [/size][/font][*][font=宋体][size=10.5pt]} [/size][/font][/list][align=left][font=宋体][size=10.5pt]3. [/size][/font][font=宋体][size=10.5pt]好，我们现在要在Client机器上调用getAge()和getName()这两个business method，那么就得编写相应的Stub(Client端)和Skeleton(Server端)程序。这是Stub的实现： [/size][/font][/align]
[align=left][font=宋体][size=10.5pt]代码[/size][/font][/align]
[list=1][*][font=宋体][size=10.5pt]import java.io.ObjectOutputStream; [/size][/font][*][font=宋体][size=10.5pt]import java.io.ObjectInputStream; [/size][/font][*][font=宋体][size=10.5pt]import java.net.Socket; [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt]public class Person_Stub implements Person { [/size][/font][*][font=宋体][size=10.5pt] Socket socket; [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] public Person_Stub() throws Throwable { [/size][/font][*][font=宋体][size=10.5pt] // connect to skeleton [/size][/font][*][font=宋体][size=10.5pt] socket = new Socket("computer_name", 9000); [/size][/font][*][font=宋体][size=10.5pt] } [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] public int getAge() throws Throwable { [/size][/font][*][font=宋体][size=10.5pt] // pass method name to skeleton [/size][/font][*][font=宋体][size=10.5pt] ObjectOutputStream outStream = [/size][/font][*][font=宋体][size=10.5pt] new ObjectOutputStream(socket.getOutputStream()); [/size][/font][*][font=宋体][size=10.5pt] outStream.writeObject("age"); [/size][/font][*][font=宋体][size=10.5pt] outStream.flush(); [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] ObjectInputStream inStream = [/size][/font][*][font=宋体][size=10.5pt] new ObjectInputStream(socket.getInputStream()); [/size][/font][*][font=宋体][size=10.5pt] return inStream.readInt(); [/size][/font][*][font=宋体][size=10.5pt] } [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] public String getName() throws Throwable { [/size][/font][*][font=宋体][size=10.5pt] // pass method name to skeleton [/size][/font][*][font=宋体][size=10.5pt] ObjectOutputStream outStream = [/size][/font][*][font=宋体][size=10.5pt] new ObjectOutputStream(socket.getOutputStream()); [/size][/font][*][font=宋体][size=10.5pt] outStream.writeObject("name"); [/size][/font][*][font=宋体][size=10.5pt] outStream.flush(); [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] ObjectInputStream inStream = [/size][/font][*][font=宋体][size=10.5pt] new ObjectInputStream(socket.getInputStream()); [/size][/font][*][font=宋体][size=10.5pt] return (String)inStream.readObject(); [/size][/font][*][font=宋体][size=10.5pt] } [/size][/font][*][font=宋体][size=10.5pt]} [/size][/font][/list][align=left]
[font=宋体][size=10.5pt]注意，Person_Stub和PersonServer一样，都implements Person。它们都实现了getAge()和getName()两个business method，不同的是PersonServer是真的实现，Person_Stub是建立socket连接，并向Skeleton发请求，然后通过Skeleton调用PersonServer的方法，最后接收返回的结果。[/size][/font][/align]
[align=left][font=宋体][size=10.5pt]4. Skeleton[/size][/font][font=宋体][size=10.5pt]实现 [/size][/font][/align]
[align=left][font=宋体][size=10.5pt]代码[/size][/font][/align]
[list=1][*][font=宋体][size=10.5pt]import java.io.ObjectOutputStream; [/size][/font][*][font=宋体][size=10.5pt]import java.io.ObjectInputStream; [/size][/font][*][font=宋体][size=10.5pt]import java.net.Socket; [/size][/font][*][font=宋体][size=10.5pt]import java.net.ServerSocket; [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt]public class Person_Skeleton extends Thread { [/size][/font][*][font=宋体][size=10.5pt] PersonServer myServer; [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] public Person_Skeleton(PersonServer server) { [/size][/font][*][font=宋体][size=10.5pt] // get reference of object server [/size][/font][*][font=宋体][size=10.5pt] this.myServer = server; [/size][/font][*][font=宋体][size=10.5pt] } [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] public void run() { [/size][/font][*][font=宋体][size=10.5pt] try { [/size][/font][*][font=宋体][size=10.5pt] // new socket at port 9000 [/size][/font][*][font=宋体][size=10.5pt] ServerSocket serverSocket = new ServerSocket(9000); [/size][/font][*][font=宋体][size=10.5pt] // accept stub's request [/size][/font][*][font=宋体][size=10.5pt] Socket socket = serverSocket.accept(); [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] while (socket != null) { [/size][/font][*][font=宋体][size=10.5pt] // get stub's request [/size][/font][*][font=宋体][size=10.5pt] ObjectInputStream inStream = [/size][/font][*][font=宋体][size=10.5pt] new ObjectInputStream(socket.getInputStream()); [/size][/font][*][font=宋体][size=10.5pt] String method = (String)inStream.readObject(); [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] // check method name [/size][/font][*][font=宋体][size=10.5pt] if (method.equals("age")) { [/size][/font][*][font=宋体][size=10.5pt] // execute object server's business method [/size][/font][*][font=宋体][size=10.5pt] int age = myServer.getAge(); [/size][/font][*][font=宋体][size=10.5pt] ObjectOutputStream outStream = [/size][/font][*][font=宋体][size=10.5pt] new ObjectOutputStream(socket.getOutputStream()); [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] // return result to stub [/size][/font][*][font=宋体][size=10.5pt] outStream.writeInt(age); [/size][/font][*][font=宋体][size=10.5pt] outStream.flush(); [/size][/font][*][font=宋体][size=10.5pt] } [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] if(method.equals("name")) { [/size][/font][*][font=宋体][size=10.5pt] // execute object server's business method [/size][/font][*][font=宋体][size=10.5pt] String name = myServer.getName(); [/size][/font][*][font=宋体][size=10.5pt] ObjectOutputStream outStream = [/size][/font][*][font=宋体][size=10.5pt] new ObjectOutputStream(socket.getOutputStream()); [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] // return result to stub [/size][/font][*][font=宋体][size=10.5pt] outStream.writeObject(name); [/size][/font][*][font=宋体][size=10.5pt] outStream.flush(); [/size][/font][*][font=宋体][size=10.5pt] } [/size][/font][*][font=宋体][size=10.5pt] } [/size][/font][*][font=宋体][size=10.5pt] } catch(Throwable t) { [/size][/font][*][font=宋体][size=10.5pt] t.printStackTrace(); [/size][/font][*][font=宋体][size=10.5pt] System.exit(0); [/size][/font][*][font=宋体][size=10.5pt] } [/size][/font][*][font=宋体][size=10.5pt] } [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] public static void main(String args []) { [/size][/font][*][font=宋体][size=10.5pt] // new object server [/size][/font][*][font=宋体][size=10.5pt] PersonServer person = new PersonServer("Richard", 34); [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] Person_Skeleton skel = new Person_Skeleton(person); [/size][/font][*][font=宋体][size=10.5pt] skel.start(); [/size][/font][*][font=宋体][size=10.5pt] } [/size][/font][*][font=宋体][size=10.5pt]} [/size][/font][/list][align=left][font=宋体][size=10.5pt]Skeleton[/size][/font][font=宋体][size=10.5pt]类 extends from Thread，它长驻在后台运行，随时接收client发过来的request。并根据发送过来的key去调用相应的business method。[/size][/font][/align]
[align=left][font=宋体][size=10.5pt]5. [/size][/font][font=宋体][size=10.5pt]最后一个，Client的实现 [/size][/font][/align]
[align=left][font=宋体][size=10.5pt]代码[/size][/font][/align]
[list=1][*][font=宋体][size=10.5pt]public class PersonClient { [/size][/font][*][font=宋体][size=10.5pt] public static void main(String [] args) { [/size][/font][*][font=宋体][size=10.5pt] try { [/size][/font][*][font=宋体][size=10.5pt] Person person = new Person_Stub(); [/size][/font][*][font=宋体][size=10.5pt] int age = person.getAge(); [/size][/font][*][font=宋体][size=10.5pt] String name = person.getName(); [/size][/font][*][font=宋体][size=10.5pt] System.out.println(name + " is " + age + " years old"); [/size][/font][*][font=宋体][size=10.5pt] } catch(Throwable t) { [/size][/font][*][font=宋体][size=10.5pt] t.printStackTrace(); [/size][/font][*][font=宋体][size=10.5pt] } [/size][/font][*][font=宋体][size=10.5pt] } [/size][/font][*][font=宋体][size=10.5pt]} [/size][/font][/list][align=left][font=宋体][size=10.5pt]Client[/size][/font][font=宋体][size=10.5pt]的本质是，它要知道Person接口的定义，并实例一个Person_Stub，通过Stub来调用business method，至于Stub怎么去和Server沟通，Client就不用管了。[/size][/font][/align]
[align=left][font=宋体][size=10.5pt]注意它的写法：
Person person = new Person_Stub();
而不是
Person_Stub person = new Person_Stub();[/size][/font][/align]
[align=left][font=宋体][size=10.5pt]为什么？因为要面向接口编程嘛，呵呵。[/size][/font][/align]
[size=10.5pt][font=宋体]本人没有用过Weblogic，这里就结合WebSphere来讲讲各个类的调用关系吧。[/font][/size]
[size=10.5pt][font=宋体]假定我们要创建一个读取User信息的SessionBean，需要我们写的有3个文件：[/font][font=宋体]
1. UserServiceHome.java
Home接口[/font][/size]
[font=宋体][size=10.5pt]2. UserService.java
Remote[/size][size=10.5pt]接口[/size][/font]
[font=宋体][size=10.5pt]3. UserServiceBean.java
Bean[/size][size=10.5pt]实现[/size][/font]
[font=宋体][size=10.5pt]WSAD[/size][size=10.5pt]最终会生成10个class。其它7个是什么呢？我们一个一个数过来：[/size][/font]
[font=宋体][size=10.5pt]4. _UserServiceHome_Stub.java
[/size][size=10.5pt]这个当然就是Home接口在Client端(动态加载)的Stub类了，它implements UserServiceHome。[/size][/font]
[font=宋体][size=10.5pt]5. _EJSRemoteStatelessUserServiceHome_a940aa04_Tie.java
Home[/size][size=10.5pt]接口在Server端的Skeleton类，"a940aa04"应该是随机生成的，所有其他的相关class名里都会有这个标志串，Tie是Corba对Skeleton的叫法。[/size][/font]
[font=宋体][size=10.5pt]6. EJSRemoteStatelessUserServiceHome_a940aa04.java
Home[/size][size=10.5pt]接口在Server端的实现，当然，它也implements UserServiceHome。[/size][/font]
[font=宋体][size=10.5pt]7. EJSStatelessUserServiceHomeBean_a940aa04.java
[/size][size=10.5pt]由#6调用，create _UserService_Stub。(为什么#6不能直接create _UserService_Stub呢？后面再讲。)[/size][/font]
[font=宋体][size=10.5pt]8. _UserService_Stub.java
Remote[/size][size=10.5pt]接口在Client端(动态加载)的Stub类。它implements UserService。[/size][/font]
[font=宋体][size=10.5pt]9. _EJSRemoteStatelessUserService_a940aa04_Tie.java
Remote[/size][size=10.5pt]接口在Server端的Skeleton类。[/size][/font]
[font=宋体][size=10.5pt]10. EJSRemoteStatelessUserService_a940aa04.java
Remote[/size][size=10.5pt]接口在Server端的实现，当然，它也implements UserService。并且，它负责调用UserServiceBean——也就是我们所写的Bean实现类——里面的business method。[/size][/font]
[size=10.5pt][font=宋体]那么，各个类之间的调用关系到底是怎么样的呢？简单的说，就是两次RMI循环。[/font][/size]
[align=left][font=宋体][size=10.5pt]先来看看Client端的程序是怎么写的：[/size][/font][/align]
[align=left][font=宋体][size=10.5pt]代码[/size][/font][/align]
[list=1][*][font=宋体][size=10.5pt]try { [/size][/font][*][font=宋体][size=10.5pt] InitialContext ctx = new InitialContext(); [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] //[/size][/font][font=宋体][size=10.5pt]第一步 [/size][/font][*][font=宋体][size=10.5pt] UserServiceHome home = [/size][/font][*][font=宋体][size=10.5pt] (UserServiceHome) PortableRemoteObject.narrow( [/size][/font][*][font=宋体][size=10.5pt] ctx.lookup(JNDIString), [/size][/font][*][font=宋体][size=10.5pt] UserServiceHome.class); [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] //home: _UserServiceHome_Stub [/size][/font][*][font=宋体][size=10.5pt] System.out.println(home.toString()); [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] //[/size][/font][font=宋体][size=10.5pt]第二步 [/size][/font][*][font=宋体][size=10.5pt] UserService object = home.create(); [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] //ojbect: _UserService_Stub [/size][/font][*][font=宋体][size=10.5pt] System.out.println(object.toString()); [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt] //[/size][/font][font=宋体][size=10.5pt]第三步 [/size][/font][*][font=宋体][size=10.5pt] int userId = 1; [/size][/font][*][font=宋体][size=10.5pt] UserInfo ui = object.getUserInfo(userId); [/size][/font][*][font=宋体][size=10.5pt]} [/size][/font][/list][align=left]
[font=宋体][size=10.5pt]在第一步之后，我们得到了一个UserServiceHome(interface)定义的对象home，那么，home到底是哪个class的instance呢？用debug看一下，知道了home原来就是_UserServiceHome_Stub的实例。[/size][/font][/align]
[align=left][font=宋体][size=10.5pt]从第二步开始，就是我们的关注所在，虽然只有简单的一行代码，
UserService object = home.create();
但是他背后的系统是怎么运做的呢？我们进入代码来看吧：[/size][/font][/align]
[align=left][font=宋体][size=10.5pt]1. [/size][/font][font=宋体][size=10.5pt]调用home.create() [/size][/font][/align]
[align=left][font=宋体][size=10.5pt]代码[/size][/font][/align]
[list=1][*][font=宋体][size=10.5pt]UserServiceHome home; [/size][/font][*][font=宋体][size=10.5pt]UserService obj = home.create(); [/size][/font][/list][align=left][font=宋体][size=10.5pt]2. [/size][/font][font=宋体][size=10.5pt]实际是调用_UserServiceHome_Stub.create()，在这个方法里面，Stub向Skeleton发送了一个create的字串： [/size][/font][/align]
[align=left][font=宋体][size=10.5pt]代码[/size][/font][/align]
[list=1][*][font=宋体][size=10.5pt]org.omg.CORBA.portable.OutputStream out = _request("create", true); [/size][/font][*][font=宋体][size=10.5pt]in = (org.omg.CORBA_2_3.portable.InputStream)_invoke(out); [/size][/font][/list][align=left][font=宋体][size=10.5pt]3. Server[/size][/font][font=宋体][size=10.5pt]端的Skeleton接收Stub发来的request，并调用相应的方法： [/size][/font][/align]
[align=left][font=宋体][size=10.5pt]代码[/size][/font][/align]
[list=1][*][font=宋体][size=10.5pt]_EJSRemoteStatelessUserServiceHome_a940aa04_Tie._invoke() { [/size][/font][*][font=宋体][size=10.5pt] ...... [/size][/font][*][font=宋体][size=10.5pt] switch (method.length()) { [/size][/font][*][font=宋体][size=10.5pt] case 6: [/size][/font][*][font=宋体][size=10.5pt] if (method.equals("create")) { [/size][/font][*][font=宋体][size=10.5pt] return create(in, reply); [/size][/font][*][font=宋体][size=10.5pt] } [/size][/font][*][font=宋体][size=10.5pt] ...... [/size][/font][*][font=宋体][size=10.5pt] } [/size][/font][*][font=宋体][size=10.5pt]} [/size][/font][/list][align=left]
[font=宋体][size=10.5pt]代码[/size][/font][/align]
[list=1][*][font=宋体][size=10.5pt]_EJSRemoteStatelessUserServiceHome_a940aa04_Tie.create() { [/size][/font][*][font=宋体][size=10.5pt] EJSRemoteStatelessUserServiceHome_a940aa04 target = null; [/size][/font][*][font=宋体][size=10.5pt] result = target.create(); [/size][/font][*][font=宋体][size=10.5pt] org.omg.CORBA.portable.OutputStream out = reply.createReply(); [/size][/font][*][font=宋体][size=10.5pt] Util.writeRemoteObject(out,result); [/size][/font][*][font=宋体][size=10.5pt] return out; [/size][/font][*][font=宋体][size=10.5pt]} [/size][/font][/list][align=left][font=宋体][size=10.5pt]4. Skeleton[/size][/font][font=宋体][size=10.5pt]调用的是UserServiceHome的Server端实现类的create方法 [/size][/font][/align]
[align=left][font=宋体][size=10.5pt]代码[/size][/font][/align]
[list=1][*][font=宋体][size=10.5pt]EJSRemoteStatelessUserServiceHome_a940aa04.create() { [/size][/font][*][font=宋体][size=10.5pt] UserService _EJS_result; [/size][/font][*][font=宋体][size=10.5pt] _EJS_result = EJSStatelessUserServiceHomeBean_a940aa04.create(); [/size][/font][*][font=宋体][size=10.5pt]} [/size][/font][/list][align=left][font=宋体][size=10.5pt]5. #4[/size][/font][font=宋体][size=10.5pt]又调用EJSStatelessUserServiceHomeBean_a940aa04.create() [/size][/font][/align]
[align=left][font=宋体][size=10.5pt]代码[/size][/font][/align]
[list=1][*][font=宋体][size=10.5pt]UserService result = super.createWrapper(new BeanId(this, null)); [/size][/font][/list][align=left]
[font=宋体][size=10.5pt]至此，我们终于结束了第一个RMI循环，并得到了Remote接口UserService的Stub类_UserService_Stub，就是#5里面的result。[/size][/font][/align]
[font=宋体][size=10.5pt]这里有一个问题，为什么#4不直接create _UserService_Stub，而又转了一道#5的手呢？因为#4 extends from EJSWrapper，它没有能力create Stub，因此必须借助#5，which extends from EJSHome，这样才可以生成一个Stub。如果不是为了生成这个Stub，应该可以不走#5这一步。[/size][/font]
[font=宋体][size=10.5pt][/size][/font]
[font=宋体][size=10.5pt][/size][/font]
[align=left][font=宋体][size=10.5pt]OK, now we got the object which is instanceOf _UserService_Stub, and implements UserService[/size][/font][/align]
[align=left][font=宋体][size=10.5pt]现在我们的Client端走到第三步了：
UserInfo ui = object.getUserInfo(userId);[/size][/font][/align]
[align=left][font=宋体][size=10.5pt]继续看代码，开始第二个RMI循环：[/size][/font][/align]
[align=left][font=宋体][size=10.5pt]1. [/size][/font][font=宋体][size=10.5pt]调用object.getUserInfo() [/size][/font][/align]
[align=left][font=宋体][size=10.5pt]代码[/size][/font][/align]
[list=1][*][font=宋体][size=10.5pt]UserService object; [/size][/font][*][font=宋体][size=10.5pt]object.getUserInfo(userId); [/size][/font][/list][align=left][font=宋体][size=10.5pt]2. [/size][/font][font=宋体][size=10.5pt]实际是调用_UserService_Stub.getUserInfo(int arg0)，在这个方法里面，Stub向Skeleton发送了一个getUserInfo的字串和arg0这个参数： [/size][/font][/align]
[align=left][font=宋体][size=10.5pt]代码[/size][/font][/align]
[list=1][*][font=宋体][size=10.5pt]org.omg.CORBA.portable.OutputStream out = _request("getUserInfo", true); [/size][/font][*][font=宋体][size=10.5pt]out.write_long(arg0); [/size][/font][*][font=宋体][size=10.5pt]in = (org.omg.CORBA_2_3.portable.InputStream)_invoke(out); [/size][/font][/list][align=left][font=宋体][size=10.5pt]3. Server[/size][/font][font=宋体][size=10.5pt]端的Skeleton接收Stub发来的request，并调用相应的方法： [/size][/font][/align]
[align=left][font=宋体][size=10.5pt]代码[/size][/font][/align]
[list=1][*][font=宋体][size=10.5pt]_EJSRemoteStatelessUserService_a940aa04_Tie._invoke() { [/size][/font][*][font=宋体][size=10.5pt] switch (method.charAt(5)) [/size][/font][*][font=宋体][size=10.5pt] { [/size][/font][*][font=宋体][size=10.5pt] case 83: [/size][/font][*][font=宋体][size=10.5pt] if (method.equals("getUserInfo")) { [/size][/font][*][font=宋体][size=10.5pt] return getUserInfo(in, reply); [/size][/font][*][font=宋体][size=10.5pt] } [/size][/font][*][font=宋体][size=10.5pt] ...... [/size][/font][*][font=宋体][size=10.5pt] } [/size][/font][*][font=宋体][size=10.5pt]} [/size][/font][*][font=宋体][size=10.5pt] [/size][/font][*][font=宋体][size=10.5pt]_EJSRemoteStatelessUserService_a940aa04_Tie.getUserInfo() { [/size][/font][*][font=宋体][size=10.5pt] EJSRemoteStatelessUserService_a940aa04 target = null; [/size][/font][*][font=宋体][size=10.5pt] int arg0 = in.read_long(); [/size][/font][*][font=宋体][size=10.5pt] UserDTO result = target.getUserInfo(arg0); [/size][/font][*][font=宋体][size=10.5pt] org.omg.CORBA_2_3.portable.OutputStream out = reply.createReply(); [/size][/font][*][font=宋体][size=10.5pt] out.write_value(result,UserDTO.class); [/size][/font][*][font=宋体][size=10.5pt] return out; [/size][/font][*][font=宋体][size=10.5pt]} [/size][/font][/list][align=left][font=宋体][size=10.5pt]4. Skeleton[/size][/font][font=宋体][size=10.5pt]调用的是UserService的Server端实现类的getUserInfo方法 [/size][/font][/align]
[align=left][font=宋体][size=10.5pt]代码[/size][/font][/align]
[list=1][*][font=宋体][size=10.5pt]EJSRemoteStatelessUserService_a940aa04.getUserInfo() { [/size][/font][*][font=宋体][size=10.5pt] UserServiceBean _EJS_beanRef = container.preInvoke(this, 0, _EJS_s); [/size][/font][*][font=宋体][size=10.5pt] _EJS_result = _EJS_beanRef.getUserInfo(id); [/size][/font][*][font=宋体][size=10.5pt]} [/size][/font][/list][align=left]
[font=宋体][size=10.5pt]最后的最后，#4终于调用了我们写的UserServiceBean里的getUserInfo方法，这才是我们真正想要去做的事情。[/size][/font][/align]
[align=left][font=宋体][size=10.5pt]至此，第二个RMI循环也终于结束了。[/size][/font][/align]
[size=10.5pt][font=宋体]回顾一下上面的分析，可以很清晰的看到两次RMI循环的过程，下图(见链接)描述了整个流程：[/font][/size]
[size=10.5pt][url=http://www.pbase.com/image/27229257][font=宋体][color=#0000ff]http://www.pbase.com/image/27229257[/color][/font][/url][/size]
[size=10.5pt][font=宋体]黄色的1，6，10是程序员要写的，其余是系统生成的。[/font][/size]
[size=10.5pt][font=宋体]#1[/font][/size][size=10.5pt][font=宋体]是Home interface, #2和#4都implements 了它。[/font][font=宋体]
#6是Remote interface, #7和#9都implements 了它。[/font][font=宋体]
#10是Bean实现。[/font][/size]
[size=10.5pt][font=宋体]写到这里，基本要说的就说完了。这实在是一项累死人的工作，希望您能稀饭。欢迎补充，欢迎摘错。谢谢，呵呵。[/font][/size]
[size=10.5pt][font=宋体]简单讲，就是为了适应分布式开发的需要。[/font][/size]
[size=10.5pt][font=宋体]首先，回到我最后给出的流程图。[/font][/size]
[size=10.5pt][font=宋体]Client[/font][/size][size=10.5pt][font=宋体]端最原始的冲动，肯定是能直接调用#10.UserServiceBean就爽了。那么第一个问题来了，[/font][font=宋体]
[b]Client[/b][b]和Server不在一个JVM里[/b]。[/font][/size]
[size=10.5pt][font=宋体]这好办，我们不是有RMI吗，好，这个问题就这么解决了：[/font][font=宋体]
1. UserServiceBeanInterface.getUserInfo()
2. UserServiceBeanStub
3. UserServiceBeanSkeleton
4. UserServiceBean[/font][/size]
[size=10.5pt][font=宋体]用着用着，第二个问题来了，[/font][font=宋体]
[b]UserServiceBean[/b][b]只有人用，没人管理，transaction logic, security logic, bean instance pooling logic这些不得不考虑的问题浮出水面了[/b]。[/font][/size]
[font=宋体][size=10.5pt]OK[/size][size=10.5pt]，我们想到用一个delegate，EJBObject，来进行所有这些logic的管理。client和EJBObject打交道，EJBObject调用UserServiceBean。[/size][/font]
[size=10.5pt][font=宋体]注意，这个EJBObject也是一个Interface，#6.UserService这个interface正是从它extends而来。并且EJBObject所管理的这些logic，正是AppServer的一部分。[/font][/size]
[size=10.5pt][font=宋体]现在的流程变为了：[/font][font=宋体]
EJBObject
1. UserService.getUserInfo()
2. UserServiceStub
3. UserServiceSkeleton
4. UserServiceImp
5. UserServiceBean[/font][/size]
[size=10.5pt][font=宋体]这已经和整幅图里的#6, #7, #8, #9, #10一一对应了。[/font][/size]
[size=10.5pt][font=宋体]现在能满足我们的需求了吗？不，第三个问题又来了：[/font][font=宋体]
[b]既然是分布式开发，那么我当然没理由只用一个Specified Server，我可能需要用到好几个不同的Server，而且EJBObject也需要管理呀[/b][/font][/size]
[font=宋体][size=10.5pt]OK[/size][size=10.5pt]，为了适应你的需要，我们还得加再一个HomeObject，首先它来决定用哪个Server(当然，是由你用JNDI String设定的)，其次，它来管理EJBObject。[/size][/font]
[size=10.5pt][font=宋体]注意，这个EJBHome也是一个Interface，#1.UserServiceHome这个interface正是从它extends而来。并且EJBHome管理EJBObject的logic，也是AppServer的一部分。[/font][/size]
[size=10.5pt][font=宋体]现在的调用次序是[/font][font=宋体]
1. EJBHome.create()
2. EJBHomeStub
3. EJBHomeSkeleton
4. EJBHomeImp(EJSWrapper)
5. EJSHome[/font][/size]
[size=10.5pt][font=宋体]得到EJBObject[/font][/size]
[size=10.5pt][font=宋体]6. UserService.getUserInfo()
7. UserServiceStub
8. UserServiceSkeleton
9. UserServiceImp
10. UserServiceBean[/font][/size]
[size=10.5pt][font=宋体]现在已经完全和流程图的调用顺序一致了。[/font][/size]
[size=10.5pt][font=宋体]综上所述，EJB的调用确实很麻烦，但是搞的这么麻烦，确实是有搞的麻烦的道理，实在是不得不为也。[/font][/size]
[size=10.5pt][font=宋体]哎哟，好累啊。希望我把这个问题说清楚了，您也没给我绕迷糊。谢谢。[/font][/size]
[[i] 本帖最后由 苦命 于 2007-10-26 09:58 编辑 [/i]]
页:
[1]
