一.通过cxf JaxWsDynamicClientFactory进行WebService 客户端调用

  代码:在项目中从非项目内的接口获取数据

    public Object hospitalApiResponse(String paramXml,String subHospitalID){
        //打印 入参 xml
        logger.info(">>>>>>>>>>>>调用web Service服务接口入参为:"+paramXml+"<<<<<<<<<<<<<");
        //创建客户端
        JaxWsDynamicClientFactory dcf =JaxWsDynamicClientFactory.newInstance();
        //通过缓存获取url
        Object wsdlUrlObj = ConcurrentHashMapCacheUtils.getCache(subHospitalID);
        if (wsdlUrlObj == null) {
            //如果缓存中没有存值,则清空所有缓存,从数据中重新查出来放入缓存中
            ConcurrentHashMapCacheUtils.clear();
            List<HospitalList> hospitalList = appService.findHospitalList();
            for (HospitalList hos : hospitalList) {
                //设置缓存参数
                ConcurrentHashMapCacheUtils.setCache(hos.getHospitalId(), hos.getWsUrl());
            }
        }
        Object wsdlUrlNew = ConcurrentHashMapCacheUtils.getCache(subHospitalID);
        //如果数据库中也没有就返回 null
        if(wsdlUrlNew == null){
            logger.info(">>>>>>>>>>>>调用web Service服务接口地址不正确<<<<<<<<<<<<<");
            return "服务接口地址异常";
        }
        String wsdlUrl =wsdlUrlNew .toString();
        logger.info(">>>>>>>>>>>>调用web Service服务接口地址为:"+wsdlUrl+"<<<<<<<<<<<<<");
        //固定 wsdl url配置
//        String wsdlUrl = hisIdTransitionWsdlUrl(subHospitalID);
        Client client = dcf.createClient(wsdlUrl);
        //定义operationID
        String operationID = WjwConstant.HOSPITAL_FUNTION_STR;
        //接 返回结果值
        Object[] response = new Object[0];
        try {
            //operationID对应方法 ,待后续对接认证
            response = client.invoke(operationID,paramXml);
        } catch (Exception e) {
            logger.error("调用医院接口异常", e);
            e.printStackTrace();
        }
        logger.info(">>>>>>>>>>>>调用web Service服务接口返回结果为:"+response[0]+"<<<<<<<<<<<<<");
            return response[0];
    }
public Object hospitalApiResponse(String paramXml,String subHospitalID)

  参考:https://blog.csdn.net/lichuangcsdn/article/details/83053327

12-26 06:44
查看更多