如何用数据库实现完美队列

Question

我正在设计一个购物车，
我的购物车里有X产品。每个产品都与一个商店相关联。

• 示例产品1由Shop1销售

1. 我以XML的形式获取产品1的详细信息（Shop1中的可用性和价格[当产品售出或价格发生变化时]）

这应该如何处理？

我将项目分为两个部分：

1：项目1

我创建了一个基于表单的应用程序，所有商店都使用它
销售产品时，商店管理员将输入产品详细信息（可用单元数…等）并提交。我将其转换为XML并保存到表1中。

示例：
表1

Product_ID  | XML 
--------------------------------
Prod_1A     | xml  
Prod_2A     | xml  
Prod_3A     | xml  
Prod_1A     | xml  

2： 项目2

在这个项目中，我使用

ServletContextListener

当我部署这个项目时，在ServletContextListener contextLaunated方法
的帮助下，我正在创建一个Timer，它将每10秒运行一次。在那个Timer中，我正在检查Table1是否包含任何记录。如果是，在Timer类的run方法中，我正在从中挑选1条记录并更新我的购物车中的数据。

for (int i = 0; i <= 5 ; i++) {

    fetchFromNotif = fetchFromNotif(); // this methods picks a unique record
    if (fetchFromNotif != null) {
        new Thread()
        {
            public void run()
            {
                // updating the data in my Shopping cart DB.
            }
        };
        t.start();
    }
}

我的问题是，这是否是每10秒使用计时器并创建多个线程的正确方法？是否有更好的方法来实现这些要求。

对于这种类型的场景，是否有更好的方法来实现队列机制？

Answer 1

我清楚地了解到，您需要从项目#2轮询项目#1模块数据库，以获取产品更新并更改数据库#2中的购物卡数据。

在项目#2中，您可以实现ScheduledExecutorService，并在其中进行获取和更新，无需详细说明：

public class MyAppServletContextListener 
           implements ServletContextListener {
. . .
    @Override
    public void contextInitialized(ServletContextEvent e) {
        //Schedule cart updater

        Executors.newSingleThreadScheduledExecutor()
            .schedule(new Runnable() {
                @Override
                public void run() {
                    ProductUpdate productUpdate = fetchProductUpdate();

                    //do some additional stuff with productUpdate, some checks or logging

                    updateShoppingCart(shoppingCart, productUpdate);
                }
            }, 10, TimeUnit.SECONDS);
    }

}

但实际上，如果不强烈要求将产品更新逻辑与购物车更新分开，我建议在商店更新产品后立即更新项目#1中的所有购物车数据。然后您不需要任何计时器，因为您已经处于产品更新上下文中，您可以准确地看到更新了哪个产品以及更改了哪些数据。

public void processProductUpdateForm(ProductUpdate upd) {
    updateProductInDatabase(upd);


    updateAssociatedShoppingCarts(upd);

}

Answer 2

您还可以确定购物车中何时需要此更新的产品信息，并拉取信息而不是推送信息。也许你不需要实时更新它？

也许你可以检查一下，只有当用户去结账时，产品库存或价格是否有任何更新？或者在你确定的其他点上。。。

这样您就可以简化事情，而不用担心线程或队列。

Answer 3

您可以为此使用JMS。

-您将在html" target="_blank">服务器上运行JMS服务（可以是部署project 2的同一服务器）

-项目1-将向队列添加XML

-Project 2-将从队列中读取。

使用JMS，您不必实现自己的计时器/侦听器。项目1将获得到队列的连接，并将消息添加到队列。JMS客户端将实现MessageListener。每当项目1将消息添加到队列时，都会调用项目2中的MessageListener#onMessage。

对于创建队列，您可以使用Apache的ActiveMQ。

还要检查：how-can-i-use-textmessage-to-send-an-xml-file-to-jms-queue

编辑：正如“Amrola”所指出的，使用MDB（消息驱动Bean）比使用Message Listener更好。使用MDB将为您提供ejb容器提供的服务。