Chapter06 消息驱动Bean一、JMS(Java Message Service) MOM:Message Oriented Middleware(面向消息中间件) 消息中间件的作用: (1) 接收消息发送方发送的消息 (2) 将接收的消息可靠地发送给消息接收方 MOM系统中的角色: MOM消息中间件:Server程序 消息客户端:消息收发方,Client,消息发送方(消息生产者),消息接收方(消息消费者) 常见的MOM: IBM WebSphere MQ BEA tuxedo/Q Tibco Rendezvous Microsoft MSMQ
JMS API 作用:消息程序不再依赖特定的MOM。
JMS支持的两种编程模型: (1) Publish/Subscribe(pub/sub) 发布/订阅模型 (2) Point-to-Point(PTP)点对点模型 pub/sub: ① 用Topic存放消息 ② 允许有多个生产者和消费者,同一个消息可被多个消费者消费,且在Topic中不会因消费而删除。 PTP: ① 消息服务器上用Queue队列来存放消息 ② 允许多个消息的生产者发送消息到Queue,但是消息只允许一个消息消费者消费。一旦消息被消费,MOM会把消息从Queue中删除。
JMS编程模型的共同点: 消息生产者发送消息到MOM,并不关心消息消费者是谁,何时消费该消息,JMS也不会影响正常的业务逻辑代码的运行。
JMS编程步骤: Step1:配置管理对象(在Application server上) ConnectionFactory:消息连接工厂,负责创建连接 Queue/Topic:消息目的地,负责存放消息 Step2:分别编写消息发送/接收程序 TopicSession session=connection.createTopicSession(false,TopicSession.AUTO_ACKNOWLEDGE); AUTO_ACKNOWLEDGE:不使用事务,使用自动应答的方式来确认消息 默认情况下(使用事务),消息的确认:当事务结束,消息就会得到确认。 对于pub/sub模型: 订阅者(消息接收者)必须先运行(原因是消息消费者要负责启动消息连接) 对于PTP模型:消息发送者和消息接收者无运行顺序限制。 二、MDB(Message-Driven Bean) Message-Driven Bean(消息驱动Bean) MDB是一种EJB,用来监听消息目的地的消息,并且处理该消息(相当于消息消费者)。 消息驱动Bean,可以实现异步编程,也就是发送消息,而不必等待返回确认,也就像发邮件一样,只是发出,而阻塞不必等待回应。 消息驱动Bean是在接受到消息之后再通过onMessage方法进行消息的处理,也就是消息的消费者,消息驱动Bean也是无状态的。 MDB的特点: (1) MDB不能被客户端直接调用,因为MDB没有本地/远程接口; (2) MDB是一个无状态的EJB,不能保存客户端状态,可以方便地构造一个池(pooling) (3) MDB不能返回异常给客户端; (4) MDB通过实现onmessage()方法来处理消息。 public void onMessage(Message message) { if(message instanceof TextMessage){ TextMessage tm=(TextMessage)message; String s = null; try { s = tm.getText(); } catch (JMSException ex) { ex.printStackTrace(); } try { tm.setText("reserve"+s); } catch (JMSException ex) { ex.printStackTrace(); } } }
MDB编程: (1) javax.jms.ManagerListener必须实现这个接口 javax.ejb.MessageDrivenBean(Opitional) (2) 必须提供缺省的构造方法(容器随时会通过构造方法构造MDB) (3) 可以通过@MessageDriven标注该类为一个消息驱动Bean @MessageDriven(mappedName=“jms/Topic”)告诉容器,该MDB监听消息的目的地。 观察者模式:只有实现了MessageListener,有消息就会处理消息。 不要在onmessage()方法中抛出异常,应该在catch语句块中处理异常。
三、MDB高级特性: Transaction(事务) 消息的发送与消息的接收不能处在同一个事务中(消息收发可能阻塞)。 Security(安全) MDB(消息消费者)不能组织非安全消息的发送。 Load balancing(负载均衡) MDB采用拉模型去构造负载均衡(监听到有消息,就会进行“拉过去”处理),Session Bean采用推模型(在会话Bean的实例化池中,来一个客户端请求就“推出去”一个Session Bean去处理请求),因此MDB是一种比Session Bean更好完成负载均衡功能的EJB。 Clustering(集群) 在集群技术中,MDB常发生重复消费(Duplicate consumption in a cluster),用于保证业务(Stateful Session Bean)执行的连续性。 |
|
来自: lance library > 《EJB》