消息驱动bean(MDB)实例

Posted 2020-09-27 cxchanpin

到眼下为止前面介绍的有关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="javax.jms.Queue"),
        @ActivationConfigProperty(propertyName="messageSelector",
                                  propertyValue="RECIPIENT=‘ReportProcessor‘")
})
public class ReportProcessorBean implements javax.jms.MessageListener {
    public void onMessage(javax.jms.Message message) {
        try {
            System.out.println("Processing message: " + ((TextMessage) message).getText());
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

在本例中对于上面的消息驱动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来说仅仅须要知道他的两个标签就可以：异步，消息。