简单实⽤java调⽤WSDL接⼝,并解析返回数据格式
最近因为⼀些数据问题,需要跟第三⽅对接数据,OK!要联系⽅式,联系上了,然后⼈家就给我⼀个⽂档,说所有东西上⾯都有.....,没办法只能⾃⼰慢慢琢磨了!
然后发现他们是WSDL的⽅式调⽤的,百度了⼀下,WSDL是基于 XML 的⽤于描述 Web Services 以及如何访问 Web Services 的语⾔,以前只是知道有这么各东西,但是从来没⽤过,只能研究⼀下怎么搞了!以下只是我个⼈研究得⼀点点浅见哈,只是为了以后复习使⽤,有什么问题请各位指出哈!
⼀般拿到WSDL的接⼝⽂档以后,先得看下接⼝地址能不能调通,就是直接把接⼝地址放在浏览器⾥⾯看下能不能放⽂档xml⽂档内容。能访问到以后,就是要学会怎么看xml⾥⾯的内容了。
这个⽂档内容看起来很多,刚开始看的时候⼀头雾⽔,然后就是百度百度再百度,这⾥就直接说怎么⽤吧,感觉这⾥⾯有⽤的就最上⾯的xmlns对应的那⼀串地址以及<wsdl:types>⾥⾯的东西了,可以看到<wsdl:types>的<xs:element>⾥⾯有个name,这个就是对应的可以这个接⼝下⾯可以调⽤的⽅法了,sequence⾥⾯就是需要传⼊的参数。下⾯是java具体调⽤的代码
h.car.util;
import org.dom4j.Document;
import org.dom4j.DocumentException;
import org.dom4j.DocumentHelper;
import java.io.BufferedReader;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.HttpURLConnection;
import java.URL;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import org.dom4j.Document;
import org.dom4j.DocumentException;
import org.dom4j.DocumentHelper;
import org.dom4j.Element;
import javax.annotation.Resource;
public class GetEquipMsgUtils {
public static void main(String[] args) throws IOException {
//第⼀步:创建服务地址,也就是提供的WSDL的接⼝地址
URL url = new URL("xxxxxxxxxxxxxxxx/xxxx/xxxxxxxxx?wsdl");
//第⼆步:打开⼀个通向服务地址的连接
HttpURLConnection connection = (HttpURLConnection) url.openConnection(); //第三步:设置参数
//3.1发送⽅式设置:POST必须⼤写
connection.setRequestMethod("POST");
//3.2设置数据格式:content-type
connection.setRequestProperty("Content-Type", "text/xml;charset=UTF-8"); //3.3设置输⼊输出,因为默认新创建的connection没有读写权限,
connection.setDoInput(true);
connection.setDoOutput(true);
//第四步:组织SOAP数据,发送请求,
String soapXML = getXML(⽅法名,参数1,参数2);
//将信息以流的⽅式发送出去
OutputStream os = OutputStream();
os.Bytes());
//第五步:接收服务端响应,打印
int responseCode = ResponseCode();
if(200 == responseCode){//表⽰服务端响应成功
//获取当前连接请求返回的数据流
InputStream is = InputStream();
InputStreamReader isr = new InputStreamReader(is);
BufferedReader br = new BufferedReader(isr);
StringBuilder sb = new StringBuilder();
String temp = null;
while(null != (temp = br.readLine())){
sb.append(temp);
}
/
**
* 打印结果
*/
System.out.println("---"+sb.toString());
try{
//对返回的数据进⾏JSON格式化
System.out.println(String()));
System.out.println(String()));
}catch (Exception e){
e.printStackTrace();
}
is.close();
isr.close();
br.close();
}
os.close();
}
//请求⼊参
public static String getXML(String method,int begin,int end){
String soapXML = "<soapenv:Envelope xmlns:soapenv=\"/soap/envelope/\" xmlns:tns=\"guizhou.scue\">" +"<soapenv:Header></soapenv:Header> "
+"<soapenv:Body> "
+"<tns:"+method+"> "//⽅法名
+"<tns:offset>"+begin+"</tns:offset>"//参数1
+"<tns:row_count>"+end+"</tns:row_count>"//参数2
+"</tns:"+method+">"
+"</soapenv:Body>"
+"</soapenv:Envelope>";
return soapXML;
}
/**
* xml转json
*
* @param xmlStr
* @return
* @throws DocumentException
*/
public static JSONObject xml2Json(String xmlStr) throws DocumentException {
Document doc = DocumentHelper.parseText(xmlStr);
JSONObject json = new JSONObject();
write的返回值RootElement(), json);
return json;
}
/
**
* xml转json
*
* @param element
* @param json
*/
public static void dom4j2Json(Element element, JSONObject json) {
List<Element> chdEl = element.elements();
for(Element e : chdEl){
if (!e.elements().isEmpty()) {
JSONObject chdjson = new JSONObject();
dom4j2Json(e, chdjson);
Object o = (e.getName());
if (o != null) {
JSONArray jsona = null;
if (o instanceof JSONObject) {
JSONObject jsono = (JSONObject) o;
jsona = new JSONArray();
jsona.add(jsono);
jsona.add(chdjson);
}
if (o instanceof JSONArray) {
jsona = (JSONArray) o;
jsona.add(chdjson);
}
json.Name(), jsona);
} else {
if (!chdjson.isEmpty()) {
json.Name(), chdjson);
}
}
} else {
if (!e.getText().isEmpty()) {
json.Name(), e.getText());
}
}
}
}
}
然后运⾏,就能接收到接⼝的返回数据了!如果有中⽂乱码的话,就把编辑器以及项⽬的编码格式都改成UTF-8的就可以了--------------------------------------------------------------------------------------------
补充说明:当获取当前连接请求返回的数据流并读取的时候,如果返回数据不完整就会抛异常
java.io.IOException: Premature EOF
这个问题问度娘,都说读取的时候
String temp = null;
while(null != (temp = br.readLine())){
sb.append(temp);
}
这⼀段改成
int BUFFER_SIZE = 1024;
char[] buffer = new char[BUFFER_SIZE]; // or some other size,
int charsRead = 0;
while ( (charsRead = br.read(buffer, 0, BUFFER_SIZE)) != -1) {
sb.append(buffer, 0, charsRead);
}
这样⼦就好了,但是我试过了还是会抛异常,了好久都没到具体的解决办法,如果有⼤神看见帖⼦,望指导⼀下应该怎么做才⾏..................,这个问题我也会持续跟踪,有解决办法了再第⼀时间发出来
版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198,我们将在24小时内删除。
发表评论