Play Keepaway: StringでSOAP通信

wsdlからwsimportを使って自動生成したJavaクラスSayHelloを使って、SOAPメッセージ(xml)をString型で生成し、
そのStringをURLConnectionでHTTP送受信する。
で、レスポンスをStringにして
SOAPMessageに戻す。

SOAPMessageからSOAPEnvelopeの子要素をorg.w3c.dom.Nodeオブジェクトで取得。
最後に、JAXBのUnmarshallでNodeからSayHelloResponse（wsimportで生成されたSOAPの応答のクラス）に変換する。
あとは、いつものSOAPです。

以上！ソースが汚すぎるから、明日整形しましょうかね。

view plainprint?
/** 
 *  
 */  
package jp.blogspot.tanakanbb;  
  
import java.io.BufferedReader;  
import java.io.BufferedWriter;  
import java.io.ByteArrayInputStream;  
import java.io.ByteArrayOutputStream;  
import java.io.InputStreamReader;  
import java.io.OutputStreamWriter;  
import java.io.StringWriter;  
import java.net.URL;  
import java.net.URLConnection;  
  
import javax.xml.bind.JAXBContext;  
import javax.xml.bind.Marshaller;  
import javax.xml.bind.Unmarshaller;  
import javax.xml.parsers.DocumentBuilderFactory;  
import javax.xml.soap.MessageFactory;  
import javax.xml.soap.SOAPMessage;  
import javax.xml.soap.SOAPPart;  
import javax.xml.transform.Transformer;  
import javax.xml.transform.TransformerFactory;  
import javax.xml.transform.dom.DOMSource;  
import javax.xml.transform.stream.StreamResult;  
import javax.xml.transform.stream.StreamSource;  
  
import org.w3c.dom.Document;  
  
import com.tanakanbb.sample.soap.SayHello;  
import com.tanakanbb.sample.soap.SayHelloResponse;  
  
public class JaxWSExecutor {  
  
 public static void main(String[] args) throws Exception {  
  
  DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();  
  dbf.setNamespaceAware(true);  
  Document doc = dbf.newDocumentBuilder().newDocument();  
  
  JAXBContext context = JAXBContext.newInstance(SayHello.class);  
  Marshaller marshaller = context.createMarshaller();  
  marshaller.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, Boolean.TRUE);  
  
  SayHello sayHello = new SayHello();  
  
  sayHello.setName("hoge");  
  
  marshaller.marshal(sayHello, doc);  
  
  // We now have a DOM tree which has been populated by JAX-B  
  MessageFactory factory = MessageFactory.newInstance();  
  SOAPMessage message = factory.createMessage();  
  message.getSOAPBody().addDocument(doc);  
  
  message.saveChanges();  
  
  ByteArrayOutputStream outputStream = new ByteArrayOutputStream();  
  
  message.writeTo(outputStream);  
  
  String xml = outputStream.toString("utf-8");  
  
