第一种办法:下载apache cxf的包,使用wsdl2java工具生成java客户端,未能解决带验证的问题。
第二种方法:根据wsdl文件生成客户端,也没找到解决方法。
最后使用httpclient解决。
public class DynamicHttpclientCall {
private String namespace;
private String methodName;
private String wsdlLocation;
private String soapResponseData;
private String username;
private String password;
private String myWorkStation;
static int socketTimeout = 30000;// 请求超时时间
static int connectTimeout = 30000;// 传输超时时间
public DynamicHttpclientCall(String namespace, String methodName,
String wsdlLocation,String username,String password,String myWorkStation) {
this.namespace = namespace;
this.methodName = methodName;
this.wsdlLocation = wsdlLocation;
this.username = username;
this.password = password;
this.myWorkStation = myWorkStation;
}
public HttpClientContext createBasicAuthContext(HttpHost host,String username, String password) {
CredentialsProvider credsProvider = new BasicCredentialsProvider();
Credentials defaultCreds = new UsernamePasswordCredentials(username, password);
credsProvider.setCredentials(new AuthScope(host.getHostName(), host.getPort()), defaultCreds);
AuthCache authCache = new BasicAuthCache();
BasicScheme basicAuth = new BasicScheme();
authCache.put(host, basicAuth);
HttpClientContext context = HttpClientContext.create();
context.setCredentialsProvider(credsProvider);
context.setAuthCache(authCache);
return context;
}
public String invoke(Map<String, String> patameterMap) throws Exception {
//HttpHost host = new HttpHost("piprd.shandongair.com.cn",50000);
//HttpClientContext createBasicAuthContext = createBasicAuthContext(host,username,password);
HttpPost postMethod = new HttpPost(wsdlLocation);
postMethod.setHeader("Content-type", "application/soap+xml; charset=utf-8");
// HttpRequest postMethod = new HttpRequest(wsdlLocation);
String soapRequestData = buildRequestData(patameterMap);
// byte[] bytes = soapRequestData.getBytes("utf-8");
// InputStream inputStream = new ByteArrayInputStream(bytes, 0,bytes.length);
// RequestEntity requestEntity = new InputStreamRequestEntity(inputStream, bytes.length, "application/soap+xml; charset=utf-8");
// postMethod.setRequestEntity(requestEntity);
postMethod.setEntity(new StringEntity(soapRequestData));
HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();
// // 设置BasicAuth
CredentialsProvider provider = new BasicCredentialsProvider();
// // Create the authentication scope
AuthScope scope = new AuthScope(AuthScope.ANY_HOST, AuthScope.ANY_PORT, AuthScope.ANY_REALM);
// // Create credential pair,在此处填写用户名和密码
UsernamePasswordCredentials credentials = new UsernamePasswordCredentials(username, password);
// // Inject the credentials
provider.setCredentials(scope, credentials);
// // Set the default credentials provider
httpClientBuilder.setDefaultCredentialsProvider(provider);
// // HttpClient
CloseableHttpClient closeableHttpClient = httpClientBuilder.build();
// httpClient.getParams().setParameter(HttpProtocolParams.HTTP_CONTENT_CHARSET, "utf-8");
// NTCredentials creds = new NTCredentials(username,password,myWorkStation,"");
CloseableHttpResponse execute = closeableHttpClient.execute(postMethod);
int statusCode = execute.getStatusLine().getStatusCode();
String text = IOUtils.toString(execute.getEntity().getContent(), "utf-8");
return text;
}
// public int invoke(Map<String, String> patameterMap) throws Exception {
// PostMethod postMethod = new PostMethod(wsdlLocation);
// String soapRequestData = buildRequestData(patameterMap);
//
// byte[] bytes = soapRequestData.getBytes("utf-8");
// InputStream inputStream = new ByteArrayInputStream(bytes, 0,bytes.length);
// RequestEntity requestEntity = new InputStreamRequestEntity(inputStream, bytes.length, "application/soap+xml; charset=utf-8");
// postMethod.setRequestEntity(requestEntity);
//
//// HttpClient httpClient = new HttpClient();
// // 创建HttpClientBuilder
// HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();
//// // 设置BasicAuth
// CredentialsProvider provider = new BasicCredentialsProvider();
//// // Create the authentication scope
// AuthScope scope = new AuthScope(AuthScope.ANY_HOST, AuthScope.ANY_PORT, AuthScope.ANY_REALM);
//// // Create credential pair,在此处填写用户名和密码
// UsernamePasswordCredentials credentials = new UsernamePasswordCredentials(username, password);
//// // Inject the credentials
// provider.setCredentials(scope, credentials);
//// // Set the default credentials provider
// httpClientBuilder.setDefaultCredentialsProvider(provider);
//// // HttpClient
// CloseableHttpClient closeableHttpClient = httpClientBuilder.build();
//
//// httpClient.getParams().setParameter(HttpProtocolParams.HTTP_CONTENT_CHARSET, "utf-8");
//// NTCredentials creds = new NTCredentials(username,password,myWorkStation,"");
//
//
//
// int statusCode = httpClient.executeMethod(postMethod);
// soapResponseData = postMethod.getResponseBodyAsString();
// return statusCode;
// }
private String buildRequestData(Map<String, String> patameterMap) {
StringBuffer soapRequestData = new StringBuffer();
soapRequestData.append("<soapenv:Envelope xmlns:soapenv=/"http://schemas.xmlsoap.org/soap/envelope//" xmlns:com=/"com:sda:querydata/"><soapenv:Header/>");
soapRequestData.append("<soapenv:Body><com:MT_DD_Request><MSGRP></MSGRP></com:MT_DD_Request></soapenv:Body></soapenv:Envelope>");
// Set<String> nameSet = patameterMap.keySet();
// for (String name : nameSet) {
// soapRequestData.append("<" + name + ">" + patameterMap.get(name)+ "</" + name + ">");
// }
return soapRequestData.toString();
}
}
原创文章,作者:kepupublish,如若转载,请注明出处:https://blog.ytso.com/tech/opensource/191847.html