database - 如何将从消息驱动的 bean 中检索到的数据保存到数据库中？

Question

我想为应用程序使用 n 层架构，以便客户端层、Web 层、业务层和数据层是分开的。我想知 Prop 有消息的消息驱动 bean 如何在不更改体系结构的情况下将其保存到数据库中。 (这是使用一个普通的 session bean，我检索了通过 JSP 页面输入到 servlet 的数据，并从称为 bean 类的 servlet 中检索了对数据库有操作的数据，不可能用消息驱动的 bean 执行此操作，因为它已经有重写方法 onMessage)

到目前为止，我可以直接使用消息 bean 从 servlet 检索值，但我想将其更改为数据库操作不在 servlet 中的 4 层架构。

我的 servlet 代码

@Resource(mappedName = "jms/dest")
private Queue dest;
@Resource(mappedName = "jms/queue")
private ConnectionFactory queue;

protected void doGet(HttpServletRequest request, HttpServletResponse response)
        throws ServletException, IOException {
    response.setContentType("text/html;charset=UTF-8");

    String str = request.getParameter("message");

    try {
        sendJMSMessageToDest(str);
    } catch (JMSException ex) {

    }


private Message createJMSMessageForjmsDest(Session session, Object messageData) throws JMSException{
    TextMessage tm = session.createTextMessage();
    tm.setText(messageData.toString());
    return tm;
}
private void sendJMSMessageToDest(Object messageData) throws JMSException{
    Connection connection = null;
    Session session = null;

    try {
        connection = queue.createConnection();
        session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        MessageProducer messageProducer = session.createProducer(dest);
        messageProducer.send(createJMSMessageForjmsDest(session,messageData));
    } catch (JMSException ex) {

    }
}

Answer 1

您必须考虑两种可能的工作流程:

1. 同步交互。
2. 异步交互。

下面我画了一个可能的架构，涵盖了启动工作流程。这些组件是:

• DAO:数据访问对象层。这负责在没有业务逻辑的情况下持久化和查询数据库。用无状态 session Bean 实现
• BL:业务逻辑层。这是负责流程业务逻辑，不知道数据将被持久化或查询在哪里只是调用 DAO 层。也独立于 View 层(Web、Web Service、Rest 等)。
• Serlvet:在这种情况下代 TableView 层或网络交互，用户直接调用 BL 以处理数据检索。
• MDB:该层用于异步事件，它从队列(或主题)中取出消息，然后调用 BL 层处理检索到的数据。

此架构支持代码重用和职责分离。

有两个工作流程的图表。

1. 同步工作流程:
   1. Servlet 调用 BL。
   2. BL 调用 DAO。
   3. DAO 与数据库交互
2. 异步工作流程:
   • 我。 Servlet 排队消息 A、B、C
   • 二。 MDB出列A
   • iii. MDB 调用 BL。
   • iv. BL 调用 DAO。
   • 诉。 DAO 与数据库交互