[J2EE] un daemon sur un serveur j2EE ??

un daemon sur un serveur j2EE ?? [J2EE] - Java - Programmation

Marsh Posté le 06-03-2009 à 20:21:39    

Bonjour,
 
J'ai une application qui va chercher des données chez un client, traite ces données, et renvois le resultat.
Cette application doit tourner en boucle "à vie" (toutes les X secondes demande des nouvelles données), et fait un traitement spécial en fonction du type de la données.
L'ajout de nouveau type de données implique un nouveau traitement.
 
 
N'y connaissant rien en J2EE, pour moi un serveur J2EE c'est comme une "boite à outils", donc je pourrais y mettre toutes mes algos de traitement des données, et quand y a un nouveau type de données deployer le nouvel outil.
De cette façon, le client du serveur J2EE serait en fait un daemon qui recupere les données et la balance au bon "outil".
 
 
Mais est ce qu'un serveur J2EE est capable de prendre en charge ce type de client (daemon) ?


Message édité par ffluff le 06-03-2009 à 20:23:43
Reply

Marsh Posté le 06-03-2009 à 20:21:39   

Reply

Marsh Posté le 06-03-2009 à 20:56:11    

Reply

Marsh Posté le 07-03-2009 à 14:28:25    

Merci ca semble être ce que je cherche
 
Je suis entrain d'essayer de voir comment ca marche pour ca j'utilise NetBeans 6.5 et GlassFish v2.
 
Le serveur demarre bien, j'ai donc creer sous netbeans un nouveau projet "Enterprise Project"
 
Et j'ai cree mon Session EJB :
 

Code :
  1. // Test1Bean.class
  2. package test;
  4. import javax.ejb.Stateless;
  6. @Stateless
  7. public class Test1Bean implements Test1Remote {
  9.     public void getMessage() {
  10.         System.out.println("TEST!!!!!!!!!!!" );
  11.     }
  12. }


Code :
  1. // Test1Remote.class
  2. package test;
  4. import javax.ejb.Remote;
  6. @Remote
  7. public interface Test1Remote {
  8.     void getMessage();   
  9. }


Puis une web application pour y mettre mon servlet
 

Code :
  1. //QuartzServlet.class
  3. package servlet;
  5. import java.io.IOException;
  6. import javax.servlet.GenericServlet;
  7. import javax.servlet.ServletConfig;
  8. import javax.servlet.ServletException;
  9. import javax.servlet.ServletRequest;
  10. import javax.servlet.ServletResponse;
  11. import org.quartz.CronTrigger;
  12. import org.quartz.JobDetail;
  13. import org.quartz.Scheduler;
  14. import org.quartz.impl.StdSchedulerFactory;
  15. import org.quartz.jobs.ee.ejb.EJBInvokerJob;
  17. public class QuartzServlet extends GenericServlet {
  18.     @Override
  19.     public void init(ServletConfig config) throws ServletException {
  20.         super.init(config);
  21.         System.out.println("Scheduling Job .." );
  22.         JobDetail jd = new JobDetail("Test Quartz", "My Test Job", EJBInvokerJob.class);
  23.         jd.getJobDataMap().put ("ejb","java:comp/env/ejb/Test1" );
  24.         jd.getJobDataMap().put("method","getMessage" );
  25.         Object[] jdArgs = new Object[0];
  26.         jd.getJobDataMap().put("args", jdArgs);
  27.         CronTrigger cronTrigger = new CronTrigger("Test Quartz", "Test Quartz" );
  29.         try {
  30.             String cronExpr = null;
  31.             cronExpr = getInitParameter("cronExpr" );
  32.             System.out.println(cronExpr);
  33.             cronTrigger.setCronExpression(cronExpr);
  34.             Scheduler sched = StdSchedulerFactory.getDefaultScheduler();
  35.             sched.scheduleJob(jd, cronTrigger);
  36.             System.out.println("Job scheduled now .." );
  37.         } catch (Exception e) {
  38.             e.printStackTrace();
  39.         }
  40.     }
  42.     @Override
  43.     public void service(ServletRequest arg0, ServletResponse arg1)
  44.             throws ServletException, IOException {
  45.     }
  47.     @Override
  48.     public String getServletInfo() {
  49.         return "Short description";
  50.     }
  51. }


