學習記錄(webservice)
WebService 的發布與調用
發布:https://wenku.baidu.com/view/2edb9cff941ea76e58fa042c.html
JAVA調用Webservice
RPC 方式,強烈推薦。這種方式不多說,直接看代碼就懂了
- public String getOnline(String url){
- int errCode=0;
- JSONObject resultJson=new JSONObject();
- String result="";
-
Service service = new Service();
- Call call;
- try {
- call=(Call) service.createCall();
- QName opAddEntry = new QName("urn:demo", "GetOnlineInfo"); //設置命名空間和需要調用的方法名
- call.setTargetEndpointAddress(url); //設置請求路徑
- call.setOperationName("GetNcgOnlineInfo"); //調用的方法名
-
call.setTimeout(Integer.valueOf(2000)); //設置請求超時
- call.setReturnType(org.apache.axis.encoding.XMLType.XSD_STRING);//設置返回類型
- result= (String) call.invoke(opAddEntry,new Object[]{});
- } catch (ServiceException e) {
- // TODO Auto-generated catch block
- System.out.println("查詢在線狀態1:"+e.getMessage());
-
errCode=1;
- } catch (RemoteException e) {
- // TODO Auto-generated catch block
- System.out.println("查詢在線狀態2:"+e.getMessage());
- errCode=2;
- }
- resultJson.put("errCode", errCode);
- resultJson.put("data", result);
- return resultJson.toString();
- }
裏面註釋比較全。還有些別的設置也比較簡單,自己琢磨就知道了。例如編碼方式、解析時間等。
說說這種方式的問題吧。我在使用的時候遇到的是:和我對接的人編寫了兩個WebService。但是由於這兩個中有許多部分是相同的,他就把這兩個合並了,同時提供了兩個命名空間(具體怎麽操作的我也不清楚),那麽問題了,這其中有一個命名空間的所有方法我都能成功調用,但是都無法收到返回值。當時我就方了,開始還是好好的,怎麽就突然不行了,於是我繼續執行,查看報錯消息,同時抓包查看報文內容。終於給我發現了問題。
下圖是返回結果報的錯,大體意識就是說我設置的命名空間和對方的命名空間不匹配。然後RPC解析就失敗了。
然後我利用Wireshark抓包,得到一下結果。可以看看出,我請求的是命名空間是 ns1="urn:ncg"(其余的都是wsdl默認自帶的)。可是我收到的返回報文就變了。變成了這樣的 xmlns:dag="http://tempuri.org/dag.xsd" xmlns:dag="urn:dag" xmlns:ncg="urn:ncg" 足足有三個啊。RPC按照默認設置的 ns1="urn:ncg" 去解析,那肯定什麽都解析不了的。所以只有自己去解析了。這種情況可以利用第三種或者第四種方式進行調用。
第三種:利用HttpURLConnection拼接和解析報文進行調用。
還是上面那個查詢設備的方法。只不過改了下。當然,我這是知道報文後的解決辦法。
- public String ncgConnection(String url,String method){
- URL wsUrl;
- int errCode=0;
- JSONObject resultJson=new JSONObject();
- String result="";
- try {
- wsUrl = new URL(url+"/"+method);
- HttpURLConnection conn = (HttpURLConnection) wsUrl.openConnection();
- conn.setDoInput(true);
- conn.setDoOutput(true);
- conn.setRequestMethod("POST");
- conn.setRequestProperty("Content-Type", "text/xml;charset=UTF-8");
- conn.setConnectTimeout(2000);
- conn.setReadTimeout(2000);
- OutputStream os = conn.getOutputStream();
- //請求體
- //<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"><soapenv:Body><ns1:DeleteCascadeFromCms soapenv:encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" xmlns:ns1="urn:ncg"><ncg-code-list xsi:type="xsd:string">["11241525"]</ncg-code-list></ns1:DeleteCascadeFromCms></soapenv:Body></soapenv:Envelope>
- String soap = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" "
- + "xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\"><soapenv:Body><ns1:"+method+" soapenv:encodingStyle=\"http://schemas.xmlsoap.org/soap/encoding/\" xmlns:ns1=\"urn:ncg\"/></soapenv:Body></soapenv:Envelope>";
- os.write(soap.getBytes());
- InputStream is = conn.getInputStream();
- byte[] b = new byte[1024];
- int len = 0;
- String s = "";
- while((len = is.read(b)) != -1){
- String ss = new String(b,0,len,"UTF-8");
- s += ss;
- }
- result=s.split("<response xsi:type=\"xsd:string\">")[1].split("</response>")[0];
- is.close();
- os.close();
- conn.disconnect();
- } catch (MalformedURLException e) {
- // TODO Auto-generated catch block
- System.out.println("通訊模塊1:"+e.getMessage());
- errCode=1;
- } catch (IOException e) {
- // TODO Auto-generated catch block
- System.out.println("通訊模塊2:"+e.getMessage());
- errCode=2;
- }
- resultJson.put("errCode", errCode);
- resultJson.put("data", result);
- return resultJson.toString();
- }
正常來說,利用HttpURLConnection實現很多的調用不需要自己拼接請求頭和解析返回結果的(例如java端提供的一些action或者controller),可是在這兒調用WebService,確確實實的需要自己手寫。對比上面那個Wireshark抓包的結果可以發現,在請求體部分按照對方提供的wsdl進行拼接,結果部分也進行相同的解析。可以正確獲得結果。
第四種,利用httpclient
簡單來說,httpClient可以算是加強版的HttpURLConnection,httpClient的API比較多,也比較穩定,不容易擴展。HttpURLConnection比較輕量級,容易根據自己的需求進行擴展。但是穩定性不如httpClient。
這種方法具體實現思路和HttpURLConnection一樣。只是有點小區別。代碼如下:
- public void demo(String url){
- HttpClient httpClient=new HttpClient();
- PostMethod postMethod=new PostMethod();
- postMethod.setPath(url+"/ncg.wsdl"); //路徑和wsdl名
- String soap = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" "
- + "xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\"><soapenv:Body><ns1:GetNcgOnlineInfo soapenv:encodingStyle=\"http://schemas.xmlsoap.org/soap/encoding/\" xmlns:ns1=\"urn:ncg\"/></soapenv:Body></soapenv:Envelope>";
- try {
- byte[] b=soap.getBytes("utf-8");
- InputStream is = new ByteArrayInputStream(b, 0, b.length);
- RequestEntity re = new InputStreamRequestEntity(is, b.length,
- "application/soap+xml; charset=utf-8");
- postMethod.setRequestEntity(re);
- int statusCode = httpClient.executeMethod(postMethod);
- String soapResponseData = postMethod.getResponseBodyAsString();
- postMethod.releaseConnection();
- //解析
- System.out.println(soapResponseData.split("<response xsi:type=\"xsd:string\">")[1].split("</response>")[0]);
- } catch (UnsupportedEncodingException e1) {
- // TODO Auto-generated catch block
- e1.printStackTrace();
- } catch (HttpException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- } catch (IOException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- }
結果:我這兒沒有做更多的判斷,直接輸出,這種方式我以前其實並沒有用到。如果有需要可以更具返回的狀態判斷是否成功。如果你去抓包的話,你會發現這個會和上面HttpURLConnection抓的一樣。
轉載至 https://blog.csdn.net/qq_31183297/article/details/79522746
僅供個人學習參考
學習記錄(webservice)