我正在开发一个将部署到Tomcat的Web应用程序。启动Tomcat后，我使用servlet（在web.xml中）调用Java类：

<web-app>
    <display-name>Consumer</display-name>
    <servlet>
        <servlet-name>start</servlet-name>
        <servlet-class>com.test.sample.Consumer</servlet-class>
        <load-on-startup>1</load-on-startup>
    </servlet>
</web-app>

我的Consumer.java订阅了AMQP服务器上的队列。我通过使用while (true)循环来实现此目的，该循环在独立的Java程序中可以正常工作。Itt也可以在Web应用程序的上下文中使用，但是我永远无法停止Tomcat服务器（在NetBeans
IDE中），并且我相信while循环是罪魁祸首。这是一些代码：

public class Consumer {
    public Consumer()
        consume();
    }

    private void consume()

        ...

        while (true) {
            // Await incoming messages from queue
            // Process message
        }

    }

}

有没有更好的方法来解决这个问题？还是要发出信号才能退出循环？

谢谢！

更新为使用ServletContextListener：

public final class ApplicationListener implements ServletContextListener {

    private ScheduledExecutorService scheduler;

    public ApplicationListener() {
    }

    @Override
    public void contextDestroyed(ServletContextEvent event) {
        System.out.println("***** Stopping Consumer *****");
        scheduler.shutdownNow();
    }

    @Override
    public void contextInitialized(ServletContextEvent event) {

        System.out.println("***** Starting Consumer *****");

        scheduler = Executors.newSingleThreadScheduledExecutor();
        scheduler.scheduleAtFixedRate(new ScheduledConsumer(), 0, 15000, TimeUnit.MILLISECONDS);

    }

    public class ScheduledConsumer implements Runnable {
        @Override
        public void run() {
            Consumer k = new Consumer();
            k.consumeOnce();
        }
    }
}