大家好，又见面了，我是你们的朋友全栈君。
WebServiceUtils 工具类
package xxxx;
import java.util.ResourceBundle;
import org.apache.cxf.endpoint.Client;
import org.apache.cxf.frontend.ClientProxy;
import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;
import org.apache.cxf.transport.http.HTTPConduit;
import org.apache.cxf.transports.http.configuration.HTTPClientPolicy;
import org.springframework.stereotype.Service;
@Service
public class WebServiceUtils {
public static final int CXF_CLIENT_CONNECT_TIMEOUT = 30 * 1000;
public static final int CXF_CLIENT_RECEIVE_TIMEOUT = 30 * 1000;
/**
*
* @param clazz
* @param paraName
* @param timeout
* @return
*/
public <T> T getWebService(Class<T> clazz, String paraName, Integer... timeout) {
ResourceBundle dBResources = ResourceBundle.getBundle("application-config");
String url = dBResources.getString(paraName);
if (timeout == null || timeout.length == 0) {
return getWebServiceByUrl(clazz, url);
} else if (timeout.length == 1) {
return getWebServiceByUrl(clazz, url, timeout[0], timeout[0]);
} else {
return getWebServiceByUrl(clazz, url, timeout[0], timeout[1]);
}
}
public <T> T getWebServiceByUrl(Class<T> clazz, String url) {
return getWebServiceByUrl(clazz, url, CXF_CLIENT_CONNECT_TIMEOUT, CXF_CLIENT_RECEIVE_TIMEOUT);
}
private <T> T getWebServiceByUrl(Class<T> clazz, String url, Integer connetTimeout, Integer receiveTimeout) {
// 用于创建JAX-WS代理的工厂，此类提供对用于设置代理的内部属性的访问。使用它可以提供比标准JAX-WS API更多的控制。
JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
factory.setServiceClass(clazz);
factory.setAddress(url);
@SuppressWarnings("unchecked")
// 创建可用于进行远程调用的代理对象。
T webService = (T) factory.create();
// 设置接口 连接超时和请求超时
// 通过代理对象获取本地客户端
Client proxy = ClientProxy.getClient(webService);
// 通过本地客户端设置 网络策略配置
HTTPConduit conduit = (HTTPConduit) proxy.getConduit();
// 用于配置客户端HTTP端口的属性
HTTPClientPolicy policy = new HTTPClientPolicy();
// 超时控制 单位 : 毫秒
policy.setConnectionTimeout(connetTimeout);
policy.setReceiveTimeout(receiveTimeout);
conduit.setClient(policy);
return webService;
}
}
实际调用示例
String jsonoInfo = null;
try {
jsonInfo = webServiceUtil.getWebService(GjxxWebService.class,
"webService_url").gjglAccountqueryPersonFuzzyWs(zjhm, idType, pageNo, pageSize);
} catch (WebServiceException se) {
xxxxxxx....
}
各参数名称等分析:
| 名称 | 描述 |
|---|---|
| GjxxWebService | 通过wsdl 生成的接口 |
| webService_url | 接口的url地址 |
| gjglAccountqueryPersonFuzzyWs | 接口中的某个方法 |
| zjhm, idType, pageNo, pageSize | 调用该接口所需要的参数 |
| jsonInfo | 调用该接口的返回值,据接口具体而定 |
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请联系我们举报，一经查实，本站将立刻删除。
发布者：全栈程序员-站长，转载请注明出处：https://javaforall.net/162672.html原文链接：https://javaforall.net
