SOAPメッセージを取得し、Java

Question

サインイン私は、NetBeansで開発されたWebサービスを持っているし、次のようになります。

import _504.iec62325.wss._1._0.MsgFaultMsg; 
import ch.iec.tc57._2011.schema.message.ErrorType; 
import ch.iec.tc57._2011.schema.message.FaultMessageType; 
import ch.iec.tc57._2011.schema.message.HeaderType; 
import ch.iec.tc57._2011.schema.message.ReplyType; 
import ch.iec.tc57._2011.schema.message.ResponseMessageType; 
import javax.jws.WebService; 
import javax.xml.ws.BindingType; 
import ch.iec.tc57._2011.schema.message.RequestMessageType; 
... 

@WebService(serviceName = "ServiceEME", portName = "Service_EME_Port", 
     endpointInterface = "_504.iec62325.wss._1._0.PortTFEDIType", 
     targetNamespace = "urn:iec62325.504:wss:1:0", 
     wsdlLocation = "WEB-INF/wsdl/ServiceEME/servicioCS.wsdl") 
@BindingType(value = "http://java.sun.com/xml/ns/jaxws/2003/05/soap/bindings/HTTP/") 

public class ServiceEME 
{ 
    @Resource 

    private static final String CONTEXT = "PRODUCTION"; 
    private final String DATA_TYPE = "datatype"; 
    private final String SERVER_TIMESTAMP = "servertimestamp"; 
    private final String VERB_GET = "get"; 
    private final String NOUN_QUERYDATA = "querydata"; 
    private static final String NOUN_LIST = "messagelist"; 
    private static final String NOUN_ANY = "any"; 

    private static enum TipoMensaje { 
     QUERY_DATA, 
     MESSAGE_LIST, 
     MESSAGE_GET; 
    } 

    public ResponseMessageType request (RequestMessageType parameter) 
             throws MsgFaultMsg 
    { 
     Document msgAsDocument = null; 
     RSAPrivateKey privateKey = null; 
     X509Certificate cert = null; 
     try 
     { 
      switch(getMessageType(parameter)) 
      { 
       case QUERY_DATA : 
        return QueryData.procesar(parameter); 
       case MESSAGE_LIST : 
        return MessagesList.procesar(parameter); 
       case MESSAGE_GET : 
        return GetMessage.procesar(parameter); 
       default: 
        throw componerError("Error", "Error"); 
      } 
     } 
     catch (InterpretaInputException ex) 
     { 
      throw componerError(ex.getCode(), ex.getMessage()); 
     } 
    } 
... 

public static void signDocument(final Document msgAsDocument, final 
    RSAPrivateKey privateKey, final X509Certificate cert) 
               throws InterpretaInputException 
    { 
     try 
     { 
      XMLSignatureFactory fac = XMLSignatureFactory.getInstance("DOM"); 
      List<Transform> trfLst = new ArrayList<>(); 
      trfLst.add(fac.newTransform(Transform.ENVELOPED, 
               (TransformParameterSpec) null)); 
      trfLst.add(fac.newCanonicalizationMethod(CanonicalizationMethod. 
            INCLUSIVE, (C14NMethodParameterSpec) null)); 
      Reference ref = fac.newReference("", fac.newDigestMethod 
            (DigestMethod.SHA1,null), trfLst, null, null); 
      SignedInfo si = fac.newSignedInfo(fac.newCanonicalizationMethod 
       (CanonicalizationMethod.INCLUSIVE, (C14NMethodParameterSpec) null), 
       fac.newSignatureMethod(SignatureMethod.RSA_SHA1, null), 
       Collections.singletonList(ref)); 
      Node headerNode = null; 
      NodeList nl = msgAsDocument.getElementsByTagNameNS 
          ("http://iec.ch/TC57/2011/schema/message", "Header"); 

      if (nl.getLength() == 1) 
      { 
       headerNode = nl.item(0); 
      } 
      else 
      {//Header error 
       throw new InterpretaInputException(
        Constants.ERROR_QRY_004_CODE, Constants.ERROR_QRY_004_DETAIL); 
      } 

      DOMSignContext dsc = new DOMSignContext(privateKey, headerNode); 
      KeyInfoFactory keyInfoFactory = fac.getKeyInfoFactory(); 
      List<Object> x509Content = new ArrayList<>(); 

      x509Content.add(keyInfoFactory.newX509IssuerSerial(cert. 
           getIssuerDN().getName(), cert.getSerialNumber())); 
      x509Content.add(cert.getSubjectX500Principal().getName()); 
      x509Content.add(cert); 
      X509Data xd = keyInfoFactory.newX509Data(x509Content); 

      KeyInfo keyInfo = keyInfoFactory.newKeyInfo 
               (Collections.singletonList(xd)); 
      XMLSignature signature = fac.newXMLSignature(si, keyInfo); 

      signature.sign(dsc); 
     } 
     catch (Exception e) 
     { //Simplified exception handling for brevity 
      throw new InterpretaInputException(
        Constants.ERROR_HAND_009_CODE, Constants.ERROR_HAND_009_DETAIL); 
     } 
    } 
} 

問題なくサービスの応答を今私は、サーバ証明書に基づいて署名を追加する必要があります。このシグネチャは、コード内で確認できるようにsignDocument関数を介して生成されます。

私の問題は、私は、カスタム応答「ResponseMessageType」を持っていると私は署名タグを生成し、メッセージに追加するには、ドキュメントタイプにこの応答を変換する方法を知らないということです。私はmsgAsDocumentに私のResponseMessageTypeを変換する方法を知らないので この3つの項目

Document msgAsDocument = null; 
RSAPrivateKey privateKey = null; 
X509Certificate cert = null; 

はemtpyです。

私は別のサイトを読んでいると、多分私は、SOAPメッセージをインターセプトするハンドラを使用する必要がありますが、私は自分の答えを傍受し、それを送信する前に、メッセージにそれを導入する方法を見つけ出すことができます。

ありがとうございます。

Answer 1

私はハンドラを追加し、問題を解決しました。

public class SignHandler implements SOAPHandler<SOAPMessageContext> 
.... 
@Override 
public boolean handleMessage(SOAPMessageContext context) 
{ 
    //System.out.println("Server : handleMessage()......"); 
    Boolean isResponse = (Boolean) context.get(MessageContext. 
               MESSAGE_OUTBOUND_PROPERTY); 
    if(isResponse) 
    { 
     try 
     { 
      SOAPMessage soapMsg = context.getMessage(); 
      Source source = soapMsg.getSOAPPart().getContent(); 
      Node root = null; 
... 

今日私にとって新しい概念は多すぎます。

ありがとうございます！