java - Web 应用程序、集群 tomcat 和 mongoDB - 如何实现持久队列

Question

我们正在构建一个小型 Web 应用程序，该应用程序将在具有负载均衡器的 3 个 tomcat 集群上运行，该 Web 应用程序基于带有用于 mongodb 的 spring 数据模块的 spring 框架。

我们的目标是拥有一个具有持久性的队列(将保留集群故障\服务器关闭等数据)。

如果队列大小 > 0，则必须清空此队列。

如果队列大小>0，我们希望一些进程会尝试清空这个队列

这里有一些需要考虑的事情:

1) 为了从队列中移除一个元素，需要一些逻辑。2) 很可能在为特定队列元素完成一些逻辑后，结果将不会从队列中删除该元素。 (稍后重试)3)我们用的是tomcat集群，一定要保留并发机制才不会出错。 (mongodb不支持加锁)

有什么想法可以实现这一目标的最简单方法是什么？

谢谢!

Answer 1

在 Tomcat 和 Mongo 之间使用 ActiveMQ。有一个请求队列。从队列中获取值并进行处理。如果需要重试，使用AMQ的重试机制，将对象加入到同一个队列中。