  // <SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/"><SOAP-ENV:Header/><SOAP-ENV:Body><sayHello xmlns="http://soap.sample.tanakanbb.com"><name>hoge</name></sayHello></SOAP-ENV:Body></SOAP-ENV:Envelope>  
  System.out.println(xml);  
  try {  
   URL url = new URL(  
     "http://localhost:8084/soap_sample/services/Hello");  
  
   URLConnection con = url.openConnection();  
  
   // 送信するよ！指定  
   con.setDoOutput(true);  
  
   con.setRequestProperty("Content-Type", "application/soap+xml");  
   con.setRequestProperty("SoapAction", "");  
  
   // --------------------  
   // 送信する  
   // --------------------  
   OutputStreamWriter ow1 = new OutputStreamWriter(con  
     .getOutputStream());  
   BufferedWriter bw1 = new BufferedWriter(ow1);  
  
   // POSTの内容を書き出す  
   bw1.write(xml);  
  
   // クローズ  
   bw1.close();  
   ow1.close();  
  
   // --------------------  
   // 受信する  
   // --------------------  
   InputStreamReader ir1 = new InputStreamReader(con.getInputStream());  
   BufferedReader br1 = new BufferedReader(ir1);  
  
   ByteArrayOutputStream ba = new ByteArrayOutputStream();  
   // １行ずつ書き出す  
   int b;  
   while ((b = br1.read()) != -1) {  
    ba.write(b);  
   }  
  
   String response = ba.toString("utf-8");  
  
   // クローズ  
   br1.close();  
   ir1.close();  
   ba.close();  
  
   // <?xml version="1.0" encoding="UTF-8"?><soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"><soapenv:Body><sayHelloResponse xmlns="http://soap.sample.tanakanbb.com"><sayHelloReturn>Hello!, hoge</sayHelloReturn></sayHelloResponse></soapenv:Body></soapenv:Envelope>  
   System.out.println(response);  
  
   // Create SoapMessage  
   MessageFactory msgFactory = MessageFactory.newInstance();  
   SOAPMessage message2 = msgFactory.createMessage();  
   SOAPPart soapPart = message2.getSOAPPart();  
  
   // Load the SOAP text into a stream source  
   byte[] buffer = response.getBytes();  
   ByteArrayInputStream stream = new ByteArrayInputStream(buffer);  
   StreamSource source = new StreamSource(stream);  
  
   // Set contents of message  
   soapPart.setContent(source);  
  
   // -- DONE  
   // <?xml version="1.0" encoding="UTF-8"?><soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"><soapenv:Body><sayHelloResponse xmlns="http://soap.sample.tanakanbb.com"><sayHelloReturn>Hello!, hoge</sayHelloReturn></sayHelloResponse></soapenv:Body></soapenv:Envelope>  
   message2.writeTo(System.out);  
  
   System.out.println("");  
  
   org.w3c.dom.Node srcNode = message2.getSOAPPart().getEnvelope()  
     .getBody().getFirstChild();  
  
   StringWriter writer = new StringWriter();  
  
   Transformer transformer = TransformerFactory.newInstance()  
     .newTransformer();  
   transformer.transform(new DOMSource(srcNode), new StreamResult(  
     writer));  
  
   // <?xml version="1.0" encoding="UTF-8"?><sayHelloResponse xmlns="http://soap.sample.tanakanbb.com"><sayHelloReturn>Hello!, hoge</sayHelloReturn></sayHelloResponse>  
   System.out.println(writer.toString());  
  
   JAXBContext context2 = JAXBContext  
     .newInstance(SayHelloResponse.class);  
  
   Unmarshaller m = context2.createUnmarshaller();  
   Object obj = m.unmarshal(srcNode);  
   SayHelloResponse ret = (SayHelloResponse) obj;  
  
   // Hello!, hoge  
   System.out.println(ret.getSayHelloReturn());  
  
  } catch (Exception e) {  
   e.printStackTrace();  
  }  
  
 }  
}  
/**
 * 
 */
package jp.blogspot.tanakanbb;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.StringWriter;
import java.net.URL;
import java.net.URLConnection;

import javax.xml.bind.JAXBContext;
import javax.xml.bind.Marshaller;
import javax.xml.bind.Unmarshaller;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.soap.MessageFactory;
import javax.xml.soap.SOAPMessage;
import javax.xml.soap.SOAPPart;
import javax.xml.transform.Transformer;
import javax.xml.transform.TransformerFactory;
import javax.xml.transform.dom.DOMSource;
import javax.xml.transform.stream.StreamResult;
import javax.xml.transform.stream.StreamSource;

import org.w3c.dom.Document;

import com.tanakanbb.sample.soap.SayHello;
import com.tanakanbb.sample.soap.SayHelloResponse;

public class JaxWSExecutor {

 public static void main(String[] args) throws Exception {

  DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();
  dbf.setNamespaceAware(true);
  Document doc = dbf.newDocumentBuilder().newDocument();

  JAXBContext context = JAXBContext.newInstance(SayHello.class);
  Marshaller marshaller = context.createMarshaller();
  marshaller.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, Boolean.TRUE);

  SayHello sayHello = new SayHello();

  sayHello.setName("hoge");

  marshaller.marshal(sayHello, doc);