Code :
  1. // web.xml
  3. <?xml version="1.0" encoding="UTF-8"?>
  4. <web-app version="2.5" xmlns="http://java.sun.com/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/ [...] &#034;&gt;
  5.     <display-name>Quartz Initializer Servlet</display-name>
  6.     <servlet>
  7.         <servlet-name>QuartzInitializer</servlet-name>
  8.         <servlet-class>org.quartz.ee.servlet.QuartzInitializerServlet</servlet-class>
  9.         <load-on-startup>1</load-on-startup>
  10.     </servlet>
  11.     <servlet>
  12.         <servlet-name>QuartzServlet</servlet-name>
  13.         <servlet-class>servlet.QuartzServlet</servlet-class>
  14.         <init-param>
  15.             <param-name>cronExpr</param-name>
  16.             <param-value>* * * * * ?</param-value>
  17.         </init-param>
  18.         <load-on-startup>2</load-on-startup>
  19.     </servlet>
  21.     <servlet-mapping>
  22.         <servlet-name>QuartzInitializer</servlet-name>
  23.         <url-pattern>/NewServlet</url-pattern>
  24.     </servlet-mapping>
  25.    
  26.     <session-config>
  27.         <session-timeout>
  28.             30
  29.         </session-timeout>
  30.     </session-config>
  31.     <welcome-file-list>
  32.         <welcome-file>index.jsp</welcome-file>
  33.     </welcome-file-list>
  34.     <ejb-ref>
  35.         <ejb-ref-name>ejb/Test1</ejb-ref-name>
  36.         <ejb-ref-type>Session</ejb-ref-type>
  37.         <home>test.Test1Bean</home>
  38.         <remote>test.Test1Remote</remote>
  39.         <ejb-link>Test1Bean</ejb-link>
  40.     </ejb-ref>
  42. </web-app>


Le problème c'est que quand je deploy mon app, le "cron" se lance bien mais dans les logs il y a :

Code :
  1. Job My Test Job.Test Quartz threw an unhandled Exception:
  2. java.lang.ClassCastException
  3.         at com.sun.corba.ee.impl.javax.rmi.PortableRemoteObject.narrow(PortableRemoteObject.java:258)
  4.         at javax.rmi.PortableRemoteObject.narrow(PortableRemoteObject.java:137)
  5.         at org.quartz.jobs.ee.ejb.EJBInvokerJob.execute(EJBInvokerJob.java:166)
  6.         at org.quartz.core.JobRunShell.run(JobRunShell.java:202)
  7.         at org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:525)
  8. Caused by: java.lang.ClassCastException: test._Test1Remote_Wrapper
  9.         at com.sun.corba.ee.impl.javax.rmi.PortableRemoteObject.narrow(PortableRemoteObject.java:241)
  10.         ... 4 more
  11. Job (My Test Job.Test Quartz threw an exception.
  12. org.quartz.SchedulerException: Job threw an unhandled exception. [See nested exception: java.lang.ClassCastException]
  13.         at org.quartz.core.JobRunShell.run(JobRunShell.java:213)
  14.         at org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:525)
  15. Caused by: java.lang.ClassCastException
  16.         at com.sun.corba.ee.impl.javax.rmi.PortableRemoteObject.narrow(PortableRemoteObject.java:258)
  17.         at javax.rmi.PortableRemoteObject.narrow(PortableRemoteObject.java:137)
  18.         at org.quartz.jobs.ee.ejb.EJBInvokerJob.execute(EJBInvokerJob.java:166)
  19.         at org.quartz.core.JobRunShell.run(JobRunShell.java:202)
  20.         ... 1 more
  21. Caused by: java.lang.ClassCastException: test._Test1Remote_Wrapper
  22.         at com.sun.corba.ee.impl.javax.rmi.PortableRemoteObject.narrow(PortableRemoteObject.java:241)
  23.         ... 4 more


Quelqu'un pourrait me dire ou j'ai foirée ?

Reply

Marsh Posté le 08-03-2009 à 09:22:48    

Jamais utilise Quartz, mais as-tu essaye leurs exemples/bien lu leur doc ?


---------------
Les aéroports où il fait bon attendre, voila un topic qu'il est bien
Reply

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed