java中调用web service接口（使用AXIS的CALL调用方式）

矫情吗；* 2022-05-03 00:26 250阅读 0赞

1.首先要把AXIS包里的jar文件放到java项目的lib目录下，这里用的是AXIS1\_4版本  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjg2ODYzOA_size_27_color_FFFFFF_t_70]  
2.在java代码中实现：远程调用路径以及设置参数  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjg2ODYzOA_size_27_color_FFFFFF_t_70 1]  
3.若接口提供的方法需要传递xml类型的参数，例如接口是这样的  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjg2ODYzOA_size_27_color_FFFFFF_t_70 2]  
实现代码 如下：

package test;
    
    import java.rmi.RemoteException;
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.Statement;
    
    import javax.xml.namespace.QName;
    import javax.xml.rpc.ParameterMode;
    import javax.xml.rpc.ServiceException;
    
    import org.apache.axis.client.Call;
    import org.apache.axis.client.Service;
    import org.apache.axis.encoding.XMLType;
    
    import util.DBUtil;
    import util.MySqlDBUtil;
    
    
    public class CopyOfOrgSt {
        private static Connection con = null;
        private static PreparedStatement pst = null;
        private static ResultSet rs = null;
        private static Connection mcon = null;
        private static PreparedStatement mpst = null;
        private static ResultSet mrs = null;
        
        public static void main(String[] args){
            CopyOfOrgSt orgst=new CopyOfOrgSt();
            orgst.seAndtr();
        }
        
        public String invokeRemoteFuc(String method,String param) {
            System.out.println(param);
              // 远程调用路径 
              String endpoint = "http://IP地址:端口号/*/*/*?wsdl";
              String result = "call failed!";
              Service service = new Service();
              Call call;
                     try {
                         call = (Call) service.createCall();
                         call.setTargetEndpointAddress(endpoint); 
                         //new QName的URL是要指向的命名空间的名称，这个URL地址在你的wsdl打开后可以看到的，
                         //上面有写着targetNamespace="http://*.*.*/",这个就是你的命名空间值了;
                         call.setOperationName(new QName("http://*.*.*/",method)); // 调用的方法名
                         // 设置参数名 :参数名 ,参数类型:String, 参数模式：'IN' or 'OUT'
                         call.addParameter("guid",XMLType.XSD_STRING,ParameterMode.IN);
                         call.setEncodingStyle("UTF-8");
                         call.setReturnType(XMLType.XSD_STRING);
                         result = (String) call.invoke(new Object[] {param});// 远程调用
                    } catch (ServiceException e) {
                         e.printStackTrace();
                    } catch (RemoteException e) {
                         e.printStackTrace();
                    }
                    return result;
        }
        
        public  void seAndtr() {
            con=DBUtil.getConnection();
            mcon=MySqlDBUtil.getConnection();
            String param="";
            String sql="select a.FKeyID,isnull(b.FKeyID,'-1') as PARENTORGID,a.FNo,a.FName from ORGMAIN a left join ORGMAIN b on cast(a.FParentID as nvarchar(50))=b.FNo";
            String msql="select * from org_organization where orgserial=?";
            try {//   更新/添加
                pst=con.prepareStatement(sql);
                mpst=mcon.prepareStatement(msql);
                rs=pst.executeQuery();
                if(rs!=null){
                    while(rs.next()){
                        param="<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"yes\"?>"+
                                  "<ORGANIZATION>"+
                                          "<Field ColName=\"guid\" Value=\""+rs.getString("FKeyID")+"\"></Field>"+
                                          "<Field ColName=\"parentOrgId\" Value=\""+rs.getString("PARENTORGID")+"\"></Field>"+
                                          "<Field ColName=\"orgName\" Value=\""+rs.getString("FName")+"\"></Field>"+
                                          "<Field ColName=\"orgCode\" Value=\""+rs.getString("FNo")+"\"></Field>"+
                                          //"<Field ColName=\"orgManagerEmpId\" Value=\""+rs.getString("FKeyID")+"\"></Field>"+
                                          //"<Field ColName=\"orgDescripte\" Value=\""+rs.getString("FKeyID")+"\"></Field>"+
                                  "</ORGANIZATION>";
                        String ppid=rs.getString("FNo");
                        System.out.println("======================================="+ppid);
                        mpst.setString(1,ppid);
                        mrs=mpst.executeQuery();
                        
                        if(mrs.next()){//有结果集，更新
                            String result=invokeRemoteFuc("updateOrganization",param);
                            System.out.println("更新结果："+result);
                        }else{//无结果集，新增
                            String result=invokeRemoteFuc("addOrganization",param);
                            System.out.println("新增结果："+result);
                        }
                    }
                }
                //删除
                String delsql="select orgserial from org_organization where orgserial not in (?) and guid is not null";
                mpst=mcon.prepareStatement(delsql);
                    String dpsql="select FNo from ORGMAIN";
                    Statement dpst=con.createStatement();
                    ResultSet dprs=dpst.executeQuery(dpsql);
                    String str="";
                    if(dprs!=null){//从中间库中查询所有的FNo
                        while(dprs.next()){
                            str=str.concat(","+dprs.getString("FNo"));//将所有FNo用","拼接
                            //str.append(","+dprs.getString("FNo"));//将所有FNo用","拼接
                        }
                        str=str.substring(1);
                        mpst.setString(1,str);//将字符串设置到最外层查询
                        mrs=mpst.executeQuery();//执行最外层查询
                        String delorgserial="";
                        if(mrs!=null){
                            while(mrs.next()){
                                delorgserial=delorgserial.concat(","+mrs.getString("orgserial"));//取得oa所有的需要删除的组织编号
                            }
                            delorgserial=delorgserial.substring(1);
                            System.out.println("---"+delorgserial);
                            //取得需要删除的记录的guid和组织名,orgparentorgid字段用来关联出parentOrgId
                            String selsql="select guid,orgname,orgserial,orgparentorgid from org_organization where orgserial=?";
                            mpst=mcon.prepareStatement(selsql);    
                            String[] strs=delorgserial.split(",");
                            for(int i=0;i<strs.length;i++){
                                mpst.setString(1,strs[i]);//遍历字符数组分别赋值到sql
                                mrs=mpst.executeQuery();//执行最外层查询
                                //用查询出来的guid作为parentOrgId
                                String selmsql="";
                                if(mrs.next()){
                                    int orgparentorgid=mrs.getInt("orgparentorgid");
                                    selmsql="select guid from org_organization where org_id="+orgparentorgid;
                                }
                                Statement selmst=mcon.createStatement();
                                ResultSet selmrs=selmst.executeQuery(selmsql);
                                String guid="";
                                if(selmrs.next()){
                                    guid=selmrs.getString("guid");
                                }
                                param="<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"yes\"?>"+
                                          "<ORGANIZATION>"+
                                                  "<Field ColName=\"guid\" Value=\""+mrs.getString("guid")+"\"></Field>"+
                                                  "<Field ColName=\"parentOrgId\" Value=\""+guid+"\"></Field>"+
                                                  "<Field ColName=\"orgName\" Value=\""+mrs.getString("orgname")+"\"></Field>"+
                                                  "<Field ColName=\"orgCode\" Value=\""+mrs.getString("orgserial")+"\"></Field>"+
                                                  //"<Field ColName=\"orgManagerEmpId\" Value=\""+rs.getString("FKeyID")+"\"></Field>"+
                                                  //"<Field ColName=\"orgDescripte\" Value=\""+rs.getString("FKeyID")+"\"></Field>"+
                                          "</ORGANIZATION>";
                                //执行删除操作
                                String result=invokeRemoteFuc("delOrganization",param);
                                System.out.println("删除结果："+result);
                                
                            }
                            
                        }else{
                            System.out.println("没有需要删除的数据");
                        }
                    }
                
                    
                rs.close();
                pst.close();
                con.close();
                mrs.close();
                mpst.close();
                mcon.close();
                
            }catch(Exception e){
                e.printStackTrace();
            }
        }
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjg2ODYzOA_size_27_color_FFFFFF_t_70]: /images/20220503/c39c888b19c741ad84e0a4c433dbae17.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjg2ODYzOA_size_27_color_FFFFFF_t_70 1]: /images/20220503/8d737db2855a482b811d864219acd8e7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjg2ODYzOA_size_27_color_FFFFFF_t_70 2]: /images/20220503/f5edb6de211e4d51bcad663ec0a6bcf7.png