Java webservice的POST和GET请求调用方式

目录

• webservice的POST和GET请求调用
• POST请求
• 1.发送请求
• 2.POST请求体
• 3.测试
• GET请求
• 通过webService调第三方提供的接口post与get
• POST
• GET

webservice的POST和GET请求调用

POST请求

1.发送请求

import java.io.DataOutputStream;
import java.io.InputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.HashMap;
import java.util.Map;
import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.commons.httpclient.methods.RequestEntity;
import org.apache.commons.httpclient.methods.StringRequestEntity;
import com.google.common.io.ByteStreams;
/**
 * HttpClient发送SOAP请求
 * @param wsdl url地址
 * @param xml   请求体参数
 * @return
 * @throws Exception
 */
public static String sendHttpPost(String wsdl, String xml) throws Exception{
    int timeout = 10000;
    // HttpClient发送SOAP请求
    System.out.println("HttpClient 发送SOAP请求");
    HttpClient client = new HttpClient();
    PostMethod postMethod = new PostMethod(wsdl);
    // 设置连接超时
    client.getHttpConnectionManager().getParams().setConnectionTimeout(timeout);
    // 设置读取时间超时
    client.getHttpConnectionManager().getParams().setSoTimeout(timeout);
    // 然后把Soap请求数据添加到PostMethod中
    RequestEntity requestEntity = new StringRequestEntity(xml, "text/xml", "UTF-8");
    // 设置请求体
    postMethod.setRequestEntity(requestEntity);
    int status = client.executeMethod(postMethod);
    // 打印请求状态码
    System.out.println("status:" + status);
    // 获取响应体输入流
    InputStream is = postMethod.getResponseBodyAsStream();
    // 获取请求结果字符串
    return new String(ByteStreams.toByteArray(is));
}
/**
 * HttpURLConnection 发送SOAP请求
 * @param wsdl url地址
 * @param xml   请求体参数
 * @return
 * @throws Exception
 */
public static String sendURLConnection(String wsdl, String xml) throws Exception{
    int timeout = 10000;
    // HttpURLConnection 发送SOAP请求
    System.out.println("HttpURLConnection 发送SOAP请求");
    URL url = new URL(wsdl);
    HttpURLConnection conn = (HttpURLConnection) url.openConnection();
    conn.setRequestProperty("Content-Type", "text/xml; charset=utf-8");
    conn.setRequestMethod("POST");
    conn.setUseCaches(false);
    conn.setDoInput(true);
    conn.setDoOutput(true);
    conn.setConnectTimeout(timeout);
    conn.setReadTimeout(timeout);
    DataOutputStream dos = new DataOutputStream(conn.getOutputStream());
    dos.write(xml.getBytes("utf-8"));
    dos.flush();
    InputStream inputStream = conn.getInputStream();
    // 获取请求结果字符串
    return new String(ByteStreams.toByteArray(inputStream));
}

ByteStreams的maven

<dependency>
        <groupId>com.google.guava</groupId>
        <artifactId>guava</artifactId>
        <version>27.0.1-jre</version>
    </dependency>

2.POST请求体

/**
 * POST请求体
 * @param map 请求参数
 * @param methodName 方法名
 * @return
 */
public static String getXml(Map<String ,String> map , String methodName){
    StringBuffer sb = new StringBuffer("");
    sb.append("<?xml version=\"1.0\" encoding=\"UTF-8\"?>");
    sb.append("<soap:Envelope "
            + "xmlns:xsi='http://www.w3.org/2001/XMLSchema-instance' "
            + "xmlns:xsd='http://www.w3.org/2001/XMLSchema' "
            + "xmlns:soap='http://schemas.xmlsoap.org/soap/envelope/'>");
    sb.append("<soap:Body>");
    sb.append("<" + methodName + " xmlns='http://tempuri.org/'>");
    //post参数
    for (String str : map.keySet()){
        sb.append("<"+str+">"+map.get(str)+"</"+str+">");
    }
    sb.append("</" + methodName + ">");
    sb.append("</soap:Body>");
    sb.append("</soap:Envelope>");
    return sb.toString();
}

3.测试

/**
* HTTP POST请求
*/
public static void main(String[] args) throws Exception{
    String wsdl = "http://IP:端口/xxx?wsdl";
    String methodName = "方法名";
    Map<String ,String> map = new HashMap<>();
    map.put("参数名","参数值");
    //请求体xml
    String xml = getXml(map, methodName);
    //发送请求
    String s = sendHttpPost(wsdl, xml);
    System.out.println(s);
}

GET请求

