WEBSERVICE代码

XML：

<!--   ~ Licensed to the Apache Software Foundation (ASF) under one   ~ or more contributor license agreements. See the NOTICE file   ~ distributed with this work for additional information   ~ regarding copyright ownership. The ASF licenses this file   ~ to you under the Apache License, Version 2.0 (the   ~ "License"); you may not use this file except in compliance   ~ with the License. You may obtain a copy of the License at   ~   ~ http://www.apache.org/licenses/LICENSE-2.0   ~   ~ Unless required by applicable law or agreed to in writing,   ~ software distributed under the License is distributed on an   ~ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY   ~ KIND, either express or implied. See the License for the   ~ specific language governing permissions and limitations   ~ under the License.   -->

<service name="ReiKingCallService" scope="application">     <description>         ReiKing Call Service     </description>     <operation name="callService">         <messageReceiver class="org.apache.axis2.receivers.RawXMLINOutMessageReceiver"/>     </operation>     <parameter name="ServiceClass">umb.ws.service.ReiKingCallService</parameter> </service>

SERVER ：

package umb.ws.service;

import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.StringWriter; import java.net.MalformedURLException; import java.net.URL; import java.net.URLEncoder; import java.util.Hashtable; import java.util.Iterator;

import javax.xml.stream.FactoryConfigurationError; import javax.xml.stream.XMLOutputFactory; import javax.xml.stream.XMLStreamException;

import org.apache.axiom.om.OMAbstractFactory; import org.apache.axiom.om.OMElement; import org.apache.axiom.om.OMFactory; import org.apache.axiom.om.OMNamespace;

public class ReiKingCallService {

 private String namespace = "http://reiking.samples/xsd";  

private Hashtable values =  null;    

public OMElement callService(OMElement user) {   

user.build(); user.detach();

//  StringWriter writer = new StringWriter();

//  try {

//   user.serialize(XMLOutputFactory.newInstance()

//           .createXMLStreamWriter(writer));

//  } catch (XMLStreamException e1) {

  // TODO 自动生成 catch 块

//   e1.printStackTrace();

//  } catch (FactoryConfigurationError e1) {

// TODO 自动生成 catch 块

//   e1.printStackTrace();

//  }

//        writer.flush();

//        System.out.println(writer.toString());        

          values = new Hashtable();   

          Iterator list = user.getChildElements();  

          while(list.hasNext()) {   

           OMElement e = (OMElement) list.next();    

           System.out.println(e.getLocalName() + ": "+e.getText());   

           values.put(e.getLocalName(), e.getText());  

     }     

          String User = (String) values.get("User");                

          String password = (String) values.get("PWD");      

          String serverID = (String) values.get("ServerAppID");                

          String menuID = (String) values.get("MenuID");               

          String locator = (String) values.get("Locator");               

          String serviceType = (String) values.get("ServiceType");            

          String serviceID = (String) values.get("ServiceID");                

          String varID= (String) values.get("VarID");       

          String varValue= (String) values.get("VarValue");        

          String inputType = (String) values.get("InputType");        

          String inputContent = (String) values.get("InputContent");                    

          String res;        

        try        

        {          String tt="";         

              if ((varID !=null)&&(varID.length()>0)){            

                      varValue = URLEncoder.encode(new String(varValue.getBytes(), "iso-8859-1"), "iso-8859-1");   

                      tt += "&VarID=" + varID + "&VarValue=" + varValue;  

               }  

                if ((inputType !=null)&&(inputType.length()>0)) {       

                           inputContent = URLEncoder.encode(new String(inputContent.getBytes(), "iso-8859-1"), "iso-8859-1");     

                        tt += "&InputType=" + inputType + "&InputContent=" + inputContent;  

                }

                   String url = "http://localhost:7001/rkmanager/RKManager?";           

                   res = getXmlRtnContent(url                    

                         + "ProcessType=webservice.CallWebService&ServerAppID=" + serverID + "&MenuID=" + menuID + "&Locator=" + locator                          + "&ServiceType=" + serviceType + "&ServiceID=" + serviceID+ "&User=" + User + "&PWD=" + password      

                         + tt);   

          }       catch (Exception e)         {  

                  System.out.println(e.getMessage());            

                    res = "FAILED:" + e.getMessage();      

          }    

                  OMFactory fac = OMAbstractFactory.getOMFactory();       

                  OMNamespace omNs =   fac.createOMNamespace(namespace, "ns");       

                  OMElement method = fac.createOMElement("callServiceResponse", omNs);      

                  OMElement value = fac.createOMElement("return", omNs);    

                  value.addChild(fac.createOMText(value, res));    

                  method.addChild(value);      

                  return method;

       }    

