分享
 
 
 

EnterpriseJavaBeansDistilled......

王朝java/jsp·作者佚名  2008-05-31
窄屏简体版  字體: |||超大  

消息驱动bean(续)

jms是异步的

JMS消息的一个主要优势在于它是异步的。换句话说,JMS客户能发送消息,而无需等待回复。我们来比较一下它和Java RMI同步发送消息的灵活性。RMI是一种用于组装事务组件的极好选择,但在使用上很受限。每次客户调用EJB的方法时,都会因等待方法执行结果而诸塞当前线程。这种“lock-step”处理使得客户依赖于EJB服务器的可用性,从而导致了客户和EJB的紧耦合。

在JMS中,客户异步发送消息到目的地(topic或queue),同时其他的JMS客户也能从该目的地地址接收消息。当JMS客户发送消息时,它不用等待回复。因为消息发送到路由器,路由器负责将消息分发给其他的JMS客户。发送消息的客户和接收消息的客户形成了松耦合,因为发送者不再依赖于接受者的可用性。

RMI的这种限制使得JMS成为了,用于和其他应用通讯,极为诱人的替代品。使用标准的JNDI ENC,EJB能获得到JMS供应者的JMS连接,并用连接分发异步消息给其他的应用。比如,TravelAgent会话Bean可以使用JMS来通知其他的应用程序,预定已经处理过了,

在这种情形下,接收来自TravelAgent EJB的JMS消息的应用可能是消息驱动Bean,或者是企业中的其他应用,或者是其他组织中的应用,这些组织因为被告知预定已经完成而受益。还可能是,一起分享信息的商业合作者,或者是添加客户到目录邮件列表的内部市场应用程序。

JMS使得EJB发送消息而没有出现诸塞。EJB不知道消息接收者,因为它将消息发送到虚拟通道(目的地),而不是直接给另外的应用。应用能够选择从哪个虚拟通道接收消息,并接受新预定的通知。

企业消息有趣的一方面是,这种技术本身的松耦合、异步特定意味着:发送者的事务和安全context并没有对消息的接收者形成影响。比如,当TravelAgent EJB发送票务消息时,JMS供应者可能要鉴定它,但它的安全context并没有给接收该消息的JMS客户形成影响。当JMS客户接收到来自TravelAgentEJB的消息时,它对消息发送的安全context并没有概念。其实事实就是这样,因为发送者和接收者在使用不同安全管理的操作环境中。

类似地,事务也从不在发送者和接收者之间有关系。首先,发送者对接收者没有概念。如果消息发送到存在一个,或成千上万个接收者的topic中,在这种模糊的环境中管理这种分布式事务不太现实。另外,接收消息的客户可能在消息发送后很长时间内都没有收到它,因为它们临时down机了,或者不能够接收到消息。JMS强有力的关键点在于它允许发送者和接收者是临时的松耦合。事务一般都是快速执行的,因为事物锁定资源,具有不可预期的长时间事务的可能性也太不现实。

A JMS client can, however, have a distributed transaction with the JMS provider so that it manages the send or receive operation in the context of a transaction. For example, if the TravelAgent EJB's transaction fails for any reason, the JMS provider will discard the ticket message sent by the TravelAgent EJB. Transactions and JMS are covered in more detail in Chapter 14.

然而,JMS客户能够和JMS供应者有分布式事务,从而能够在同一事物上下文中管理发送和接收操作。比如,如果TravelAgent EJB事务由于某种原因失败,JMS供应者将丢弃TravelAgent EJB发送的票务消息。本书第14章有事务和JMS的详细阐述。

jms消息模型:发布-订阅 和 点对点

JMS提供了两种消息模型:发布-订阅和 点对点。JMS规范称之为,messaging domains。在JMS术语中,发布-订阅 和 点对点经常分别缩写为pub/sub和p2p(或PTP).本章这两种叫法都有。

简而言之,发布-订阅用于一对多广播式消息,然而点对点用于一对一分发消息

发布-订阅

在发布-订阅消息中,生产者能通过称之为topic的虚拟通道将消息发送给多个消费者。消费者可以选择订阅的topic。任何发送到topic的消息会将分发到所有订阅了它的消费者。每个消费者会接收到每条消息的一份拷贝。发布-订阅模型大体上是一个基于推技术的模型,因为消息会自动广播到消费者,而不需消费者向它们发送请求或为新消息pull topic。

