Вызов webservice должен быть такой же нитью или отдельной нитью?

Question

Ниже у меня есть фрагмент кода программы сокета. Что я делаю первым, если есть данные, то я обрабатываю в первом разделе, где я использую dbconn1. Там после того, как на основании полученных данных я получил переменную callWebService, и если она установлена ​​в callWebService = 1, то у меня есть оператор if, чтобы сделать другое новое соединение и вызов и внешний веб-сервис. Я разделил их из-за того, что веб-служба не работает и не удалось остановить мою первую часть. Я не уверен, что это правильный метод, или раздел раздела должен быть полностью разделен на отдельный поток? Что является более эффективным для обработки, потому что я заметил, когда вебсервис вниз это, потому что мой ресурс идти вверх причинит соединение существо базы данных задержать

BufferedWriter writer1 = null; 
Connection dbconn1 = null; 
Connection dbconn2 = null; 
    public void run() { // etc 
    writer1 = null; 
    String message=""; 
    BufferedReader reader1 = null; 
    try { 

     writer1 = new BufferedWriter(new OutputStreamWriter(receivedSocketConn1.getOutputStream())); 
     reader1 = new BufferedReader(new InputStreamReader(receivedSocketConn1.getInputStream())); 
     receivedSocketConn1.setSoTimeout(60000); 
     int nextChar=0; 
     int callWebService=0; 
     while ((nextChar=reader1.read()) != -1) {  
      message += (char) nextChar; 
      if (nextChar == '*'){ 

       try{ 
        System.out.println("\n\n Trying establish a new db connection "); 
        dbconn1 = connectionPool.getConnection(); 
        dbconn1.setAutoCommit(false); 
        System.out.println("\n\n Checking db connection status "+dbconn1.isClosed()); 
        if ((dbconn1 == null) || dbconn1.isClosed()) { 
         System.out.println("\n\n db connection status is closed"); 
         dbconn1 = connectionPool.getConnection(); 
         dbconn1.setAutoCommit(false); 
//other codes follow here. 

         // e.g. the callWebService=1; 
         dbconn1.commit(); 
        } 
       } 
       catch (SQLException ex){ 
        System.out.println("Error SQL Exception : "+ex.toString()); 
        ex.printStackTrace(System.out); 
        try{  
        dbconn1.rollback(); 
        } 
        catch (Exception rollback) {  
        System.out.println("\nRollback dbconn1 :"); 
        rollback.printStackTrace(System.out); 
        } 
       } 
       catch (Exception e){ 
        System.out.println("\nSQL Error here :"); 
        e.printStackTrace(System.out); 
       try{  
        dbconn1.rollback(); 
       } 
       catch (Exception rollback) {  
        System.out.println("\nRollback dbconn1 :"); 
        rollback.printStackTrace(System.out); 
       } 
       } 
       finally{ 
        try { 

        if (dbconn1 != null) { 
        dbconn1.close(); 
        System.out.println("\n\n dbConn1 is being closed"); 
       } 

       } 
       catch(SQLException ex){ 
        System.out.println("SQLException has been caught for dbConn1 close"); 
        ex.printStackTrace(); 
       } 

      if(callWebService==1){ 

       try{ 
        System.out.println("\n\n Trying establish a new db connection "); 
        dbconn2 = connectionPool.getConnection(); 
        dbconn2.setAutoCommit(false); 
        sendIncomingData(dataID, dataString) 
        dbconn2.commit(); 
        } 
        catch (SQLException ex){ 
        System.out.println("Error SQL Exception : "+ex.toString()); 
        ex.printStackTrace(System.out); 
        try{  
         dbconn2.rollback(); 
        } 
         catch (Exception rollback) {  
         System.out.println("\nRollback dbconn2 :"); 
         rollback.printStackTrace(System.out); 
        } 
        } 
        catch (Exception e){ 
        System.out.println("\nSQL Error here :"); 
        e.printStackTrace(System.out); 
        try{  
        dbconn2.rollback(); 
        } 
        catch (Exception rollback) {  
         System.out.println("\nRollback dbconn2 :"); 
         rollback.printStackTrace(System.out); 
        } 
        } 
        finally{ 
        try { 

        if (dbconn2 != null) { 
         dbconn2.close(); 
         System.out.println("\n\n dbConn2 is being closed"); 
        } 

        } 
        catch(SQLException ex){ 
        System.out.println("SQLException has been caught for dbConn1 close"); 
        ex.printStackTrace(); 
       } 
      } 



      } 

      } 
     } 


    } 
    catch (SocketTimeoutException ex){ 
      System.out.println("SocketTimeoutException has been caught "); 
      ex.printStackTrace(); 
    } 
    catch (IOException ex) { 
      System.out.println("IOException has been caught "); 
      ex.printStackTrace(); 
    } 
    catch (Exception ex) { 

      System.out.println("Exception has been caught"); 
      ex.printStackTrace(System.out); 
    }  
    finally{ 

     try { 
      if (writer1 != null) { 
       writer1.close(); 
      }    
     } 
     catch(IOException ex){ 
      System.out.println("IOException has been caught for finally"); 
      ex.printStackTrace(System.out); 
     } 
    } 
} 

void sendIncomingData(int dataID, String dataString) throws Exception { 

     try{ 
      SOAPConnectionFactory soapConnectionFactory = SOAPConnectionFactory.newInstance(); 
      SOAPConnection soapConnection = soapConnectionFactory.createConnection(); 
      String url = "http://**********/webservice.asmx?WSDL"; 
      SOAPMessage soapACK = soapConnection.call(soapCalling(dataID,dataString), url); 
      printSOAP(soapACK,dataID); //do some sql insert/update in this function 
      } 
      catch (Exception e){ 
       e.printStackTrace(); 
       System.err.println(e.toString()); 
       throw e; 
      } 

} 
SOAPMessage createSOAPIncoming(int dataID,String dataString) throws Exception { 
      MessageFactory messageFactory = MessageFactory.newInstance(); 
     SOAPMessage soapMessage = messageFactory.createMessage(); 
     SOAPPart soapPart = soapMessage.getSOAPPart(); 

     String serverURI = "http://*******"; 

     // SOAP Envelope 
     SOAPEnvelope envelope = soapPart.getEnvelope(); 
     SOAPBody body = envelope.getBody(); 
     SOAPBodyElement element = body.addBodyElement(envelope.createName("*******")); 
     element.addChildElement("dataID").addTextNode(dataID); 
     element.addChildElement("dataString").addTextNode(dataString); 
     MimeHeaders headers = soapMessage.getMimeHeaders(); 
     soapMessage.saveChanges(); 

     /* Print the request message */ 
     System.out.print("\n\n Request SOAP Message To ACK FOR = "); 
     soapMessage.writeTo(System.out); 
     System.out.print("\n\n After Print = "); 
     System.out.println(); 

     return soapMessage; 
} 

Очень часто я получаю эту ошибку от веб-сервиса, если его вниз.

SEVERE: SAAJ0537: Invalid Content-Type. Could be an error message instead of a SOAP message 
com.sun.xml.internal.messaging.saaj.SOAPExceptionImpl: com.sun.xml.internal.messaging.saaj.SOAPExceptionImpl: Invalid Content-Type:text/html. Is this an error message instead of a SOAP response? 
at com.sun.xml.internal.messaging.saaj.client.p2p.HttpSOAPConnection.call(HttpSOAPConnection.java:148) 
at sk1$ConnectionHandler.sendIncomingData(sk1.java:2753) 
at sk1$ConnectionHandler.run(sk1.java:2057) 
at java.lang.Thread.run(Thread.java:722) 
Caused by: com.sun.xml.internal.messaging.saaj.SOAPExceptionImpl: Invalid Content-Type:text/html. Is this an error message instead of a SOAP response? 
at com.sun.xml.internal.messaging.saaj.soap.MessageImpl.identifyContentType(MessageImpl.java:649) 
at com.sun.xml.internal.messaging.saaj.soap.MessageFactoryImpl.createMessage(MessageFactoryImpl.java:85) 
at com.sun.xml.internal.messaging.saaj.client.p2p.HttpSOAPConnection.post(HttpSOAPConnection.java:327) 
at com.sun.xml.internal.messaging.saaj.client.p2p.HttpSOAPConnection.call(HttpSOAPConnection.java:144) 

Answer 1

Решение проблемы не многопоточное, а правильная реализация бизнес-логики.

• Если оба вызова веб-службы и базы данных, которые вы делаете, функционально независимы, вы можете разделить функциональность на независимые блоки и освободить соединение или реализовать функциональность в других потоках.
• Если оба вызова веб-службы и базы данных взаимозависимы, вам необходимо выяснить способ захвата веб-службы, чтобы ситуация с ситуацией и освободить соединение.