                private String getXmlRtnContent(String url) throws Exception     {     

                     try   {

               //             System.out.println("URL:  " + url);      

                               URL pku = new URL(url);       

                               InputStreamReader inputStreamReader = new InputStreamReader(pku .openStream());        

                               BufferedReader in = new BufferedReader(inputStreamReader);

                               String inputLine;       

                               StringBuffer stringBuffer = new StringBuffer();   

                               while ((inputLine = in.readLine()) != null)             {                

                   //              System.out.println(inputLine);         

                                    stringBuffer = stringBuffer.append(inputLine);       

                                }            

                               in.close();     

                              return (stringBuffer.toString());      

                              }         catch (MalformedURLException ex)         {  

                                        System.out.println("exception in " + this.getClass().getName() + ": " + ex);         

                                        throw new Exception("error connect! ");  

                             }    catch (IOException ex)         {        

                              System.out.println("exception in " + this.getClass().getName() + ": " + ex);         

                              throw new Exception("error connect! ");    

                            }

                       }

                  }

CLIENT:

package umb.ws.client;

import java.io.StringWriter;

import javax.xml.stream.XMLOutputFactory;

import org.apache.axiom.om.OMElement;

import org.apache.axis2.Constants;

import org.apache.axis2.addressing.EndpointReference;

import org.apache.axis2.client.Options;

import org.apache.axis2.client.ServiceClient;

import umb.di.db.Row;

import umb.di.db.RowInfo;

import umb.di.db.RowSet;

import umb.di.value.ValueInfo;

import umb.di.value.ValueInterface;

import umb.di.value.ValueString;

public class AXIOMClient {  

    private static EndpointReference targetEPR =       

                   new EndpointReference(  "http://localhost:7001/rkwebservice/services/ReiKingCallService");

        public static void addRowInfo(RowSet rowSet) {  

                   RowInfo rowInfo = new RowInfo();  

                   ValueInfo vi;

                    for (int i=0; i<5; i++) {  

                           vi = new ValueInfo("No."+i, ValueInfo.VALUE_TYPE_STRING);

                               rowInfo.addValueInfo(vi);

                   }      rowSet.putRowInfo(rowInfo);  }

                   public static void addRows(RowSet rowSet) {  

                                 Row row = new Row();

                                 ValueInterface v;

                                 v = new ValueString("HQG");   

                                 row.addValue(v );  

                                v = new ValueString("北京"); 

                                row.addValue(v );

                                v = new ValueString("1000");  

                                row.addValue(v );

                                v = new ValueString("1970-07-31"); 

                                 row.addValue(v );

                                v = new ValueString("中科院"); 

                                row.addValue(v );  

                                rowSet.addRow(row);   

                                row = new Row();

                                v = new ValueString("wdx");

                                row.addValue(v );  

                                v = new ValueString("北京"); 

                                row.addValue(v );  

                                v = new ValueString("1000");  

                                row.addValue(v );

                                v = new ValueString("1971-01-31");

                                row.addValue(v );  

                                v = new ValueString("北京大学"); 

                                 row.addValue(v );  

                                rowSet.addRow(row);     

                                row = new Row();  

                               v = new ValueString("Hxy"); 

                               row.addValue(v );  

                                 v = new ValueString("北京");  

                                 row.addValue(v );  

                                 v = new ValueString("1000");  

                                  row.addValue(v );

                                 v = new ValueString("2004-11-11");

                                 row.addValue(v );   

                                  v = new ValueString("哈佛大学"); 

                                 row.addValue(v );  

                                  rowSet.addRow(row);

                        }

                         public static void main(String[] args) {        

                                   try {        

                                          Options options = new Options();          

                                           options.setTo(targetEPR);       

                                           options.setTransportInProtocol(Constants.TRANSPORT_HTTP);

                                           ServiceClient sender = new ServiceClient();    

                                            sender.setOptions(options);          

                                            OMElement sendInfo;    

                                            OMElement result;     

                                            StringWriter writer = new StringWriter();     

                                             String response;          

                                             sendInfo = RKWebServiceClientUtil.getCallService("admin", "reiking", "yy/dxserver", "WebService测试", "Process",

                                                              "App1ETLProcess", "yy_ue_pppp");                                    

                                              sendInfo.serialize(XMLOutputFactory.newInstance()            

                                                .createXMLStreamWriter(writer));        

                                              writer.flush();       

                                              System.out.println(writer.toString());           

                                              result = sender.sendReceive(sendInfo);

                                              response = result.getFirstElement().getText();      

                                             System.err.println("Call Web Service : " + response);                 

                                             RowSet rowSet = new RowSet(10000);   

                                              addRowInfo(rowSet);   

                                              addRows(rowSet);       

                                              sendInfo = RKWebServiceClientUtil.getCallServiceHasRowSetInput("admin", "reiking", "yy/dxserver", "WebService测试

                                               RowSet",         "DataProcess", "DataProcessService2", "RowSetToFile", rowSet);  

                                              writer = new StringWriter();      

                                              sendInfo.serialize(XMLOutputFactory.newInstance()            

                                                  .createXMLStreamWriter(writer));     

                                              writer.flush();      

                                             System.out.println(writer.toString());            

                                             result = sender.sendReceive(sendInfo);

                                             response = result.getFirstElement().getText();       

                                             System.err.println("Call Web Service : " + response);              

                                        } catch (Exception e) {           

                                               e.printStackTrace();      

                                        }  

                                 }   

                           }