EJB RMI 通信原理与流程

EJB 是 RMI 的封装框架，实现了RMI的功能。

RMI：
    Remote Method Invocation 远程方法调用。用于不同的jvm间通信，由 jdk:java.rmi.Remote 接口实现。

    对于异步通信需要四个关键的类
        接口  接口实现类  实现类存根stub（用于客户端）  实现类框架Skeleton（用于服务端）

        stub 和 skeleton 就是两个jvm端的通信兵(接口人)，stub 告诉 skeleton 我要调用哪个方法，
        skeleton 调用服务器端实现类来调用具体的方法，并将结果返回给 stub。

        虽然 stub 和 skeleton 都是 接口的实现类，但在客户端只需要 接口 和 stub 就行了。

//RMI 示例：
        // 接口
        public interface Person
        {
            public int getAge() throws Throwable;
            public String getName() throws Throwable;
        }

        // 接口实现类 方法返回具体的消息
        public class PersonServer implements Person
        {
            int age;
            String name;

            public PersonServer(String name, int age) {
                this.age = age;
                this.name = name;
            }

            public int getAge(){
                return age;
            }

            public String getName(){
                return name;
            }
        }

        // 客户端操作 stub类  负责告诉 skeleton ：我要调用哪个方法
        import java.io.ObjectOutputStream;
        import java.io.ObjectInputStream;
        import java.net.Socket;

        public class Person_Stub implements Person {
            Socket socket;

            public Person_Stub(); throws Throwable {
                // connect to skeleton
                socket = new Socket("computer_name", 9000);
            }

            public int getAge(); throws Throwable {
                // pass method name to skeleton
                ObjectOutputStream outStream =
                    new ObjectOutputStream(socket.getOutputStream(););;
                outStream.writeObject("age");;
                outStream.flush();;

                ObjectInputStream inStream =
                    new ObjectInputStream(socket.getInputStream(););;
                return inStream.readInt();;
            }

            public String getName(); throws Throwable {
                // pass method name to skeleton
                ObjectOutputStream outStream =
                    new ObjectOutputStream(socket.getOutputStream(););;
                outStream.writeObject("name");;
                outStream.flush();;

                ObjectInputStream inStream =
                    new ObjectInputStream(socket.getInputStream(););;
                return (String);inStream.readObject();;
            }
        }

        // 服务端skeleton类  负责通过实现类 调用stub类指定的方法
        import java.io.ObjectOutputStream;
        import java.io.ObjectInputStream;
        import java.net.Socket;
        import java.net.ServerSocket;

        public class Person_Skeleton extends Thread {
            PersonServer myServer;

            public Person_Skeleton(PersonServer server); {
                // get reference of object server
                this.myServer = server;
            }

            public void run(); {
                try {
                    // new socket at port 9000
                    ServerSocket serverSocket = new ServerSocket(9000);;
                    // accept stub's request
                    Socket socket = serverSocket.accept();;

                    while (socket != null); {
                        // get stub's request
                        ObjectInputStream inStream =
                            new ObjectInputStream(socket.getInputStream(););;
                        String method = (String);inStream.readObject();;

                        // check method name
                        if (method.equals("age");); {
                            // execute object server's business method
                            int age = myServer.getAge();;
                            ObjectOutputStream outStream =
                                new ObjectOutputStream(socket.getOutputStream(););;

                            // return result to stub
                            outStream.writeInt(age);;
                            outStream.flush();;
                        }

                        if(method.equals("name");); {
                            // execute object server's business method
                            String name = myServer.getName();;
                            ObjectOutputStream outStream =
                                new ObjectOutputStream(socket.getOutputStream(););;

                            // return result to stub
                            outStream.writeObject(name);;
                            outStream.flush();;
                        }
                    }
                } catch(Throwable t); {
                    t.printStackTrace();;
                    System.exit(0);;
                }
            }

            public static void main(String args []); {
                // new object server
                PersonServer person = new PersonServer("Richard", 34);;

                Person_Skeleton skel = new Person_Skeleton(person);;
                skel.start();;
            }
        }

 

 

 

EJB：
    stub 和 skeleton 类由服务器部署时动态生成。
    普通的RMI需要在客户端保存stub类，而EJB不需要，因为服务器会把stub类的对象实例发送给客户端。

    EJB 实现了RMI的功能需要一个类和两个接口,由框架或服务器生成的类会根据不同的服务器生成不同的类。
        由于不同的 服务器 之间交互的方式不同，比如 weblogic 和 jboss 的通信端口不一样，实现的机制
        也不一样。要根据不同的服务器，生成用于对应服务器的通信类。
        比如 weblogic 在部署ejb时，就会生成用于 weblogic 通信的 stub 和 skeleton 字节码文件。
        EJB会根据不同的服务器有针对性的生成 bean 类的实现类。

    用户编写            EJBC生成          部署时动态生成字节码文件
    bean  类            实现类
    remote接口          实现类               stub   skeleton
    home  接口          实现类               stub   skeleton

    EJB 的因此远程通信至少要有两次 RMI 先敲门，后通信 。
    第一次是 Home 接口的 RMI ，home接口 stub 通知 skeleton 开始ejb通信。然后home接口会生成
        remote接口 的 stub 字节码文件 并传递给 客户端 用于通信。
    第二次是 remote接口 真正开始通信。

    由于在EJB中，客户端只需要存两个类 home 和 remote 接口，当需要跟服务器端通信时，先通知服务器
    获得 通信的 stub ，然后再进行通信。
    也就是说 EJB 中，home RMI 仅仅是为了将 Remote 接口的stub传递给客户端。
    然后客户端通过得到的 remote 接口的 stub 直接跟服务器进行通信。

    先敲门，后通信。敲门的过程中我们可以进行身份验证等等。

    流程示例：

        // 获得 home 接口的 stub
        Home home = (Home) PortableRemoteObject.narrow(ctx.lookup("Hello"), HelloHome.class);

        // 通过 home_stub 获得 remote_stub
        Remote remote = home.create();

        //　remote_stub 与 服务器进行通信
        remote.helloword();

 

流程实例2：

EJB调用流程：
    class:
        SessionBean
        Service 分发调用 local / remote home

    interface:
        EJBObject
        EJBHome     create   EJBObject

        EJBLocalObject
        EJBLocalHome    create      EJBLocalObject
   
    Home 负责创建 EJBObject
    EJBObject 通过框架调用 SessionBean
       
struts请求调用流程：
    action 调用 Service 的方法
    Service 分发调用 local / remote home
    EJBObject / EJBLocalObject 框架调用 SessionBean  (框架是如何知道调用哪个SessionBean的呢？) 
    SessionBean 调用 persistents 层