1. 程式人生 > >學習記錄(webservice)

學習記錄(webservice)

system mls 正常 學習 獲得 function on() -s exe

WebService 的發布與調用

發布:https://wenku.baidu.com/view/2edb9cff941ea76e58fa042c.html

JAVA調用Webservice

RPC 方式,強烈推薦。這種方式不多說,直接看代碼就懂了

  1. public String getOnline(String url){
  2. int errCode=0;
  3. JSONObject resultJson=new JSONObject();
  4. String result="";
  5. Service service = new Service();
  6. Call call;
  7. try {
  8. call=(Call) service.createCall();
  9. QName opAddEntry = new QName("urn:demo", "GetOnlineInfo"); //設置命名空間和需要調用的方法名
  10. call.setTargetEndpointAddress(url); //設置請求路徑
  11. call.setOperationName("GetNcgOnlineInfo"); //調用的方法名
  12. call.setTimeout(Integer.valueOf(2000)); //設置請求超時
  13. call.setReturnType(org.apache.axis.encoding.XMLType.XSD_STRING);//設置返回類型
  14. result= (String) call.invoke(opAddEntry,new Object[]{});
  15. } catch (ServiceException e) {
  16. // TODO Auto-generated catch block
  17. System.out.println("查詢在線狀態1:"+e.getMessage());
  18. errCode=1;
  19. } catch (RemoteException e) {
  20. // TODO Auto-generated catch block
  21. System.out.println("查詢在線狀態2:"+e.getMessage());
  22. errCode=2;
  23. }
  24. resultJson.put("errCode", errCode);
  25. resultJson.put("data", result);
  26. return resultJson.toString();
  27. }

裏面註釋比較全。還有些別的設置也比較簡單,自己琢磨就知道了。例如編碼方式、解析時間等。

說說這種方式的問題吧。我在使用的時候遇到的是:和我對接的人編寫了兩個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拼接和解析報文進行調用。

還是上面那個查詢設備的方法。只不過改了下。當然,我這是知道報文後的解決辦法。

  1. public String ncgConnection(String url,String method){
  2. URL wsUrl;
  3. int errCode=0;
  4. JSONObject resultJson=new JSONObject();
  5. String result="";
  6. try {
  7. wsUrl = new URL(url+"/"+method);
  8. HttpURLConnection conn = (HttpURLConnection) wsUrl.openConnection();
  9. conn.setDoInput(true);
  10. conn.setDoOutput(true);
  11. conn.setRequestMethod("POST");
  12. conn.setRequestProperty("Content-Type", "text/xml;charset=UTF-8");
  13. conn.setConnectTimeout(2000);
  14. conn.setReadTimeout(2000);
  15. OutputStream os = conn.getOutputStream();
  16. //請求體
  17. //<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>
  18. String soap = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" "
  19. + "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>";
  20. os.write(soap.getBytes());
  21. InputStream is = conn.getInputStream();
  22. byte[] b = new byte[1024];
  23. int len = 0;
  24. String s = "";
  25. while((len = is.read(b)) != -1){
  26. String ss = new String(b,0,len,"UTF-8");
  27. s += ss;
  28. }
  29. result=s.split("<response xsi:type=\"xsd:string\">")[1].split("</response>")[0];
  30. is.close();
  31. os.close();
  32. conn.disconnect();
  33. } catch (MalformedURLException e) {
  34. // TODO Auto-generated catch block
  35. System.out.println("通訊模塊1:"+e.getMessage());
  36. errCode=1;
  37. } catch (IOException e) {
  38. // TODO Auto-generated catch block
  39. System.out.println("通訊模塊2:"+e.getMessage());
  40. errCode=2;
  41. }
  42. resultJson.put("errCode", errCode);
  43. resultJson.put("data", result);
  44. return resultJson.toString();
  45. }

正常來說,利用HttpURLConnection實現很多的調用不需要自己拼接請求頭和解析返回結果的(例如java端提供的一些action或者controller),可是在這兒調用WebService,確確實實的需要自己手寫。對比上面那個Wireshark抓包的結果可以發現,在請求體部分按照對方提供的wsdl進行拼接,結果部分也進行相同的解析。可以正確獲得結果。

技術分享圖片

第四種,利用httpclient

簡單來說,httpClient可以算是加強版的HttpURLConnection,httpClient的API比較多,也比較穩定,不容易擴展。HttpURLConnection比較輕量級,容易根據自己的需求進行擴展。但是穩定性不如httpClient。

這種方法具體實現思路和HttpURLConnection一樣。只是有點小區別。代碼如下:

  1. public void demo(String url){
  2. HttpClient httpClient=new HttpClient();
  3. PostMethod postMethod=new PostMethod();
  4. postMethod.setPath(url+"/ncg.wsdl"); //路徑和wsdl名
  5. String soap = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" "
  6. + "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>";
  7. try {
  8. byte[] b=soap.getBytes("utf-8");
  9. InputStream is = new ByteArrayInputStream(b, 0, b.length);
  10. RequestEntity re = new InputStreamRequestEntity(is, b.length,
  11. "application/soap+xml; charset=utf-8");
  12. postMethod.setRequestEntity(re);
  13. int statusCode = httpClient.executeMethod(postMethod);
  14. String soapResponseData = postMethod.getResponseBodyAsString();
  15. postMethod.releaseConnection();
  16. //解析
  17. System.out.println(soapResponseData.split("<response xsi:type=\"xsd:string\">")[1].split("</response>")[0]);
  18. } catch (UnsupportedEncodingException e1) {
  19. // TODO Auto-generated catch block
  20. e1.printStackTrace();
  21. } catch (HttpException e) {
  22. // TODO Auto-generated catch block
  23. e.printStackTrace();
  24. } catch (IOException e) {
  25. // TODO Auto-generated catch block
  26. e.printStackTrace();
  27. }
  28. }

結果:我這兒沒有做更多的判斷,直接輸出,這種方式我以前其實並沒有用到。如果有需要可以更具返回的狀態判斷是否成功。如果你去抓包的話,你會發現這個會和上面HttpURLConnection抓的一樣。

技術分享圖片

轉載至 https://blog.csdn.net/qq_31183297/article/details/79522746

僅供個人學習參考

學習記錄(webservice)