CXF动态客户端调用WebService

public class CxfApp {

    private static Map<Object, Endpoint> factoryMap = new HashMap<>();
    private static Map<Object, Client> clientMap = new HashMap<>();

    public static void main(String[] args) {
        Gson gson = new Gson();
        SysCategoryWbSReq sysCategoryWbSReq = new SysCategoryWbSReq();
        sysCategoryWbSReq.setCategoryName("test20190920");
        sysCategoryWbSReq.setCategoryCode("ML0025");
        sysCategoryWbSReq.setEnabledFlag(1);
        List<Object> paramList = new ArrayList<>();
        paramList.add(gson.toJson(sysCategoryWbSReq));
        String result = dynamicCallWebServiceByCXF("http://127.0.0.1:9095/application/applicationWBS/addAndUpdateSyscategory?wsdl",
                "addAndUpdateSyscategory",
                "http://applicationWBS.expense.app.hcf.hand.com","ApplicationWbService",paramList);
        System.out.println(result);
    }

    /**
     *
     * @param wsdlUrl  wsdl的地址：http://localhost:8001/demo/HelloServiceDemoUrl?wsdl
     * @param methodName 调用的方法名称 selectOrderInfo
     * @param targetNamespace 命名空间 http://service.limp.com/
     * @param name  name HelloServiceDemo
     * @param paramList 参数集合
     * @throws Exception
     */
    public  static String dynamicCallWebServiceByCXF(String wsdlUrl, String methodName, String targetNamespace, String name, List<Object> paramList){
        //临时增加缓存，增加创建速度
        if(!factoryMap.containsKey(methodName)){
            // 创建动态客户端
            JaxWsDynamicClientFactory factory = JaxWsDynamicClientFactory.newInstance();
            // 创建客户端连接
            Client client = factory.createClient(wsdlUrl);
            ClientImpl clientImpl = (ClientImpl) client;
            Endpoint endpoint = clientImpl.getEndpoint();
            factoryMap.put(methodName,endpoint);
            clientMap.put(methodName,client);
            System.out.println("初始化");
        }
        //从缓存中换取 endpoint、client
        Endpoint endpoint=factoryMap.get(methodName);
        Client client=clientMap.get(methodName);
        // Make use of CXF service model to introspect the existing WSDL
        ServiceInfo serviceInfo = endpoint.getService().getServiceInfos().get(0);
        // 创建QName来指定NameSpace和要调用的service
        String localPart=name+"SoapBinding";
        QName bindingName = new QName(targetNamespace, localPart);
        BindingInfo binding = serviceInfo.getBinding(bindingName);

        //创建QName来指定NameSpace和要调用的方法绑定方法
        QName opName = new QName(targetNamespace, methodName);//selectOrderInfo

        BindingOperationInfo boi = binding.getOperation(opName);
//		BindingMessageInfo inputMessageInfo = boi.getInput();
        BindingMessageInfo inputMessageInfo = null;
        if (!boi.isUnwrapped()) {
            //OrderProcess uses document literal wrapped style.
            inputMessageInfo = boi.getWrappedOperation().getInput();
        } else {
            inputMessageInfo = boi.getUnwrappedOperation().getInput();
        }

        List<MessagePartInfo> parts = inputMessageInfo.getMessageParts();

        /***********************以下是初始化参数，组装参数；处理返回结果的过程******************************************/
        Object[] parameters = new Object[parts.size()];
        for(int m=0;m<parts.size();m++){
            MessagePartInfo  part=parts.get(m);
            // 取得对象实例
            Class<?> partClass = part.getTypeClass();//OrderInfo.class;
            System.out.println(partClass.getCanonicalName()); // GetAgentDetails
            //实例化对象
            Object initDomain=null;
            //普通参数的形参，不需要fastJson转换直接赋值即可
            if("java.lang.String".equalsIgnoreCase(partClass.getCanonicalName())
                    ||"int".equalsIgnoreCase(partClass.getCanonicalName())){
                initDomain=paramList.get(m).toString();
            }
            //如果是数组
            else if(partClass.getCanonicalName().indexOf("[]")>-1){
                //转换数组
                initDomain= JSON.parseArray(paramList.get(m).toString(),partClass.getComponentType());
            }else{
                initDomain=JSON.parseObject(paramList.get(m).toString(),partClass);
            }
            parameters[m]=initDomain;

        }
        //定义返回结果集
        Object[] result=null;
        //普通参数情况 || 对象参数情况  1个参数 ||ArryList集合
        try {
            result = client.invoke(opName,parameters);
        }catch (Exception ex){
            ex.printStackTrace();
            return "参数异常"+ex.getMessage();
        }
        //返回调用结果
        if(result.length>0){
            return  JSON.toJSON(result[0]).toString();
        }
        return  "invoke success, but is void ";
    }
}