TransactionManager.java

  1. /*
  2.  * GovWay - A customizable API Gateway 
  3.  * https://govway.org
  4.  * 
  5.  * Copyright (c) 2005-2025 Link.it srl (https://link.it). 
  6.  * 
  7.  * This program is free software: you can redistribute it and/or modify
  8.  * it under the terms of the GNU General Public License version 3, as published by
  9.  * the Free Software Foundation.
  10.  *
  11.  * This program is distributed in the hope that it will be useful,
  12.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14.  * GNU General Public License for more details.
  15.  *
  16.  * You should have received a copy of the GNU General Public License
  17.  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18.  *
  19.  */



  23. package org.openspcoop2.pdd.core.node;

  25. import java.sql.Connection;

  27. import org.openspcoop2.core.id.IDSoggetto;
  28. import org.openspcoop2.pdd.config.DBManager;
  29. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  30. import org.openspcoop2.pdd.config.Resource;
  31. import org.openspcoop2.pdd.core.GestoreMessaggi;
  32. import org.openspcoop2.pdd.core.PdDContext;
  33. import org.openspcoop2.pdd.core.state.OpenSPCoopStateful;
  34. import org.openspcoop2.pdd.logger.MsgDiagnostico;
  35. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
  36. import org.openspcoop2.pdd.mdb.ConsegnaContenutiApplicativi;
  37. import org.openspcoop2.pdd.mdb.Imbustamento;
  38. import org.openspcoop2.pdd.mdb.ImbustamentoRisposte;
  39. import org.openspcoop2.pdd.mdb.InoltroBuste;
  40. import org.openspcoop2.pdd.mdb.InoltroRisposte;
  41. import org.openspcoop2.pdd.mdb.Sbustamento;
  42. import org.openspcoop2.pdd.mdb.SbustamentoRisposte;
  43. import org.openspcoop2.pdd.services.core.RicezioneBuste;
  44. import org.openspcoop2.pdd.services.core.RicezioneContenutiApplicativi;
  45. import org.openspcoop2.protocol.sdk.state.StatefulMessage;
  46. import org.openspcoop2.utils.Utilities;
  47. import org.openspcoop2.utils.date.DateManager;


  50. /**
  51.  * Classe che implementa la logica transazionale di OpenSPCoop
  52.  *
  53.  * @author Poli Andrea (apoli@link.it)
  54.  * @author $Author$
  55.  * @version $Rev$, $Date$
  56.  */

  58. public class TransactionManager {

  60.     /** Logger utilizzato per debug. */
  61.     private static org.slf4j.Logger log = OpenSPCoop2Logger.getLoggerOpenSPCoopCore();
  62.     
  63.     /** Variabile che indica il Nome del modulo dell'architettura di OpenSPCoop rappresentato da questa classe */
  64.     public static final String ID_MODULO = "TransactionManager";

  66.     /**
  67.      * Quando un modulo di OpenSPCoop chiama questo metodo, si aspetta come risposta una indicazione
  68.      * se utilizzare o meno il messaggio ricevuto.
  69.      *
  70.      * @param idModulo Identificativo del Modulo OpenSPCoop
  71.      * @param idBusta Identificativo del Messaggio Ricevuto
  72.      * @param tipo Tipo di Messaggio da gestire (INBOX/OUTBOX)
  73.      * @param idJMS ID JMS del Messaggio ricevuto
  74.      * @return Il metodo ritorna true se il modulo e' autorizzato a processare il messaggio, false altrimenti.
  75.      * 
  76.      */
  77.     public static boolean validityCheck(MsgDiagnostico msgDiag,String idModulo,String idBusta,String tipo,
  78.             String idJMS, PdDContext pddContext) throws Exception{
  79.         return TransactionManager.validityCheck(msgDiag,idModulo,idBusta,tipo,idJMS,pddContext,null);
  80.     }

  82.     /**
  83.      * Quando un modulo di OpenSPCoop chiama questo metodo, si aspetta come risposta una indicazione
  84.      * se utilizzare o meno il messaggio ricevuto.
  85.      *
  86.      * @param idModulo Identificativo del Modulo OpenSPCoop
  87.      * @param idBusta Identificativo del Messaggio Ricevuto
  88.      * @param tipo Tipo di Messaggio da gestire (INBOX/OUTBOX)
  89.      * @param idJMS ID JMS del Messaggio ricevuto
  90.      * @param servizioApplicativo Servizio Applicativo utilizzato come chiave insieme all'id
  91.      * @return Il metodo ritorna true se il modulo e' autorizzato a processare il messaggio, false altrimenti.
  92.      * 
  93.      */
  94.     public static boolean validityCheck(MsgDiagnostico msgDiag,String idModulo,String idBusta,String tipo,
  95.             String idJMS, PdDContext pddContext,String servizioApplicativo) throws Exception{
  96.         
  97.         // Risorse
  98.         OpenSPCoop2Properties properties = OpenSPCoop2Properties.getInstance();
  99.         IDSoggetto dominio = properties.getIdentitaPortaDefaultWithoutProtocol();
  100.         String idModuloTransaction = TransactionManager.ID_MODULO + "_" + idModulo;
  101.         
  102.         DBManager dbManager = DBManager.getInstance();
  103.         Resource resource = null;

  105.         OpenSPCoopStateful openspcoopstate = new OpenSPCoopStateful();
  106.         StatefulMessage state = new StatefulMessage(null, TransactionManager.log);
  107.         openspcoopstate.setStatoRichiesta(state);
  108.         GestoreMessaggi msg = new GestoreMessaggi(openspcoopstate, true,idBusta,tipo,msgDiag,null);
  109.         
  110.         long scadenzaWhile = DateManager.getTimeMillis() + properties.getTransactionManagerAttesaAttiva();

  112.         
  113.         try{

  115.             // Algoritmo 
  116.             int refreshOnlyCacheCount = 0;
  117.             
  118.             while( DateManager.getTimeMillis() < scadenzaWhile  ){
  119.                 
  120.                 refreshOnlyCacheCount++;
  121.                 // Il riferimento messaggio e il proprietario puo' essere letto dalla cache.
  122.                 // Per migliorare le performance, se non e' presente nella cache si assume anche non presente nel database.
  123.                 // - Per rifMsg se si chiama il metodo mapRiferimentoIntoIDBusta(true) l'id viene cercato solo nella cache
  124.                 // - Per proprietario se si chiama il metodo getProprietario(true) viene cercato solo nella cache
  125.                 // La cache puo' cmq svuotarsi velocemente se la dimensione e' troppo piccola rispetto al numero di msg in parallelo gestiti.
  126.                 // Quindi ogni 20 volte (se checkInterval=500 ogni 10 secondi) viene controllato anche il database, oltre alla cache.
  127.                 boolean checkOnlyCache = properties.isAbilitataCacheGestoreMessaggi();
  128.                 if(refreshOnlyCacheCount==(properties.getTransactionManagerCheckDBInterval())){
  129.                     msgDiag.highDebug("Re-inizializzo contatore refreshOnlyCacheCount");
  130.                     refreshOnlyCacheCount = 1;
  131.                     checkOnlyCache = false;
  132.                 }
  133.                 
  134.                 msgDiag.highDebug("Transaction su IDM["+idModulo+"] IDBusta["+idBusta+"] Tipo["+
  135.                         tipo+"] IDJMS["+idJMS+"] SA["+servizioApplicativo+"] ancora interval["
  136.                         +properties.getTransactionManagerCheckInterval()+"]  millisecondi "+(scadenzaWhile-DateManager.getTimeMillis()));
  137.                 
  138.                 boolean needConnection = false;
  139.                 if(properties.singleConnectionTransactionManager()==false)
  140.                     needConnection = true;
  141.                 else if(resource==null)
  142.                     needConnection = true;
  143.                 if( (checkOnlyCache==false) && needConnection ){
  144.                     msgDiag.highDebug("Prendo Connessione per TransactionManager");
  145.                     try{
  146.                         resource = dbManager.getResource(dominio,idModuloTransaction,PdDContext.getValue(org.openspcoop2.core.constants.Costanti.ID_TRANSAZIONE, pddContext));
  147.                     }catch(Exception e){
  148.                         throw new NodeException("Impossibile ottenere una Risorsa dal DBManager",e);
  149.                     }
  150.                     if(resource==null)
  151.                         throw new NodeException("Risorsa is null");
  152.                     if(resource.getResource() == null)
  153.                         throw new NodeException("Connessione is null");
  154.                     Connection connectionDB = (Connection) resource.getResource();
  155.                     state.setConnectionDB(connectionDB);
  156.             
  157.                 }
  158.                 
  159.                 msgDiag.highDebug("getProprietario("+checkOnlyCache+")");
  160.                 String proprietarioMessaggio = msg.getProprietario(idModulo,checkOnlyCache);
  161.                 msgDiag.highDebug("getProprietario("+checkOnlyCache+") proprietario="+proprietarioMessaggio);
  162.             
  163.                 /*
  164.                 if( (idModulo.startsWith(RicezioneContenutiApplicativi.ID_MODULO)) ||
  165.                     (ConsegnaContenutiApplicativi.ID_MODULO.equals(idModulo)) ){
  166.                     //log.info("getProprietarioSerializable");
  167.                     proprietarioMessaggio = msg.getProprietario_SerializableRead(properties.getGestioneSerializableDB_AttesaAttiva(),
  168.                             properties.getGestioneSerializableDB_CheckInterval());
  169.                 } else {
  170.                     //log.info("getProprietario");
  171.                     proprietarioMessaggio = msg.getProprietario();
  172.                 }
  173.                 */
  174.                 
  175.                 if(proprietarioMessaggio==null){
  176.                     // N.B.: anche se il thread eliminazione messaggi elimina un messaggio, poi comunque dopo 500 tentativi il 
  177.                     //       messaggio verra' eliminato!
  178.                     msgDiag.highDebug("Messaggio per il modulo ["+idModulo+"]: Attesa attiva, modulo precendente [Punto di inizio]");
  179.                     // Attesa attiva del modulo:
  180.                     if((properties.singleConnectionTransactionManager()==false) && (checkOnlyCache==false)){
  181.                         msgDiag.highDebug("Rilascio connessione per TransactionManager");
  182.                         dbManager.releaseResource(dominio,idModuloTransaction,resource);
  183.                     }
  184.                     //try {
  185.                         //Utilities.sleep((new java.util.Random()).nextInt(properties.getTransactionManager_CheckInterval())); // random da 0ms a TransactionManagerCheckInterval ms
  186.                     //}catch(Exception eRandom){}
  187.                     Utilities.sleep(properties.getTransactionManagerCheckInterval());
  188.                 }
  189.                 else if(proprietarioMessaggio.equals(idModulo)){
  190.                     msgDiag.highDebug("Messaggio per il modulo ["+idModulo+"]: proprietario["+proprietarioMessaggio+"] OK");
  191.                     if( (properties.singleConnectionTransactionManager() && (resource!=null) ) || (checkOnlyCache==false) ){
  192.                         msgDiag.highDebug("Rilascio connessione per TransactionManager");
  193.                         dbManager.releaseResource(dominio,idModuloTransaction,resource);
  194.                     }
  195.                     return true; // messaggio per il modulo
  196.                 }
  197.                 else if( TransactionManager.isModuloPrecedente(idModulo,proprietarioMessaggio,false) == false ){
  198.                     msgDiag.highDebug("Messaggio per il modulo ["+idModulo+"]: proprietario["+proprietarioMessaggio+"], scarta");
  199.                     if( (properties.singleConnectionTransactionManager() && (resource!=null) ) || (checkOnlyCache==false) ){
  200.                         msgDiag.highDebug("Rilascio connessione per TransactionManager");
  201.                         dbManager.releaseResource(dominio,idModuloTransaction,resource);
  202.                     }
  203.                     return false; // scarta messaggio poiche' il messaggio e' gia stato consegnato al modulo successivo
  204.                 }
  205.                 else{
  206.                     // Se avevo onlyCache, non possedevo la connessione
  207.                     if(needConnection && checkOnlyCache){
  208.                         msgDiag.highDebug("Prendo Connessione per TransactionManager NeedForJMS");
  209.                         try{
  210.                             resource = dbManager.getResource(dominio,idModuloTransaction,PdDContext.getValue(org.openspcoop2.core.constants.Costanti.ID_TRANSAZIONE, pddContext));
  211.                         }catch(Exception e){
  212.                             throw new NodeException("Impossibile ottenere una Risorsa dal DBManager",e);
  213.                         }
  214.                         if(resource==null)
  215.                             throw new NodeException("Risorsa is null");
  216.                         if(resource.getResource() == null)
  217.                             throw new NodeException("Connessione is null");
  218.                         Connection connectionDB = (Connection) resource.getResource();
  219.                         state.setConnectionDB(connectionDB); 
  220.                         
  221.                     }
  222.                     
  223.                     // Aggiornamento primo msg ricevuto
  224.                     String idJMSRicevutoPrecedentemente = null;
  225.                     if( ConsegnaContenutiApplicativi.ID_MODULO.equals(idModulo)  ){
  226.                         idJMSRicevutoPrecedentemente = msg.getIDJMSRicevuto(idModulo,servizioApplicativo);
  227.                     }else{
  228.                         idJMSRicevutoPrecedentemente =msg.getIDJMSRicevuto(idModulo);
  229.                     }

  231.                     if(idJMSRicevutoPrecedentemente == null){
  232.                         // Se null, e' la prima copia ricevuta, la memorizzo
  233.                         if( ConsegnaContenutiApplicativi.ID_MODULO.equals(idModulo)  ){
  234.                             msg.aggiornaIDHeaderJMS(idModulo,idJMS,servizioApplicativo);
  235.                         }else{
  236.                             msg.aggiornaIDHeaderJMS(idModulo,idJMS);
  237.                         }
  238.                     }else{
  239.                         // se non e' null guardo se e' una copia per me
  240.                         if(idJMSRicevutoPrecedentemente.equals(idJMS) == false){
  241.                             msgDiag.highDebug("Messaggio per il modulo ["+idModulo+"]: un altro messaggio JMS e' gia stato ricevuto, scarta");
  242.                             msgDiag.highDebug("Rilascio connessione per TransactionManager");
  243.                             dbManager.releaseResource(dominio,idModuloTransaction,resource);
  244.                             return false; // scarta messaggio
  245.                         }
  246.                     }

  248.                     msgDiag.highDebug("Messaggio per il modulo ["+idModulo+"]: Attesa attiva, modulo precedente["+proprietarioMessaggio+"]");
  249.                     // Attesa attiva del modulo:
  250.                     if( properties.singleConnectionTransactionManager()==false ){
  251.                         msgDiag.highDebug("Rilascio connessione per TransactionManager");
  252.                         dbManager.releaseResource(dominio,idModuloTransaction,resource);
  253.                     }
  254.                     Utilities.sleep(properties.getTransactionManagerCheckInterval());
  255.                 }

  257.             }

  259.             if( properties.singleConnectionTransactionManager() ){
  260.                 msgDiag.highDebug("Rilascio connessione per TransactionManager");
  261.                 dbManager.releaseResource(dominio,idModuloTransaction,resource);
  262.             }
  263.             
  264.             String msgTerminato = "TransactionManager: Attesa attiva terminata, probabilmente il messaggio e' stato gia gestito ed eliminato IDModulo["+idModulo+"] IDBusta["+idBusta+"] Tipo["+tipo+"]";
  265.             msgDiag.highDebug(msgTerminato);
  266.             TransactionManager.log.warn(msgTerminato);
  267.             return false;

  269.         }catch(Exception e){
  270.             TransactionManager.log.error("TransactionManager exception: "+e.getMessage(),e);
  271.             if(resource != null)
  272.                 dbManager.releaseResource(dominio,idModuloTransaction,resource);
  273.             throw e;
  274.         }
  275.     }


  278.     /**
  279.      * Restituisce true se il modulo <var>proprietarioMessaggio</var> e' un modulo precedente, nel flusso dei messaggi 
  280.      * all'interno dell'architettura di OpenSPCoop del modulo <var>idModulo</var>
  281.      *
  282.      * @param idModulo Identificatore del nodo che effettua il test.
  283.      * @param proprietarioMessaggio 'Potenziale' modulo precedente
  284.      * 
  285.      */
  286.     public static boolean isModuloPrecedente(String idModulo,String proprietarioMessaggio,boolean checkProprietarioNull) throws Exception{

  288.         if(idModulo.startsWith(RicezioneContenutiApplicativi.ID_MODULO)){
  289.             if(Imbustamento.ID_MODULO.equals(proprietarioMessaggio))
  290.                 return true;
  291.             else if(InoltroBuste.ID_MODULO.equals(proprietarioMessaggio))
  292.                 return true;
  293.             else if(SbustamentoRisposte.ID_MODULO.equals(proprietarioMessaggio))
  294.                 return true;
  295.             else if(Sbustamento.ID_MODULO.equals(proprietarioMessaggio))
  296.                 return true; // ricevute asincrone!
  297.             else 
  298.                 return false;
  299.         }

  301.         else if(idModulo.startsWith(RicezioneBuste.ID_MODULO)){
  302.             if(Sbustamento.ID_MODULO.equals(proprietarioMessaggio))
  303.                 return true;
  304.             else if(ConsegnaContenutiApplicativi.ID_MODULO.equals(proprietarioMessaggio))
  305.                 return true;
  306.             else if(ImbustamentoRisposte.ID_MODULO.equals(proprietarioMessaggio))
  307.                 return true;
  308.             else 
  309.                 return false;   
  310.         }

  312.         else if(Imbustamento.ID_MODULO.equals(idModulo)){
  313.             if(checkProprietarioNull){
  314.                 if(proprietarioMessaggio == null)
  315.                     return true; // punto di inizio
  316.             }
  317.             if(proprietarioMessaggio.startsWith(RicezioneContenutiApplicativi.ID_MODULO))
  318.                 return true;
  319.             else 
  320.                 return false;
  321.         }

  323.         else if(ImbustamentoRisposte.ID_MODULO.equals(idModulo)){
  324.             if(ConsegnaContenutiApplicativi.ID_MODULO.equals(proprietarioMessaggio))
  325.                 return true;
  326.             else 
  327.                 return false;
  328.         }

  330.         else if(Sbustamento.ID_MODULO.equals(idModulo)){
  331.             if(checkProprietarioNull){
  332.                 if(proprietarioMessaggio == null)
  333.                     return true; // punto di inizio
  334.             }
  335.             if(proprietarioMessaggio.startsWith(RicezioneBuste.ID_MODULO))
  336.                 return true;
  337.             else 
  338.                 return false;
  339.         }

  341.         else if(SbustamentoRisposte.ID_MODULO.equals(idModulo)){
  342.             if(InoltroBuste.ID_MODULO.equals(proprietarioMessaggio))
  343.                 return true;
  344.             else 
  345.                 return false;
  346.         }

  348.         else if(InoltroBuste.ID_MODULO.equals(idModulo)){
  349.             if(Imbustamento.ID_MODULO.equals(proprietarioMessaggio))
  350.                 return true;
  351.             else 
  352.                 return false;
  353.         }

  355.         else if(InoltroRisposte.ID_MODULO.equals(idModulo)){
  356.             // E' un punto di uscita senza risposta
  357.             // qualsiasi nodo e' un potenziale precedente
  358.             return true;
  359.         }

  361.         else if(ConsegnaContenutiApplicativi.ID_MODULO.equals(idModulo)){
  362.             if(Sbustamento.ID_MODULO.equals(proprietarioMessaggio))
  363.                 return true;
  364.             else if(SbustamentoRisposte.ID_MODULO.equals(proprietarioMessaggio))
  365.                 return true;
  366.             else if(Imbustamento.ID_MODULO.equals(proprietarioMessaggio))
  367.                 return true;
  368.             else if(InoltroBuste.ID_MODULO.equals(proprietarioMessaggio))
  369.                 return true;
  370.             else 
  371.                 return false;
  372.         }else{
  373.             return false;
  374.         }
  375.     }

  377. }
Created with JaCoCo 0.8.8.202204050719