加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 综合聚焦 > 服务器 > 安全 > 正文

ejb3 学习小结2

发布时间:2020-12-17 02:40:20 所属栏目:安全 来源:网络整理
导读:1 注意同时声明remote.local的问题 我发现在jboss 4.2.2.gA上,如果这样的话,会出错 @Stateless @Remote @local ? 是JOBSS报错的 javax.ejb.EJBException: Local and Remote Interfaces cannot have duplicate interface for bean PhysicalFileManag

1 注意同时声明remote.local的问题
   我发现在jboss 4.2.2.gA上,如果这样的话,会出错
   @Stateless
@Remote

@local

? 是JOBSS报错的
    javax.ejb.EJBException: Local and Remote Interfaces cannot have duplicate interface for bean PhysicalFileManagerBean

  不知为啥,后来查了一下,要这样改才行,具体指明是哪一个接口
   @Stateless
@Remote(UserManager.class)
@Local(UserManager.class)

?

2 注意序列化问题
   比如有个user对象要保存,则必须要序列化,如
    public class User implements Serializable{  ...}
    public void saveUser(User user) {xxx.save(user)}

?

3 local/remote的区别
   

组件接口类型影响组件方法被客户端调用时的参数传递方式。

远程调用中的参数是按值传递的,传递的是对象的拷贝,但本地调用中参数的传递则是按引用传递的,与Java编程语言中的正常的方法调用相同。

远程调用中,客户端与组件相对比较独立。因为客户端与组件操作不同的参数对象拷贝,任何一方对数据的修改,不会影响另一方的数据。

在本地调用中,客户端和组件修改的是同一个对象。在编写Enterprise Bean时,应避免使用由这种传递方式带来的副作用,因为,当应用规模增长,客户端被分布到不同的物理服务器,参数的传递方式亦随之改变。

决定一个组件应该提供远程访问还是本地访问,一般有以下一些因素。

  • 容器管理关系

    如果某Entity Bean被其他Entity Bean所关联,则此Entity Bean必须提供本地访问接口。

    ?

  • 相关Bean之间的耦合程度

    耦合程度高的Bean之间存在互相依存的关系。因此,这一类Bean一般需要提供本地访问接口,以形成一个逻辑上的单元,同时提供整个单元内交互的效率。

    ?

  • 客户端类型

    如Bean将被JavaEE应用客户端所访问,则应该提供远程访问接口。如果客户端是Web组件或其他Bean,提供何种类型的访问接口决定于这些组件的分布状况。

    ?

  • 组件分布

    JavaEE应用可以分布在多个计算机,为提供这种分布上的可伸缩性,将被分布到不同位置的组件所访问的Bean,应该提供远程访问接口。

    ?

尽管一般Bean只提供一种类型的客户访问接口,但事实上,有一些Bean仍需要同时提供两种类型的接口 

???? 一个很好的例子,比如
    public void saveUser(User user) {
??System.out.println("User[name="+user.getName()+"]已被保存");
??user.setId(1);
?}

  如果是remote调用的话:
???? ?UserManager ejb = (UserManager)ctx.lookup("UserManagerBean/remote");
??User user = new User();
??user.setName("张三");
??ejb.saveUser(user);
??
??System.out.println("用户【name="+user.getName()+",id="+user.getId()+"】已被成功保存!");

?

?? 输出的id依然为0,因为EJB改变了值,不会传给客户端的,

?? 如果用local的话,则可以输出id=1

?

4?标注的问题
?????如果ejb实现了多个接口,可以这样声明
   /**
?* 定义方式1:
?* @Remote(value={Ejb04Interface01.class,Ejb04Interface02.class,Ejb04Interface03.class})
?* @Local(Ejb04Interface04.class)
?*/
@Stateless(name="Ejb04")
public class Ejb04Bean implements Ejb04Interface01,Ejb04Interface02,
??Ejb04Interface03,Ejb04Interface04 {
  当然,也可以在各自的接口里加上@remote或@Local

?

5 webservice问题
   直接加@webservice,详细的以后再小结之

6? 简单的JMS小结
   P2P 和发布/订阅者模式,和EJB2的一样,这里就不列出来了.例子
p2p的:

   mdb端:
    

import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

@MessageDriven(
?activationConfig = {
??@ActivationConfigProperty(propertyName="destinationType",propertyValue="javax.jms.Queue"),
??@ActivationConfigProperty(propertyName="destination",propertyValue="queue/myqueue")
?}
)
public class MyMDBBean implements MessageListener {

?public void onMessage(Message msg) {
??try {
???TextMessage textMessage = (TextMessage)msg;
???System.out.println("MyMDBBean被调用了!【"+textMessage.getText()+"】");
??} catch (JMSException e) {
???e.printStackTrace();
??}
?}

}

 客户端消费:
   

public static void main(String[] args) throws Exception{
??InitialContext ctx = new InitialContext();
??
??//获取ConnectionFactory对象
??QueueConnectionFactory factory = (QueueConnectionFactory)ctx.lookup("ConnectionFactory");
??
??//创建QueueConnection对象
??QueueConnection connection = factory.createQueueConnection();
??
??//创建QueueSession对象,第一个参数表示事务自动提交,第二个参数标识一旦消息被正确送达,将自动发回响应
??QueueSession session = connection.createQueueSession(false,QueueSession.AUTO_ACKNOWLEDGE);
??
??//获得Destination对象
??Queue queue = (Queue)ctx.lookup("queue/myqueue");
??
??//创建文本消息
??TextMessage msg = session.createTextMessage("世界,你好");
??
??//创建发送者
??QueueSender sender = session.createSender(queue);
??
??//发送消息
??sender.send(msg);
??
??//关闭会话
??session.close();
??
??System.out.println("消息已发送!");
?}

}

 

发布订阅者的话,其实就是把上面的queue改成TOPIC

?

import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

@MessageDriven(
?activationConfig = {
??@ActivationConfigProperty(propertyName="destinationType",propertyValue="javax.jms.Topic"),propertyValue="topic/mytopic")
?}
)
public class MyTopicMDBBean implements MessageListener {

?public void onMessage(Message msg) {
??try {
???TextMessage textMessage = (TextMessage)msg;
???System.out.println("MyTopicMDBBean被调用了!【"+textMessage.getText()+"】");
??} catch (JMSException e) {
???e.printStackTrace();
??}
?}

}

 消费端:
   ?public static void main(String[] args) throws Exception{ ??InitialContext ctx = new InitialContext(); ?? ??//获取ConnectionFactory对象 ??TopicConnectionFactory factory = (TopicConnectionFactory)ctx.lookup("ConnectionFactory"); ?? ??//创建TopicConnection对象 ??TopicConnection connection = factory.createTopicConnection(); ?? ??//创建TopicSession对象,第一个参数表示事务自动提交,第二个参数标识一旦消息被正确送达,将自动发回响应 ??TopicSession session = connection.createTopicSession(false,TopicSession.AUTO_ACKNOWLEDGE); ?? ??//获得Destination对象 ??Topic topic = (Topic)ctx.lookup("topic/mytopic"); ?? ??//创建文本消息 ??TextMessage msg = session.createTextMessage("世界,你好"); ?? ??//创建发布者 ??TopicPublisher publisher = session.createPublisher(topic); ?? ??//发送消息 ??publisher.publish(msg); ?? ??//关闭会话 ??session.close(); ?? ??System.out.println("消息已发送!"); ?} ??

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读