post请求发送json数据-蒲公英云

post请求发送json数据

悠悠 2022-12-23 15:27 359阅读 0赞

package com.herocheer.bms.sys.util;
import com.alibaba.fastjson.JSONObject;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.HttpURLConnection;
import java.net.URL;
public class HttpRequest { 
    public static String sendPost(String url,String param){ 
        OutputStreamWriter out =null;
        BufferedReader reader = null;
        String response = "";
        //创建连接
        try { 
            URL httpUrl = null; //HTTP URL类 用这个类来创建连接
            //创建URL
            httpUrl = new URL(url);
            //建立连接
            HttpURLConnection conn = (HttpURLConnection) httpUrl.openConnection();
            conn.setRequestMethod("POST");
            conn.setRequestProperty("Content-Type", "application/json");
            conn.setRequestProperty("connection", "keep-alive");
            conn.setUseCaches(false);//设置不要缓存
            conn.setInstanceFollowRedirects(true);
            conn.setConnectTimeout(35000);
            conn.setReadTimeout(35000);
            conn.setDoOutput(true);
            conn.setDoInput(true);
            conn.connect();
            //POST请求
            out = new OutputStreamWriter(
                    conn.getOutputStream(),"utf-8");//这边不指定编码，正式环境中文数据会请求报错，报400
            out.write(param);
            out.flush();
            //读取响应
            reader = new BufferedReader(new InputStreamReader(
                    conn.getInputStream()));
            String lines;
            while ((lines = reader.readLine()) != null) { 
                lines = new String(lines.getBytes(), "utf-8");
                response+=lines;
            }
            reader.close();
            // 断开连接
            conn.disconnect();
        } catch (Exception e) { 
            System.out.println("发送 POST 请求出现异常！"+e);
            e.printStackTrace();
        }
        //使用finally块来关闭输出流、输入流
        finally{ 
            try{ 
                if(out!=null){ 
                    out.close();
                }
                if(reader!=null){ 
                    reader.close();
                }
            }
            catch(IOException ex){ 
                ex.printStackTrace();
            }
        }
        return response;
    }
    public static String sendPost2(String url, String data) { 
        String response = null;
        try { 
            CloseableHttpClient httpclient = null;
            CloseableHttpResponse httpresponse = null;
            try { 
                httpclient = HttpClients.createDefault();
                HttpPost httppost = new HttpPost(url);
                StringEntity stringentity = new StringEntity(data,
                        ContentType.create("text/json", "UTF-8"));
                httppost.setEntity(stringentity);
                httpresponse = httpclient.execute(httppost);
                response = EntityUtils
                        .toString(httpresponse.getEntity());
            } finally { 
                if (httpclient != null) { 
                    httpclient.close();
                }
                if (httpresponse != null) { 
                    httpresponse.close();
                }
            }
        } catch (Exception e) { 
            e.printStackTrace();
        }
        return response;
    }
    public static void main(String[] args) { 
        JSONObject jsonParam = new JSONObject();
        jsonParam.put("id", "12306");
        jsonParam.put("name", "孙悟空");
        String param = jsonParam.toJSONString();
        String url="http://localhost:8080/demo";
        String sendPost = sendPost2(url, param);
        System.out.println(sendPost);
    }
}