接口调用工具类可调用接口，代码如下
引入包
 import java.io.ByteArrayInputStream;
 import org.apache.axis.client.Call;
 import org.apache.axis.client.Service;
 import org.apache.axis.message.SOAPEnvelope;
 import org.apache.axis.utils.XMLUtils;
 import org.w3c.dom.Document;

码主体

public class CallWebservice {	
    	  private static Service service = new Service();
    	public String webservice(String url, String xml) {		
    	SOAPEnvelope rsp = null;		
    	Document resultDoc = null;		
    	Call call = new Call(service);		
    	call.setTargetEndpointAddress(url);	
    	ByteArrayInputStream stream;	
    	try {			
    	stream = new ByteArrayInputStream(xml.trim().getBytes("UTF-8"));			
    	SOAPEnvelope req = new SOAPEnvelope(stream);			
    	rsp = call.invoke(req);		
    	} catch (Exception e) {			
    	e.printStackTrace();		
    	}		
    	try {			
    	resultDoc = rsp.getAsDocument();		
    	} catch (Exception e) {			
    	e.printStackTrace();		
    	}		
    	String resultStr = XMLUtils.DocumentToString(resultDoc);		
    	return resultStr;
	}
}

学习主题：技术储备_rpc调用
学习目标：
 1 掌握什么是SOA
2 掌握RMI,掌握webservice
3 掌握HttpClient服务发布和消费
对应作业
1. RPC技术介绍_单体架构_SOA架构
(1) 什么是单体架构
一个归档包(列如war或者jar格式)包含了应用所有功能的应用程序,我们通常称之为单体应用.也称为单体应用架构,这是一种比较传统的架构风格.
(2) 什么是SOA架构
SOA 是 Service-Oriented Architecture 的英文缩写，就是面向服务的架构。这里的服可以理 解为 service 层业务服务。将系统拆分为不同的服务单元，通过网络协议服务单元之间进行通信。服务单元完成一个特定功能(如：验证、支付、登录等等)，通过服务单元之间的集成组成完整的应用程序。
2. RMI远程服务发布_消费_结构优化
(1) 什么是RMI远程调用
RMI 指的是远程方法调用 (Remote Method Invocation)。它是一种机制，能够让在某个 Java 虚拟机上的对象调用另一个 Java 虚拟机中的对象上的方法。可以用此方法调用的任何对象 必须实现该远程接口。 
(2) 实现RMI相关的API类有哪些，以及作用
3. WEBSERVICE远程服务发布_消费
(1) 什么是webservice
Web service 是一个平台独立的，低耦合的 web 的应用程序用于开发分布式的互操作的应用 程序。Web Service 技术， 能使得运行在不同机器上的不同应用无须借助附加的、专门的第 三方软件或硬件， 就可相互交换数据或集成。 
(2) 什么是soap和wsdl
SOAP(Simple Object Access Protocol) 简单对象访问协议: 
WSDL(Web Services Description Language) Web Service 的描述语言: 
一个 webservice 服务的说明书,通过该说明书可以完成 webservice 服务的调用 
4. httpClient_进行远程服务的发布_消费
(1) 谈谈自己对HttpClient的理解
方便是很方便就是老忘
(2) Http远程服务使用什么形式进行远程数据响应
HTTP 协议可能是现在 Internet 上使用得最多、最重要的协议了，越来越多的 Java 应用程 序需要直接通过 HTTP 协议来访问网络资源。 HttpClient 是 Apache Jakarta Common 下的子项目，供高效的、最新的、功能丰富的支持 HTTP 协议的客户端编程工具包。实现了所有 HTTP 的方法（GET,POST,PUT,HEAD 等）支持 RestFul。 

最近项目中有朋友咨询我webService接口的调用，在这里总结并分享一下，我对webService方法的调用。


一、webService接口调用工具类
public class WebService {
	private WebService() {
		throw new IllegalAccessError("CallWebServiceInterface class");
	}

	public static <E> E getWebServiceClient(String url, Class<E> clazz, int connectionTimeout, int receiveTimeout) {
		JaxWsProxyFactoryBean proxy = new JaxWsProxyFactoryBean();
		proxy.setServiceClass(clazz);
		proxy.setAddress(url);
		@SuppressWarnings("unchecked")
		E client = (E) proxy.create();
		// 配置超时时间
		Client clientProxy = ClientProxy.getClient(client);
		HTTPConduit conduit = (HTTPConduit) clientProxy.getConduit();
		HTTPClientPolicy policy = new HTTPClientPolicy();
		policy.setConnectionTimeout(connectionTimeout); // 连接超时时间
		policy.setReceiveTimeout(receiveTimeout);// 请求超时时间
		conduit.setClient(policy);
		return client;
	}

	public static <E> E getWebServiceClient(String url, Class<E> clazz) {
		return getWebServiceClient(url, clazz, 5000, 5000);
	}
}


二、webService服务接口
@WebService(targetNamespace = "http://biz.cos.interfaces.ccs.sf.com/")
public interface webServiceTest{
	

	@WebMethod
	List<String> queryAddressByPhone(String args);

}
注意：

1、webService注解上的targetNamespace是接口提供方的分包地址，获取方式可以直接访问webService接口地址返回的XML文件中获取；

2、接口中的方法名必须带webMethod注解，并且接口方法必须与提供方的接口一模一样；



三、WebService接口的调用


参数详解：

1、url为接口供应商提供的webService接口地址

