axis2 webservice学习笔记三

soap协议 1 客户端与服务端使用soap进行通信 示例代码： service端: /** ?* 使用soap协议进行通信 ?*? ?* @time 下午7:40:34 ?* @author retacn yue ?* @Email zhenhuayue@sina.com ?*/ public class SoapService { public static OMElement requestSoap = null; public OMElement request(OMElement soapBody) { requestSoap = soapBody; Iterator it = requestSoap.getChildElements(); OMElement issuerElement = (OMElement) it.next(); OMElement serialElement = (OMElement) it.next(); OMElement revocationDateElement = (OMElement) it.next(); String issuer = issuerElement.getText(); String serial = serialElement.getText(); String revocationDate = revocationDateElement.getText(); System.out.println("issuer=" + issuer + "n serial=" + serial +? "revocationDate=" + revocationDate); OMFactory factory = OMAbstractFactory.getOMFactory(); OMNamespace namespace = factory.createOMNamespace ("http://soapstyle.axis2service.yue.cn",""); OMElement soapResponse = factory.createOMElement("SoapResponse",? namespace); OMElement soaplssuer = factory.createOMElement("Issuer",namespace); soaplssuer.setText("issuer:" + issuer); soapResponse.addChild(soaplssuer); OMElement soapSerial = factory.createOMElement("Serial",namespace); soapSerial.setText("serial:" + serial); soapResponse.addChild(soapSerial); OMElement soapRevokeDate = factory.createOMElement("RevocationDate",? namespace); soapRevokeDate.setText("RevocationDate" + revocationDate); soapResponse.addChild(soapRevokeDate); soapResponse.build(); return soapResponse; } } <service name="SoapService" > ? ? <description> ? ? ? ? revoking certificate. ? ? </description> ? ?? ? ? <parameter name="ServiceClass"? locked="false">cn.yue.axis2service.soapstyle.SoapService</parameter> ? ? <operation name="request"> ? ? <messageReceiver? ? ? ? ? ? ? class="org.apache.axis2.receivers.RawXMLINOutMessageReceiver"/> ? ? <actionMapping>urn:request</actionMapping> ? ? </operation> </service> 客户端 /** ?* soap协议通信客户端 ?*? ?* 非阻塞(异步)全双工 ?*? ?* @time 下午4:04:55 ?* @author retacn yue ?* @Email zhenhuayue@sina.com ?*/ public class SoapServiceDualNonBlock { private static EndpointReference endpointReference = new EndpointReference ("http://localhost:8089/services/SoapService"); private static boolean finish = false; public void request() { OMFactory factory = OMAbstractFactory.getOMFactory(); OMNamespace namespace = factory.createOMNamespace ("http://soapstyle.axis2service.yue.cn",""); OMElement issuer = factory.createOMElement("Issuer",namespace); OMElement serial = factory.createOMElement("Serial",namespace); OMElement revocationDate = factory.createOMElement("RevocationDate",? namespace); issuer.setText("yuezhenhua"); serial.setText("1234567"); revocationDate.setText("2012-11-21"); OMElement requestSoapMessage = factory.createOMElement("request",? namespace); requestSoapMessage.addChild(issuer); requestSoapMessage.addChild(serial); requestSoapMessage.addChild(revocationDate); requestSoapMessage.build(); Options options = new Options(); options.setTo(endpointReference); ServiceClient sender = null; try { AxisCallback callback = new AxisCallback() { @Override public void onMessage(MessageContext msgContext) { OMElement result = msgContext.getEnvelope ().getBody().getFirstElement(); System.out.println("result:" + result); finish = true; } @Override public void onFault(MessageContext msgContext) { System.out.println("onFault=" +? msgContext.getEnvelope().getBody().getFault().toString()); } @Override public void onError(Exception e) { e.printStackTrace(); } @Override public void onComplete() { System.out.println("onComplete"); } }; sender = new ServiceClient(); sender.setOptions(options); System.out.println("=======invoke the service==="); sender.sendReceiveNonBlocking(requestSoapMessage,callback); synchronized (callback) { if (!finish) { try { callback.wait(1000); } catch (InterruptedException e1) { e1.printStackTrace(); } } if (!finish) { throw new AxisFault("Server was shutdown as? the async response take too long to complete"); } } } catch (AxisFault e1) { e1.printStackTrace(); } finally { if (null != sender) { try { sender.cleanup(); } catch (AxisFault e) { e.printStackTrace(); } } } } public static void main(String[] args) { SoapServiceDualNonBlock client = new SoapServiceDualNonBlock(); client.request(); } } 2 服务端将exception以soapFault的形式抛给客户端 /** ?* 将exception以soapfault形式抛给客户端 ?*? ?* @time 下午9:00:52 ?* @author retacn yue ?* @Email zhenhuayue@sina.com ?*/ public class SoapFaultService { private int i = 0; public OMElement getPrice(OMElement request) throws AxisFault { if (null == request) { SOAPFault fault = getSoapFault(); return fault; } OMFactory factory = OMAbstractFactory.getOMFactory(); OMNamespace namespace = factory.createOMNamespace ("http://soapstyle.axis2service.yue.cn",""); OMElement response = factory.createOMElement("Price",namespace); response.setText(String.valueOf(i++)); return response; } private SOAPFault getSoapFault() { MessageContext context = MessageContext.getCurrentMessageContext(); SOAPFactory factory = null; if (context.isSOAP11()) { factory = OMAbstractFactory.getSOAP11Factory(); } else { factory = OMAbstractFactory.getSOAP12Factory(); } SOAPFault fault = factory.createSOAPFault(); SOAPFaultCode faultCode = factory.createSOAPFaultCode(fault); faultCode.setText("13"); factory.createSOAPFaultValue(faultCode); SOAPFaultReason faultReason = factory.createSOAPFaultReason(fault); faultReason.setText("request can not be null!"); factory.createSOAPFaultText(faultReason); factory.createSOAPFaultDetail(fault); return fault; } } <service name="SoapFaultService" > ? ? <description> ? ? ? ? revoking certificate. ? ? </description> ? ?? ? ? <parameter name="ServiceClass"? locked="false">cn.yue.axis2service.soapstyle.SoapFaultService</parameter> ? ? <operation name="getPrice"> ? ? <messageReceiver? ? ? ? ? ? ? class="org.apache.axis2.receivers.RawXMLINOutMessageReceiver"/> ? ? <actionMapping>urn:getPrice</actionMapping> ? ? </operation> </service> 客户端 /** ?* 客户端接收从服务器端传来的以soapfault形式的exception ?*? ?* 非阻塞(异步)全双工 ?*? ?* @time 下午4:04:55 ?* @author retacn yue ?* @Email zhenhuayue@sina.com ?*/ public class SoapFaultServiceDualNonBlock { private static EndpointReference endpointReference = new EndpointReference ("http://localhost:8089/services/SoapFaultService"); private static boolean finish = false; ServiceClient sender = null; public void getPrice() { try { OMFactory factory = OMAbstractFactory.getOMFactory(); OMNamespace namespace = factory.createOMNamespace ("http://soapstyle.axis2service.yue.cn",""); // OMElement request = factory.createOMElement("Price",? namespace); Options options = new Options(); options.setTo(endpointReference); options.setAction("urn:getPrice"); options.setTransportInProtocol(Constants.TRANSPORT_HTTP); options.setUseSeparateListener(true); AxisCallback callback = new AxisCallback() { @Override public void onMessage(MessageContext msgContext) { OMElement result = msgContext.getEnvelope ().getBody().getFirstElement(); System.out.println("price:" + result); finish = true; } // 用于接收服务端抛过来的exception @Override public void onFault(MessageContext msgContext) { QName errorCode = new QName("faultcode"); QName reason = new QName("faultString"); OMElement faultElement =? msgContext.getEnvelope().getBody().getFault(); System.out.println("ErrorCode[" +? faultElement.getFirstChildWithName(errorCode).getText() + "] caused by:" +? faultElement.getFirstChildWithName(reason).getText()); } @Override public void onError(Exception e) { e.printStackTrace(); } @Override public void onComplete() { System.out.println("onComplete"); } }; sender = new ServiceClient(); sender.setOptions(options); sender.engageModule("addressing"); try { sender.sendReceiveNonBlocking(null,callback); } catch (Exception e2) { e2.printStackTrace(); System.out.println(e2.getMessage()); } synchronized (callback) { if (!finish) { try { callback.wait(1000); } catch (InterruptedException e1) { e1.printStackTrace(); } } } } catch (AxisFault e) { e.printStackTrace(); } finally { try { sender.cleanup(); } catch (AxisFault e) { e.printStackTrace(); } } } public static void main(String[] args) { SoapFaultServiceDualNonBlock client = new? SoapFaultServiceDualNonBlock(); client.getPrice(); } } 3 使用swa（soap with attachment）来进行附件的传送 axis2有两种附件传输形式 ?mtom ?swa ?soap with attachment ?客户端把要上传的文件，转成二进制码由soap的request一起发送到服务器端(attchmentID) /** ?* 接收客户端上传文件 ?*? ?* @time 下午7:47:34 ?* @author retacn yue ?* @Email zhenhuayue@sina.com ?*/ public class FileUploadService { public String uploadFile(String name,String attchmentID) { FileOutputStream fileOutputStream = null; StringBuffer uploadFilePath = new StringBuffer(); String fileNamePrefix = ""; String fileName = ""; try { MessageContext context =? MessageContext.getCurrentMessageContext(); Attachments attachments = context.getAttachmentMap(); DataHandler dataHandler = attachments.getDataHandler (attchmentID); fileNamePrefix = name.substring(name.indexOf("."),? name.length()); fileName = "11"; System.out.println("fileName:" + fileName); System.out.println("fileNamePrefix:" + fileNamePrefix); uploadFilePath.append("d:/"); uploadFilePath.append(fileName); uploadFilePath.append(fileNamePrefix); System.out.println("uploadFilePath:" + uploadFilePath); File file = new File(uploadFilePath.toString()); fileOutputStream = new FileOutputStream(file); dataHandler.writeTo(fileOutputStream); fileOutputStream.flush(); } catch (IOException e) { e.printStackTrace(); } finally { try { if (null != fileOutputStream) { fileOutputStream.close(); } fileOutputStream = null; } catch (IOException e) { e.printStackTrace(); } } return "success"; } } <service name="FileUploadService" > ? ? <parameter name="ServiceClass"? locked="false">cn.yue.axis2service.fileupload.FileUploadService</parameter> ? ? <operation name="uploadFile"> ? ?<messageReceiver? ? ? ? ? ? ?class="org.apache.axis2.rpc.receivers.RPCMessageReceiver"/> ? ?<actionMapping>urn:uploadFile</actionMapping> ? ? </operation> </service> 客户端 /** ?* 上传文件 ?*? ?* @time 下午8:07:05 ?* @author retacn yue ?* @Email zhenhuayue@sina.com ?*/ public class FileUploadClient { private static EndpointReference reference = new EndpointReference ("http://localhost:8089/services/FileUploadService"); public void uploadFile() { try { String filePath = "d:/AppCan/xizan.jpg"; String destFile = "xizan.jpg"; Options options = new Options(); options.setTo(reference); options.setProperty(Constants.Configuration.ENABLE_SWA,? Constants.VALUE_TRUE); options.setSoapVersionURI (SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI); options.setTimeOutInMilliSeconds(10000); options.setAction("urn:uploadFile"); ConfigurationContext context =? ConfigurationContextFactory.createConfigurationContextFromFileSystem ("D:/workspace4/axis2webservice/WebContent/WEB-INF/modules",null); ServiceClient sender = new ServiceClient(context,null); OperationClient mepClient = sender.createClient (ServiceClient.ANON_OUT_IN_OP); MessageContext messageContext = new MessageContext(); FileDataSource fileDataSource = new FileDataSource(new File (filePath)); DataHandler handler = new DataHandler(fileDataSource); String attachmentID = messageContext.addAttachment(handler); SOAPFactory factory = OMAbstractFactory.getSOAP11Factory(); SOAPEnvelope envelope = factory.getDefaultEnvelope(); OMNamespace namespace = factory.createOMNamespace ("http://fileupload.axis2service.yue.cn",""); OMElement uploadFile = factory.createOMElement("uploadFile",? namespace); OMElement nameEle = factory.createOMElement("name",? namespace); nameEle.setText(destFile); OMElement idEle = factory.createOMElement("attchmentID",? namespace); idEle.setText(attachmentID); uploadFile.addChild(nameEle); uploadFile.addChild(idEle); envelope.getBody().addChild(uploadFile); System.out.println("message==" + envelope); messageContext.setEnvelope(envelope); mepClient.addMessageContext(messageContext); mepClient.execute(true); MessageContext response = mepClient.getMessageContext (WSDLConstants.MESSAGE_LABEL_IN_VALUE); SOAPBody body = response.getEnvelope().getBody(); OMElement element = body.getFirstChildWithName(new QName ("http://fileupload.axis2service.yue.cn","return")); System.out.println(element.getText()); } catch (AxisFault e) { e.printStackTrace(); } } public static void main(String[] args) { FileUploadClient client = new FileUploadClient(); client.uploadFile(); } }