[原创]Weblogic之EJB的分类及其理解_Tomcat, WebLogic及J2EE讨论区_Weblogic技术|Tuxedo技术|中间件技术|Oracle论坛|JAVA论坛|Linux/Unix技术|hadoop论坛_联动北方技术论坛  
网站首页 | 关于我们 | 服务中心 | 经验交流 | 公司荣誉 | 成功案例 | 合作伙伴 | 联系我们 |
联动北方-国内领先的云技术服务提供商
»  游客             当前位置:  论坛首页 »  自由讨论区 »  Tomcat, WebLogic及J2EE讨论区 »
总帖数
1
每页帖数
101/1页1
返回列表
0
发起投票  发起投票 发新帖子
查看: 2429 | 回复: 0   主题: [原创]Weblogic之EJB的分类及其理解        下一篇 
ruiyu.yu
注册用户
等级:少尉
经验:331
发帖:15
精华:0
注册:1970-1-1
状态:离线
发送短消息息给ruiyu.yu 加好友    发送短消息息给ruiyu.yu 发消息
发表于: IP:您无权察看 2016-10-25 16:43:06 | [全部帖] [楼主帖] 楼主


  一、EJB的简介


    1、什么是EJB

    EJB是Enterprise JavaBean的简称,是Java企业Bean的意思,是Java的核心代码,是一个用于分布式业务应用的标准服务器端组件模式,主要包括会话Bean(Session Bean),实体Bean(Entity Bean)和消息驱动Bean(MessageDriven Bean)三种,下面对这些Bean做详细的解释。

    2、EJB的运行环境

    EJB需要运行在EJB容器,每个Java EE应用服务器都含有EJB容器和Web容器,所以既可以运行EJB,也可以运行Web应用。目前支持EJB 3.0的应用服务器有JBoss,WebLogic等。


    二、会话Bean(Session Bean)

    1、什么是会话Bean

    Session Bean用于实现业务逻辑。比如:要实现两个数的相加或是从数据库中读取数据,都是通过Session Bean来实现的。Session Bean相当于我们熟悉的Action类。 
    Session Bean分为两种:有状态Bean(Stateful Session Beans)和无状态Bean(Stateless Session Beans)。

    要开发一个Session Bean,需要定义接口和bean class。其中接口分为远程(Remote)和本地(Local)接口。
    远程接口(Remote interface):定义了Session Bean的业务方法,这些方法可以被来自EJB容器之外的应用访问到。 
    本地接口(Local interface):同样定义了Session Bean的业务方法,这些方法可以同处于EJB容器内的其他应用使用。因为local接口允许Bean之间直接通过内存交互,没有分布式对象协议的开销,从而改善了性能。

    Bean类(bean class):Bean class包含了业务逻辑,它必须具备一个远程或本地接口。

    2、无状态Bean(Stateless Session Beans)

    (1)无状态Bean不维护会话状态,意味着一个Bean实例可以为多个用户服务。简单的说,就是当无状态会话Bean部署到应用服务器时,EJB容器会为它预先创建一些Bean实例放在对象池。当有用户访问EJB方法时,EJB容器会从对象池中取出一个实例为之服务,服务完成后就回到对象池。当下一个用户再访问EJB方法时,EJB容器有可能再次把该实例取出来为之服务。正因为如此,无状态会话Bean只需要少量的实例就可以为成千上万个用户服务,大大提高了系统性能。 
    (2)无状态Bean比有状态Bean更具性能优势,条件允许的情况下开发人员应该首先考虑使用无状态会话Bean。 
    (3)无状态Bean定义实例如下:

    远程接口(Remote interface)如下:

    @Remote 
    public interface MyFirstDAO extends DAO{ 

    } 
        本地接口(Local interface)如下: 
        @Local 
    public interface MyDoubleDAO extends MyFirstDAO 
   
    } 

    无状态Bean定义如下:

    @Stateless(mappedName="MyFirstDAO ") 
       @Remote (MyFirstDAO .class) 
       @Local(MyDoubleDAO .class) 
    public class MyFirstDAOBean extends DaoSupport implements MyFirstDAO , MyDoubleDAO
    }


    3、 Stateful Session Bean(有状态Bean) 

  (1)Stateless Session Bean创建在对象池中,提供给众多用户使用,如果Bean class有自己的成员属性(变量),那么这些变量就会受到所有调用它的用户的影响。在一些应用场合中,有时需要每个用户都有自己的一个实例,这个实例不受其他用户的影响。就好比购物车对象,每个用户都应有自己的购物车,谁都不希望有人往自己的购物车里添加或拿掉商品,而有状态Bean正好满足满足了这种需求。每个有状态的Bean在Bean实例的生命周期内都只服务一个用户,Bean class的成员变量可以在不同的方法调用间维护特定于某个用户的数据。正因为在Bean实例的生命周期内Stateful Session Bean保持了用户的信息,所以叫有状态的Bean。 

  (2)Stateful Session Bean必须实现Serializable接口,这样EJB容器才能在它们不再使用时,把它们序列化保存到硬盘上。

  3)有状态Bean定义实例如下: 
        业务接口:Cart.java 
    import java.io.Serializable; 
    import java.util.List; 
     public interface Cart extends Serializable { 
       public void AddBuyItem(String productName); 
       public List<String> getBuyItem(); 
    } 
        Bean类: 
    import java.util.ArrayList; 
    import java.util.List; 

    import javax.ejb.Remote; 
    import javax.ejb.Stateful; 
    import com.yuyu.ejb3.Cart; 

    @SuppressWarnings("serial") 
    @Stateful 
    @Remote(Cart.class) 
    public class CartBean implements Cart{ 
    private List<String> buyitem = new ArrayList<String>(); 

    public void AddBuyItem(String productName) { 
        buyitem.add(productName); 
        } 

    public List<String> getBuyItem() { 
        return buyitem; 
        } 

    } 

    

    三、实体Bean(Entity Bean)

     1、什么是实体Bean 
创建实体Bean的目的为了实现持久化,EJB3.0遵循的持久化规范是Java Persistence API,即JPA。JPA定义了一种方法,可以将常规的Java对象映射到数据库。这些普通的Java对象被叫做Entity Bean。其实除了用JPA元数据将其映射到数据库外,Entity Bean与其他Java类没有任何区别。就是我们熟悉的POJO。 
     2、Entity Bean介绍 
    (1)Entity Bean必须用@ Entity注明。 
    (2)Entity Bean必须用@id唯一标示主键。 
    (3)如果实体Bean对象需要返回客户端,必须实现 Serializable接口。 
    (4)通过在Entity Bean中加注释可以表示表和表的关联,例如:一对多要用@OneToMany来表示。 
    (5)JPA还提供了好多注解来实现别的功能。

    

    3、Entity Bean的实例

    import java.io.Serializable; 
    import java.util.Date; 

    import javax.persistence.Column; 
    import javax.persistence.Entity; 
    import javax.persistence.GeneratedValue; 
    import javax.persistence.Id; 
    import javax.persistence.Table; 
    import javax.persistence.Temporal; 
    import javax.persistence.TemporalType; 
    import javax.persistence.GenerationType; 

    @SuppressWarnings("serial") 
    @Entity 
    @Table(name = "Person") 
    public class Person implements Serializable{ 

    private Integer personid; 
    private String name;    
    private boolean sex; 
    private Short age; 
    private Date birthday; 
  
    @Id 
    @GeneratedValue(strategy=GenerationType.AUTO) 
    public Integer getPersonid() { 
        return personid; 
    } 
    public void setPersonid(Integer personid) { 
        this.personid = personid; 
    } 
    
    @Column(nullable=false,length=32) 
    public String getName() { 
        return name; 
    } 
    public void setName(String name) { 
        this.name = name; 
    } 
    
    @Column(nullable=false) 
    public boolean getSex() { 
        return sex; 
    } 
    public void setSex(boolean sex) { 
        this.sex = sex; 
    } 
    
    @Column(nullable=false)   
    public Short getAge() { 
        return age; 
    } 
    public void setAge(Short age) { 
        this.age = age; 
    } 
    
    @Temporal(value=TemporalType.DATE) 
    public Date getBirthday() { 
        return birthday; 
    } 
    
    public void setBirthday(Date birthday) { 
        this.birthday = birthday; 
        } 
    }
 


        4、 实体Bean的管理器EntityManaager 
    EntityManaager可以用来添加、删除、更新实体Bean,通过主键查找实体Bean。 
    EntityManaager管理实体Bean的实例如下: 
    import java.util.List; 
    import javax.ejb.Remote; 
    import javax.ejb.Stateless; 
    import javax.persistence.EntityManager; 
    import javax.persistence.PersistenceContext; 
    import javax.persistence.Query; 

    import com.foshanshop.ejb3.PersonDAO; 
    import com.foshanshop.ejb3.bean.Person; 

    @Stateless 
    @Remote (PersonDAO.class) 
    public class PersonDAOBean implements PersonDAO { 
    @PersistenceContext 
    protected EntityManager em; 

    public void insertPerson(Person person) { 
        em.persist(person); 
    } 

    public Person getPersonByID(int personid) {       
        return em.find(Person.class, personid); 
    } 
    
    public void mergePerson(Person person) { 
       em.merge(person); 
    } 
    
    @SuppressWarnings("unchecked")//关闭unchecked警告 
    public List<Person> getPersonList() { 
        Query query = em.createQuery("select o from Person o order by o.personid asc"); 
        return (List<Person>) query.getResultList(); 
    } 

    public void deletePerson(int personid) { 
    Person person = em.find(Person.class, personid); 
    if(person!=null) em.remove(person); 
    } 

    public void updateName(String newname, int personid) { 
    Person person = em.find(Person.class, personid); 
    if(person!=null) person.setName(newname); 
        } 
    } 


    四、消息驱动Bean(MessageDriven Bean

    消息驱动Bean(MDB) 是设计用来专门处理基于消息请求的组件;   

    1、java消息服务(JMS)


  用于访问企业消息系统开发的中立API,企业消息系统可以协助应用软件通过网络进行消息交互

  JMS编程原理:应用程序1-->消息-->Jboss JMS-->消息-->应用程序2


    2、JMS中的消息


  一条Message由头(head)、属性(property)、主体(body)组成

  有这些来自Message接口的消息类型:StreamMessage、MapMessage、TextMessage、ObjectMessage、ByteMessage


    3、消息的传递模型


  点对点(point-to-point)  一条消息只能传递给一个接受方,用javax.jms.Queue表示

  发布/订阅(publish/subscribe)  一条消息能传递传递给多个接受方,用javax.jms.Topic表示

  两种类型都是基于公共基类javax.jms.Destination类

  

   

    4、采用消息驱动Bean接受消息MDB


    @MessageDriven(activationConfig={

    @ActivationConfigProperty(propertyName="destinationType",propertyValue="javax.jms.Queue"),

    @ActivationConfigProperty(propertyName="destination",propertyValue="queue/xinrongsoft"),

    })

    public class QueueDriverBean implements MessageListener{


    @Override

    public void onMessage(Message message) {

    TextMessage textMessage=(TextMessage) message;

    System.out.println(textMessage);

        }

    }

        




赞(0)    操作        顶端 
总帖数
1
每页帖数
101/1页1
返回列表
发新帖子
请输入验证码: 点击刷新验证码
您需要登录后才可以回帖 登录 | 注册
技术讨论