/**
* 发送请求
*/
import com.google.common.io.ByteStreams;
import org.apache.commons.httpclient.HttpStatus;
import org.codehaus.jettison.json.JSONObject;
import java.io.InputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.HashMap;
import java.util.Map;
public static void main(String[] args) throws Exception{
    String url = "http://IP:端口/xxx/方法名?参数名=参数值";
    Map result = new HashMap(16);
    try {
        URL url = new URL(url);
        HttpURLConnection connection = (HttpURLConnection)url.openConnection();
        //设置输入输出，因为默认新创建的connection没有读写权限，
        connection.setDoInput(true);
        connection.setDoOutput(true);
        //接收服务端响应
        int responseCode = connection.getResponseCode();
        if(HttpStatus.SC_OK == responseCode){//表示服务端响应成功
            InputStream is = connection.getInputStream();
            //响应结果
            String s = new String(ByteStreams.toByteArray(is));
            result = com.alibaba.fastjson.JSONObject.parseObject(s, Map.class);
        }
    } catch (Exception e) {
        e.printStackTrace();
        System.out.println("查询在线状态1:"+e.getMessage());
    }
    System.out.println(result);
}

通过webService调第三方提供的接口post与get

需求：第三方提供接口路径，在自己的项目中进行调用

注意点：调不通的时候排除接口本身的问题后，看看自己调用路径是不是正确的，有没多了或者少了【/】，参数的格式是不是跟接口文档的一致，再不行，那有可能是编码或者流处理的问题，我在实际开发中就是因为流处理的问题导致调不通。

POST

    public static String post(String method,String urls,String params){
        OutputStreamWriter out = null;
        try
        {
            URL url = new URL(urls);//第三方接口路径
            HttpsURLConnection conn = (HttpsURLConnection) url.openConnection();
            // 创建连接
            conn.setDoOutput(true);
            conn.setDoInput(true);
            conn.setUseCaches(false);
            conn.setRequestMethod(method);//请求方式 此处为POST
            String token= "123456789";//根据实际项目需要，可能需要token值
            conn.setRequestProperty("token", token);
            conn.setRequestProperty("Content-type", "application/json");
            conn.connect();
            out = new OutputStreamWriter(conn.getOutputStream(), "utf-8");//编码设置
            out.write(params);
            out.flush();
            out.close();
            // 获取响应
            BufferedReader reader = new BufferedReader( new InputStreamReader(conn.getInputStream()));
            String lines;
            StringBuffer sb = new StringBuffer();
            while ((lines = reader.readLine()) != null ){
                lines = new String(lines.getBytes(), "utf-8" );
                sb.append(lines);
            }
            reader.close();
            System.out.println(sb);
            return sb.toString();        
        }catch(Exception e) {
            e.printStackTrace();
        }
        return null;
    }

GET

//根据各自需要返回数组或者字符串   
//public static String getObject(String method,String urls,String params){
 public static JSONArray getArray(String method,String urls,String params){
        OutputStreamWriter out = null;
        try{
            URL url = new URL(urls);//接口路径
            HttpsURLConnection conn = (HttpsURLConnection) url.openConnection();
            conn.setRequestMethod(method);//请求方法 此处为GET
            conn.setDoInput(true);
            conn.setDoOutput(true);
            String token = "123456789";//请求头token
            conn.setRequestProperty("token",token);
            conn.connect();
            int status = conn.getResponseCode();
            System.out.println(status);
 
            if(status == 200){
                BufferedReader reader = new BufferedReader(new InputStreamReader(conn.getInputStream()));//怎么也调不通的时候，有可能流处理有问题
                String str = "";
                StringBuffer sb = new StringBuffer();
                while((str=reader.readLine()) != null){
                    sb.append(str);
                }
                //返回字符串的话，就直接返回 sb.toString()
                return JSONArray.parseArray(sb.toString());
            }
            System.out.println("请求服务失败，错误码为"+status);
        }catch(Exception e){
            e.printStackTrace();
        }
        return null;
    }

用实体类进行接收返回值的话，需要将返回数据做下转换，转成我们需要的实体类格式

//返回数组转实体类
JSONArray sb = getArray(method,url,params);
if (sb!=null){
    List<实体类> list = JSONObject.parseArray(sb.toJSONString(), 实体类.class);
     return list;
}else {
     throw new CustomException("调用接口失败");
}
 
//返回字符串转实体类
String json = JSONObject.toJSONString(params);
String sb = post(method,url,json);
JSONObject testJson = JSONObject.parseObject(sb);
实体类dto = JSON.toJavaObject(testJson,实体类.class);

以上为个人经验，希望能给大家一个参考，也希望大家多多支持我们。