  // We now have a DOM tree which has been populated by JAX-B
  MessageFactory factory = MessageFactory.newInstance();
  SOAPMessage message = factory.createMessage();
  message.getSOAPBody().addDocument(doc);

  message.saveChanges();

  ByteArrayOutputStream outputStream = new ByteArrayOutputStream();

  message.writeTo(outputStream);

  String xml = outputStream.toString("utf-8");

  // <SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/"><SOAP-ENV:Header/><SOAP-ENV:Body><sayHello xmlns="http://soap.sample.tanakanbb.com"><name>hoge</name></sayHello></SOAP-ENV:Body></SOAP-ENV:Envelope>
  System.out.println(xml);
  try {
   URL url = new URL(
     "http://localhost:8084/soap_sample/services/Hello");

   URLConnection con = url.openConnection();

   // 送信するよ！指定
   con.setDoOutput(true);

   con.setRequestProperty("Content-Type", "application/soap+xml");
   con.setRequestProperty("SoapAction", "");

   // --------------------
   // 送信する
   // --------------------
   OutputStreamWriter ow1 = new OutputStreamWriter(con
     .getOutputStream());
   BufferedWriter bw1 = new BufferedWriter(ow1);

   // POSTの内容を書き出す
   bw1.write(xml);

   // クローズ
   bw1.close();
   ow1.close();

   // --------------------
   // 受信する
   // --------------------
   InputStreamReader ir1 = new InputStreamReader(con.getInputStream());
   BufferedReader br1 = new BufferedReader(ir1);

   ByteArrayOutputStream ba = new ByteArrayOutputStream();
   // １行ずつ書き出す
   int b;
   while ((b = br1.read()) != -1) {
    ba.write(b);
   }

   String response = ba.toString("utf-8");

   // クローズ
   br1.close();
   ir1.close();
   ba.close();

   // <?xml version="1.0" encoding="UTF-8"?><soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"><soapenv:Body><sayHelloResponse xmlns="http://soap.sample.tanakanbb.com"><sayHelloReturn>Hello!, hoge</sayHelloReturn></sayHelloResponse></soapenv:Body></soapenv:Envelope>
   System.out.println(response);

   // Create SoapMessage
   MessageFactory msgFactory = MessageFactory.newInstance();
   SOAPMessage message2 = msgFactory.createMessage();
   SOAPPart soapPart = message2.getSOAPPart();

   // Load the SOAP text into a stream source
   byte[] buffer = response.getBytes();
   ByteArrayInputStream stream = new ByteArrayInputStream(buffer);
   StreamSource source = new StreamSource(stream);

   // Set contents of message
   soapPart.setContent(source);

   // -- DONE
   // <?xml version="1.0" encoding="UTF-8"?><soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"><soapenv:Body><sayHelloResponse xmlns="http://soap.sample.tanakanbb.com"><sayHelloReturn>Hello!, hoge</sayHelloReturn></sayHelloResponse></soapenv:Body></soapenv:Envelope>
   message2.writeTo(System.out);

   System.out.println("");

   org.w3c.dom.Node srcNode = message2.getSOAPPart().getEnvelope()
     .getBody().getFirstChild();

   StringWriter writer = new StringWriter();

   Transformer transformer = TransformerFactory.newInstance()
     .newTransformer();
   transformer.transform(new DOMSource(srcNode), new StreamResult(
     writer));

   // <?xml version="1.0" encoding="UTF-8"?><sayHelloResponse xmlns="http://soap.sample.tanakanbb.com"><sayHelloReturn>Hello!, hoge</sayHelloReturn></sayHelloResponse>
   System.out.println(writer.toString());

   JAXBContext context2 = JAXBContext
     .newInstance(SayHelloResponse.class);

   Unmarshaller m = context2.createUnmarshaller();
   Object obj = m.unmarshal(srcNode);
   SayHelloResponse ret = (SayHelloResponse) obj;

   // Hello!, hoge
   System.out.println(ret.getSayHelloReturn());

  } catch (Exception e) {
   e.printStackTrace();
  }

 }
}
Play Keepaway

2012年5月18日金曜日

StringでSOAP通信

0 件のコメント:

コメントを投稿
