首页 > 代码库 > 消息驱动bean(MDB)实例
消息驱动bean(MDB)实例
到眼下为止前面介绍的有关JavaEE的东西都是同步的。也就是说调用者调用某个方法。那么这种方法必须马上运行并返回运行结果。
用官方一些的语言来说就是“client通过业务接口调用一个方法,在将控制权返回给client之前,server完毕该方法调用”。对于我们接触到的大多数操作而言这是最自然也是最easy实现的方法。然而,有些情况下client并不须要等待server响应。而仅仅须要告诉server应该做什么就能够了。在完毕“告知”任务之后client能够继续工作,而server则默默的在一旁处理client的请求(一般会是非常多client,非常多请求)。
在JavaEE中对于消息的处理有其自身的解决的方法——消息驱动bean(Message-Driven Bean,MDB)。它是JavaEE中用于异步消息传递的EJB组件。使用消息驱动bean能够实现上文中所说的client在请求server之后还能够继续正常的工作。client利用消息(JMS?)向server发出请求,当然这些请求终于是要交付给MDB来处理的。每当server收到请求时。将调用MDB的业务接口(这里有点儿相似于会话bean,可是这里的接口并非开发者加入的),进而对应的实现者会做对应的处理。
就像前面博文中说的那样。当使用一个会话bean时。开发者一般会创建一个业务接口,并在bean类中实现它(虽然你全然能够採用无接口的方式调用会话bean)。可是对于消息驱动bean来说,它须要实现一个特定于MDB所基于的消息系统的接口。这句话有些拗口,简而言之就是用哪种类型的消息机制就须要实现其对应的接口。这里以JMS为样例,当然JMS也是最常见的情况,(须要注意的是其它基于Java连接器体系结构(Java ConnectorArchitecture,简称JCA)的消息传递系统也是能够实现消息传递的)。
对于JMS消息驱动bean来说。他的业务接口是javax.jms.MessageListener,当中定义了单一方法:onMessage()。
以下代码演示样例显示了一个消息驱动bean(採用JMS方式)的基本结构。
@MessageDriven( mappedName="destinationQueue", activationConfig = { @ActivationConfigProperty(propertyName="destinationType", propertyValue=http://www.mamicode.com/"javax.jms.Queue"),>在本例中对于上面的消息驱动bean他的消息产生是来源于一个Servlet(核心代码例如以下)
public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { response.setContentType("text/html"); PrintWriter out = response.getWriter(); printHtmlHeader(out); // if there was info submitted, send the message String messageText = request.getParameter("message"); if (messageText != null) { try { QueueConnectionFactory factory = (QueueConnectionFactory) new InitialContext().lookup("java:comp/env/jms/MyQueueConnectionFactory"); Queue destinationQueue = (Queue) new InitialContext().lookup("java:comp/env/jms/MyQueue"); QueueConnection connection = factory.createQueueConnection(); QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE); QueueSender sender = session.createSender(null); Message message = session.createTextMessage(messageText); message.setStringProperty("RECIPIENT", "ReportProcessor"); sender.send(destinationQueue, message); connection.close(); // print a response to the html stream out.println("Message \"" + messageText + "\" sent! See the console " + "or the log file at <EXAMPLES_HOME>/glassfish/domains/domain1/logs/server.log."); } catch (Exception e) { throw new ServletException(e); } } printHtmlFooter(out); }@MessageDriven注解把类标记为一个MDB。
由@ActivationConfigProperty注解所定义的激活配置属性,将通知server该消息传递系统的类型(以Queue的方式)以及该系统所须要的不论什么配置的具体信息。
在这样的情况下,仅仅有当JMS消息有一个名为RECIPIENT的属性,且其值为ReprotProcessor时。才会调用MDB。
这个样例中须要在server中做JMS的配置。对应的每当server接受一个消息时,它将把消息作为參数调用onMessage()方法。由于与client没有不论什么同步连接,所以onMessage()方法不会返回不论什么内容。
对于消息驱动bean来说仅仅须要知道他的两个标签就可以:异步,消息。
消息驱动bean(MDB)实例