一.通过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];
}
参考:https://blog.csdn.net/lichuangcsdn/article/details/83053327