1

RabbitMQ RPC

我决定使用这里描述的 RabbitMQ RPC 。

我的设置

传入的 Web 请求（在 Tomcat 上）将通过 RabbitMQ 将 RPC 请求分派到不同的服务并组装结果。我将一个回复队列与一个自定义消费者一起使用，该消费者侦听所有 RPC 响应并在一个简单的哈希映射中使用它们的相关 ID 收集它们。那里没什么好看的。这在控制器级别的简单集成测试中效果很好。

问题

当我尝试在 Tomcat 上部署的 Web 项目中执行此操作时，Tomcat 拒绝关闭。jstack 和一些调试让我了解到一个线程正在生成以侦听 RPC 响应并阻止 Tomcat 正常关闭。我猜这是因为创建的线程是在应用程序级别而不是请求级别创建的，并且不是由 Tomcat 管理的。Servlet.destroy()当我在or中设置断点时ServletContextListener.contextDestroyed(ServletContextEvent sce)，它们没有到达，所以我看不到手动清理的方法。

选择

作为替代方案，我可以为每个 Web 请求使用一个新的回复队列（和简单的 QueueingConsumer）。我已经对此进行了测试，它可以正常工作，并且 Tomcat 会按应有的方式关闭。但我想知道这是否是要走的路.. RabbitMQ 集群可以处理数千（甚至数百万）短活队列/消费者吗？我可以想象队列并没有那么大，但仍然......不断向所有集群节点广播......总内存占用......

问题

简而言之，为每个传入的 Web 请求创建一个队列是否明智，或者我应该如何使用一个队列和消费者设置 RabbitMQ，以便 Tomcat 可以正常关闭？

4

1 回答 1

4

我找到了解决我的问题的方法：

Java 客户端正在创建自己的线程。ExecutorService创建新连接时可以添加自己 的连接。在该方法中这样做 ServletContextListener.initialized()，可以在该方法中手动跟踪ExecutorService并关闭它ServletContextListener.destroyed()。

executorService.shutdown();
executorService.awaitTermination(20, TimeUnit.SECONDS);

我使用Executors.newCachedThreadPool();的线程有很多短暂的执行，并且在空闲超过 60 秒时它们会被清理。

这是 RabbitMQ Google 组线程的链接（感谢 Michael Klishin 向我展示了正确的方向）

于 2013-07-23T14:29:39.707 回答