3. 开发基于JBoss5的EJB3(2)

内容：Stateless Session Bean 和 Stateful Session Bean的区别

1. 建立一个新项目StatefulStatelessSessionBean如下：

图1

 

2. 建立StatefulSessionEJB的接口

图2

为这个接口编写的代码如下：

package com.pnft.test;

public interface StatefulSessionEJB
{
         public void Calculate(int anInteger);
         public int getResult();

}

3. 建立StatelessSessionEJB的接口

   重复2的各步骤。代码如下：

package com.pnft.test;

public interface StatelessSessionEJB
{
         public void Calculate(int anInteger);
         public int getResult();

}

可见2、3中两个接口除了接口名外，其他的内容都是一样的。

4. 实现StatefulSessionEJB接口

图3

实现代码如下：

package com.pnft.test;

import javax.ejb.Remote;
import javax.ejb.Stateful;

@Stateful
@Remote
public class StatefulSessionEJBBean implements StatefulSessionEJB
{
         private int state;
         public void Calculate(int anInteger)
         {
                   state += anInteger;
         }
         public int getResult()

         {
                   return state;
         }

}

5. 实现StatelessSessionEJB接口

   同4。所实现的代码如下：

package com.pnft.test;

import javax.ejb.Remote;
import javax.ejb.Stateless;

@Stateless
@Remote

public class StatelessSessionEJBBean implements StatelessSessionEJB
{
         private int state;
         public void Calculate(int anInteger)
         {
                   state += anInteger;
         }
         public int getResult()
         {
                   return state;
         }
}

4和5中除了实现类的名称、标注(@Stateful和@Stateless)不同外其他代码均相同，上述步骤完成后，两个Session Bean的编码工作已经完成。

图4

由上图可见，这两个Session Bean是在同一个项目中的，因此打包时，这个两个ejb会处于同一个jar包中。

 

6. 部署

图5

7. 将两个ejb的interface打包，并存放在指定的目录

图6

图7

8. 开发StatefulSessionEJB和StatelessSessionEJB的客户端

a. 如下图建立一个java项目

图8

b. 为项目加入必要的jar包和库

图9

点击Add External JARs按钮

图10

再加入ejb3client库

图11

c. 新建一个java类StatefulSessionEJBClient。

图12

编写代码如下：

package com.pnft.test;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class StatefulSessionEJBClient
{
         public static void main(String[] args)
         {
                   try
                   {
                            InitialContext ctx = new InitialContext();
                            //Session1

                            StatefulSessionEJB sfejb1 =

(StatefulSessionEJB)ctx.lookup("StatefulSessionEJBBean/remote");

                            System.out.println(sfejb1.getResult());
                            sfejb1.Calculate(1);

                            System.out.println(sfejb1.getResult());

                            sfejb1.Calculate(2);

                            System.out.println(sfejb1.getResult());

                            sfejb1.Calculate(3);

                            System.out.println(sfejb1.getResult());

                            //Session2

                            StatefulSessionEJB sfejb2 =

(StatefulSessionEJB)ctx.lookup("StatefulSessionEJBBean/remote");


                            System.out.println(sfejb2.getResult());

                            sfejb2.Calculate(1);

                            System.out.println(sfejb2.getResult());

                            sfejb2.Calculate(2);

                            System.out.println(sfejb2.getResult());

                            sfejb2.Calculate(3);

                            System.out.println(sfejb2.getResult());

                   }

                   catch(NamingException ne)
                   {
                            ne.printStackTrace();
                   }
         }
}

d. 新建另一个java类StatelessSessionEJBClient。

   同c。代码如下：

package com.pnft.test;

import javax.naming.InitialContext;
import javax.naming.NamingException;

public class StatelessSessionEJBClient

{
         public static void main(String[] args)
         {
                   try
                   {
                            InitialContext ctx = new InitialContext();

                            //Session1

                            StatelessSessionEJB sfejb1 =

(StatelessSessionEJB)ctx.lookup("StatelessSessionEJBBean/remote");

                            System.out.println(sfejb1.getResult());

                            sfejb1.Calculate(1);

                            System.out.println(sfejb1.getResult());

                            sfejb1.Calculate(2);

                            System.out.println(sfejb1.getResult());

                            sfejb1.Calculate(3);

                            System.out.println(sfejb1.getResult());

                            //Session2

                            StatelessSessionEJB sfejb2 =

(StatelessSessionEJB)ctx.lookup("StatelessSessionEJBBean/remote");

                            System.out.println(sfejb2.getResult());

                            sfejb2.Calculate(1);

                            System.out.println(sfejb2.getResult());



                            sfejb2.Calculate(2);

                            System.out.println(sfejb2.getResult());

                            sfejb2.Calculate(3);

                            System.out.println(sfejb2.getResult());

                   }
                   catch(NamingException ne)
                   {
                            ne.printStackTrace();
                   }
         }
}

e. 给项目增加jndi.properties文件

图13

f. 运行StatefulSessionEJB的Client，即StatefulSessionEJBClient.java，结果如下：

图14

g. 运行StatelessSessionEJB的Client，即StatelessSessionEJBClient.java，结果如下：

   0

   1

   3

   6

   6

   7

   9

   12

内存不够时，上面的数据或许会不正确。

转自:http://patmusing.blog.163.com/blog/static/1358349602010017103154936/