Потоки на сервере приложений
У меня есть Java-программа / поток, который я хочу развернуть на сервере приложений (GlassFish). Поток должен работать как "служба", которая запускается при запуске сервера приложений и останавливается при закрытии сервера приложений.
Как бы я поступил так? На самом деле это не Session Bean или MDB. Это просто нить.
6 ответов
Проверьте интерфейс LifecycleListener:
http://glassfish.java.net/nonav/docs/v3/api/index.html?com/sun/appserv/server/LifecycleListener.html
http://docs.oracle.com/cd/E18930_01/html/821-2418/beamc.html
Я сделал это только с Tomcat, но он должен работать в Glassfish.
Создайте класс Listener, который реализует javax.servlet.ServletContextListener
затем поместите его в файл web.xml. Он будет уведомлен, когда ваше веб-приложение будет запущено и уничтожено.
Простой класс Listener:
public class Listener implements javax.servlet.ServletContextListener {
MyThread myThread;
public void contextInitialized(ServletContextEvent sce) {
myThread = new MyThread();
myThread.start();
}
public void contextDestroyed(ServletContextEvent sce) {
if (myThread != null) {
myThread.setStop(true);
myThread.interrupt();
}
}
}
Это идет в web.xml после вашего последнего "context-param" и перед вашим первым "servlet":
<listener>
<listener-class>atis.Listener</listener-class>
</listener>
Не знаю, рекомендуют ли такие вещи или нет, но в прошлом это работало хорошо для меня.
Это не то, что вы должны делать на любом сервере приложений, если у вас нет доступа к управляемым потокам, предоставляемым сервером приложений. Я не знаком с Glassfish, но вы можете сделать это в Websphere или Weblogic, используя обычный WorkManager.
По-видимому, то же самое можно сделать в Glassfish и JBOSS через JCA WorkManager (с которым я не знаком).
Создайте сервлет, метод init которого запускает поток, являющийся основной программой.
public void init() throws ServletException {
mailThread = new MailSendThread();
mailThread.start();
}
В файле web.xml нашего приложения добавьте сервлет, который включает элемент загрузки при запуске, где число - это порядок, в котором он запускается.
<servlet>
<servlet-name>Mail Sending Servlet</servlet-name>
<servlet-class>MailServlet</servlet-class>
<load-on-startup>2</load-on-startup>
</servlet>
Мне также нужно создать несколько потоков, где каждый поток откроет сокет для других удаленных процессов, запущенных в моем приложении Glassfish. Сервер. Я посмотрел на bean-компонент LifecycleListener, предоставленный Glassfish, который вам нужно реализовать.
Я создал прототип для выполнения потоков и сокетов в реализации LifecycleListener, и он действительно не помог с управлением этими ресурсами. Чтобы получить доступ к LifecycleListener, мне нужно было установить публичный статический метод, который бы выполнял нужные действия.
Я не вижу значения в LifecycleListener, потому что я мог выполнить ту же самую работу внутри моего EJB, то есть клиента, вызывающего LifecycleListener. Потому что действительно нет должного управления Thread и Socket в бине.
Мне сказали, что JCA может быть лучшим путем. Я не пробовал это.
Я запускаю синхронизированный объект со службой таймера и только с одним истечением срока действия. Затем, в тайм-аут, я делаю то, что я хотел сделать с потоком.
http://onjava.com/pub/a/onjava/2004/10/13/j2ee-timers.html
Для меня это сработало, так как он использует компоненты J2EE и является другим потоком.