java简单实现webservice接口

今天药忘吃喽~ 2022-08-06 03:09 11阅读 0赞

webservice实现有多种方式

比如最常用的有axis框架，xfire框架，通过该框架可以发布wsdl接口，也可以实现webservice客户端，目前eclipse都有集成的插件，可以根据wsdl文件生成webservice客户端调用接口，但是这样部署的时候必须依赖框架的jar包，有时候可能因为环境等等原因，我们仅仅需要wsdl中的某一个接口，这时候可以通过http接口或socket接口直接发生xml数据，来调用服务端webservice服务，其实webservice底层还是发送xml数据，只是框架封装了对xml数据进行序列化与反序列化操作，下面以两个简单的例子说明http方式和socket方式。

http实现webservice接口调用例子：

import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.OutputStreamWriter;
    import java.io.UnsupportedEncodingException;
    import java.net.MalformedURLException;
    import java.net.URL;
    import java.net.URLConnection;
    
    public class HttpPostTest {
        void testPost(String urlStr) {
            try {
                URL url = new URL(urlStr);
                URLConnection con = url.openConnection();
                con.setDoOutput(true);
                con.setRequestProperty("Pragma:", "no-cache");
                con.setRequestProperty("Cache-Control", "no-cache");
                con.setRequestProperty("Content-Type", "text/xml");
                
                OutputStreamWriter out = new OutputStreamWriter(con.getOutputStream());    
                String xmlInfo = getXmlInfo();
                out.write(new String(xmlInfo));
                out.flush();
                out.close();
                BufferedReader br = new BufferedReader(new InputStreamReader(con.getInputStream()));
                String line = "";
                StringBuffer buf = new StringBuffer();
                for (line = br.readLine(); line != null; line = br.readLine()) {
                    buf.append(new String(line.getBytes(),"UTF-8"));
                }
                System.out.println(buf.toString());
            } catch (MalformedURLException e) {
                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    
        private String getXmlInfo() {
            // 通过wsdl文件可以查看接口xml格式数据，构造调用接口xml数据
            String xml = "<SOAP-ENV:Envelope xmlns:SOAP-ENV=/"http://schemas.xmlsoap.org/soap/envelope//" xmlns:SOAP-ENC=/"http://schemas.xmlsoap.org/soap/encoding//" xmlns:xsi=/"http://www.w3.org/2001/XMLSchema-instance/" xmlns:xsd=/"http://www.w3.org/2001/XMLSchema/">"
                        + "<SOAP-ENV:Body>"
                        +    "<m:getItemDetailSingle xmlns:m=/"http:xxxxxxxxxxxxxxxxxx//">"
                        +        "<itemMo>"
                        +            "<category>工厂类</category>"
                        +            "<city>北京</city>"
                        +            "<flag>1</flag>"
                        +            "<itemId>0</itemId>"
                        +            "<itemIndex>1</itemIndex>"
                        +            "<keyword></keyword>"
                        +            "<mobile>2147483647</mobile>"
                        +            "<password>123456</password>"
                        +            "<userName>sohu</userName>"
                        +        "</itemMo>"
                        +    "</m:getItemDetailSingle>"
                        + "</SOAP-ENV:Body>"
                        + "</SOAP-ENV:Envelope>";
            return xml;
        }
    
        public static void main(String[] args) throws UnsupportedEncodingException {
            String url = "http://localhost:9003/dataService/services/Job";
            new HttpPostTest().testPost(url);
        }
    }

socke方式实现例子：

import java.io.IOException;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.io.OutputStream;
    import java.net.Socket;
    import java.net.UnknownHostException;
    
    
    public class WebServiceClient {
    
        /**
         * @param args
         * @throws IOException 
         * @throws UnknownHostException 
         */
        public static void main(String[] args) throws UnknownHostException, IOException {
            Socket socket = new Socket("localhost",9003);   
            OutputStream os = socket.getOutputStream();   
            InputStream is = socket.getInputStream();   
            //System.out.println(socket.isConnected());
            String httpSend = "POST /dataService/services/Job HTTP/1.1/r/n"  
                            + "Content-Type:text/xml/r/n"  
                            + "Host:localhost:9003/r/n"  
                            + "Content-Length:1024/r/n"  
                            + "/r/n"  
                            + "<SOAP-ENV:Envelope xmlns:SOAP-ENV=/"http://schemas.xmlsoap.org/soap/envelope//" xmlns:SOAP-ENC=/"http://schemas.xmlsoap.org/soap/encoding//" xmlns:xsi=/"http://www.w3.org/2001/XMLSchema-instance/" xmlns:xsd=/"http://www.w3.org/2001/XMLSchema/">"
                            + "<SOAP-ENV:Body>"
                            +    "<m:getItemDetailSingle xmlns:m=/"http://localhost//">"
                            +        "<itemMo>"
                            +            "<category>工厂类</category>"
                            +            "<city>北京</city>"
                            +            "<flag>1</flag>"
                            +            "<itemId>0</itemId>"
                            +            "<itemIndex>1</itemIndex>"
                            +            "<keyword>String</keyword>"
                            +            "<mobile>2147483647</mobile>"
                            +            "<password>123456</password>"
                            +            "<userName>sohu</userName>"
                            +        "</itemMo>"
                            +    "</m:getItemDetailSingle>"
                            + "</SOAP-ENV:Body>"
                            + "</SOAP-ENV:Envelope>";
            os.write(httpSend.getBytes());   
            os.flush();   
      
            InputStreamReader ireader = new InputStreamReader(is);   
            java.io.BufferedReader breader = new java.io.BufferedReader(ireader);   
               
            String responseLine = "";   
               
            while((responseLine = breader.readLine()) != null)   
            {   
                System.out.println(new String(responseLine.getBytes(),"UTF-8"));   
            }   
                
            System.out.println("");   
    
        }
    
    }