在发布-订阅模型中,发送消息的生产者不依赖于接收消息的消费者。比如,使用发布-订阅的JMS客户能够建立持久的订阅,其间允许消费者断开、以后连接,并收集消费者断开期间发布的消息。

本章的TravelAgent EJB使用发布-订阅编程模型,并使用Topic对象作为目的地。

点对点

点对点消息模型允许JMS客户借助于,称之为queue的虚拟通道来同步和异步,发送和接收消息。其中点对点消息模型,一般都是基于pull(或者poll)的模型,消息需要客户向queue发送请求,而不是自动推到客户端。(JMS规范没有明确给出必须如何实现发布-订阅和点对点模型。这两者都可以使用推技术或拉技术,但从概念上讲发布-订阅是推和点对点是拉。)

queue可能有多个接收者,但只有一个接收者会接收到每条消息。正如图13-2所示,JMS供应者会关注消费消息的JMS客户,确保每条消息仅仅被一个JMS客户消费掉。JMS规范没有给出在多个接收者之间分发消息的规则。

用于点对点的消息API类似于发布-订阅中的。下面给出的代码演示了,如何修改TravelAgent EJB使得它使用基于queue的点对点API,而不是前述例子中使用的基于topic的发布-订阅模型。

public TicketDO bookPassage(CreditCardDO card, double price)

throws IncompleteConversationalState {

...

TicketDO ticket = new TicketDO(customer,cruise,cabin,price);

String ticketDescription = ticket.toString();

QueueConnectionFactory factory = (QueueConnectionFactory)

jndiContext.lookup("java:comp/env/jms/QueueFactory");

Queue queue = (Queue)

jndiContext.lookup("java:comp/env/jms/TicketQueue");

QueueConnection connect = factory.createQueueConneciton();

QueueSession session = connect.createQueueSession(true,0);

QueueSender sender = session.createSender(queue);

TextMessage textMsg = session.createTextMessage();

textMsg.setText(ticketDescription);

sender.send(textMsg);

connect.close();

return ticket;

} catch(Exception e) {

throw new EJBException(e);

}

}

待续。。。。。。。。

bill-转自:csdn进入讨论组讨论。

(出处:http://www.knowsky.com)

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
2023年上半年GDP全球前十五强
 百态   2023-10-24
美众议院议长启动对拜登的弹劾调查
 百态   2023-09-13
上海、济南、武汉等多地出现不明坠落物
 探索   2023-09-06
印度或要将国名改为“巴拉特”
 百态   2023-09-06
男子为女友送行,买票不登机被捕
 百态   2023-08-20
手机地震预警功能怎么开?
 干货   2023-08-06
女子4年卖2套房花700多万做美容:不但没变美脸,面部还出现变形
 百态   2023-08-04
住户一楼被水淹 还冲来8头猪
 百态   2023-07-31
女子体内爬出大量瓜子状活虫
 百态   2023-07-25
地球连续35年收到神秘规律性信号,网友:不要回答!
 探索   2023-07-21
全球镓价格本周大涨27%
 探索   2023-07-09
钱都流向了那些不缺钱的人,苦都留给了能吃苦的人
 探索   2023-07-02
倩女手游刀客魅者强控制(强混乱强眩晕强睡眠)和对应控制抗性的关系
 百态   2020-08-20
美国5月9日最新疫情:美国确诊人数突破131万
 百态   2020-05-09
荷兰政府宣布将集体辞职
 干货   2020-04-30
倩女幽魂手游师徒任务情义春秋猜成语答案逍遥观:鹏程万里
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案神机营:射石饮羽
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案昆仑山:拔刀相助
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案天工阁:鬼斧神工
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案丝路古道:单枪匹马
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:与虎谋皮
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:李代桃僵
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:指鹿为马
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案金陵:小鸟依人
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案金陵:千金买邻
 干货   2019-11-12
 
推荐阅读
 
 
 
>>返回首頁<<
 
靜靜地坐在廢墟上,四周的荒凉一望無際,忽然覺得,淒涼也很美
© 2005- 王朝網路 版權所有