2、args为webService方法需求的参数

public List<String> queryAddressByPhone(String url , String args) {
	webServiceTest client = WebService.getWebServiceClient(url, webServiceTest.class);
	List<String> Result = client.queryAddressByPhone(args);
	return Result;
}

最近项目中频繁遇到web service接口调用，调用起来麻烦，若使用wsimport生成客户端的方式调用，造成项目代码臃肿，简单整理个ws调用工具，便于在项目开发中使用。





WebServiceUtil




import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.Base64;

/**
 * Web service调用工具
 * @author Cheng.Wei
 * @date 2018年8月7日
 * @since jdk1.8
 */
public class WebServiceUtil {
    /**
     * 发送请求
     * @param request
     * @return
     * @throws IOException 
     */
    public static InputStream post(final Request request) throws IOException{
        URL url = new URL(request.getUrl());
        HttpURLConnection connection = (HttpURLConnection) url.openConnection();
        connection.setRequestProperty("content-type", "text/xml;charset=utf-8");
        connection.setDoInput(true);
        connection.setDoOutput(true);
        connection.connect();
        if(request.getAccount()!=null){
            String auth = request.getAccount().getUsername() +":"+ request.getAccount().getPassword();
            byte[] authstr = Base64.getEncoder().encode(auth.getBytes());
            connection.setRequestProperty("Authorization", "Basic "+new String(authstr));
        }
        connection.connect();
        String soapXML = request.getBody();
        try(OutputStream os = connection.getOutputStream()){
            os.write(soapXML.getBytes());
            if(connection.getResponseCode()!=200){
                throw new IOException("response:"+connection.getResponseCode());
            }
            InputStream is = connection.getInputStream();
            return is;
        }
    }
}





Request 请求报文




/**
 * 请求报文
 * @author Cheng.Wei
 * @date 2018年8月7日
 */
public class Request {
    /**访问地址*/
    private String url;
    /**XML格式数据*/
    private String body;
    /**账号信息*/
    private Account account;


    public String getUrl() {
        return url;
    }


    public void setUrl(String url) {
        this.url = url;
    }


    public String getBody() {
        return body;
    }


    public void setBody(String body) {
        this.body = body;
    }


    public Account getAccount() {
        return account;
    }


    public void setAccount(Account account) {
        this.account = account;
    }

    @Override
    public String toString() {
        return "Request [url=" + url + ", body=" + body + ", account=" + account + "]";
    }

    /**
     * 账号信息
     * @author Cheng.Wei
     * @date 2018年8月7日
     */
    public class Account{
        /**账号*/
        private String username;
        /**密码*/
        private String password;
        public String getUsername() {
            return username;
        }
        public void setUsername(String username) {
            this.username = username;
        }
        public String getPassword() {
            return password;
        }
        public void setPassword(String password) {
            this.password = password;
        }

        @Override
        public String toString() {
            return "Account [username=" + username + ", password=" + password + "]";
        }
    }

}





*测试代码




import java.io.IOException;
import java.io.InputStream;

import org.junit.Test;

/**
 * Web service 测试
 * @author Cheng.Wei
 *
 * @date 2018年8月7日
 */
public class WsTest {
    /**
     * QQ在线
     * @throws IOException
     */
    @Test
    public void qqOnline() throws IOException {
        /**QQ号*/
        String qq = "10086";
        String requestXml =  "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:web=\"http://WebXml.com.cn/\">"
                            + "<soapenv:Header/>"
                            +    "<soapenv:Body>"
                            +        "<web:qqCheckOnline>"
                            +           "<web:qqCode>"+qq+"</web:qqCode>"
                            +        "</web:qqCheckOnline>"
                            +    "</soapenv:Body>"
                            + "</soapenv:Envelope>";
        Request request = new Request();
        request.setBody(requestXml);
        request.setUrl("http://ws.webxml.com.cn/webservices/qqOnlineWebService.asmx?wsdl");
        try(InputStream inputStream = WebServiceUtil.post(request)){
            StringBuffer sb = new StringBuffer();
            byte[] b = new byte[1024];
            int len = 0;
            String str = null;
            while((len=inputStream.read(b)) != -1){
                str = new String(b, 0, len, "utf-8");
                sb.append(str);
            }
            System.out.println(sb.toString());
        }
    }
    /**
     * IP归属
     * @throws IOException 
     */
    @Test
    public void ipAddress() throws IOException{
        /**IP*/
        String ipAddress = "8.8.8.8";
        String requestXml ="<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:web=\"http://WebXml.com.cn/\">"
                            + "<soapenv:Header/>"
                            +   "<soapenv:Body>"
                            +       "<web:getCountryCityByIp>"
                            +           " <web:theIpAddress>"+ipAddress+"</web:theIpAddress>"
                            +       "</web:getCountryCityByIp>"
                            +   "</soapenv:Body>"
                            +"</soapenv:Envelope>";
        Request request = new Request();
        request.setBody(requestXml);
        request.setUrl("http://ws.webxml.com.cn/WebServices/IpAddressSearchWebService.asmx?wsdl");
        try(InputStream inputStream = WebServiceUtil.post(request)){
            StringBuffer sb = new StringBuffer();
            byte[] b = new byte[1024];
            int len = 0;
            String str = null;
            while((len=inputStream.read(b)) != -1){
                str = new String(b, 0, len, "utf-8");
                sb.append(str);
            }
            System.out.println(sb.toString());
        }
    }
}





运行结果