项目总结之HttpURLConnection的disconnect的问题

 更新时间:2023年06月07日 09:57:50   作者:毕小宝  
这篇文章主要介绍了项目总结之HttpURLConnection的disconnect的问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教

HttpURLConnection的disconnect问题

项目需要存储文件,但是由于使用百度云平台的服务器,没有文件写权限,辗转使用中间转发的策略,将文件存储在公司公网服务器上,通过云平台的文件请求都转发到文件服务器。

响应转发过程中,总是得不到转发的响应内容。

跟踪发现获取到的URLConnection的输入流的available总是返回0,导致转发响应内容为空。

调试发现把 URLConnection的disconnect()调用代码注释掉,能够转发成功。

/**
     * 以http方式发送请求,并将请求响应内容以String格式返回
     * @param path    请求路径
     * @param method  请求方法
     * @param body    请求数据
     * @return 返回响应的字符串
     */
    public static void httpRequestRediret(HttpServletResponse response,String fileName,String path, String method, String body) {
        HttpURLConnection conn = null;
        InputStream inputStream = null;
        try {
            URL url = new URL(path);
            conn = (HttpURLConnection) url.openConnection();
            conn.setDoOutput(true);
            conn.setDoInput(true);
            conn.setUseCaches(false);
            conn.setRequestMethod(method);
            if (null != body) {
                OutputStream outputStream = conn.getOutputStream();
                outputStream.write(body.getBytes("UTF-8"));
                outputStream.close();
            }
            //代理返回流信息
            inputStream = conn.getInputStream();
            response.setContentType(conn.getContentType());
            FileUtil.responseAttachment(fileName,inputStream, response);
        } catch (Exception e) {
            logger.error(e);
        }finally{
            if(conn!=null){
                conn.disconnect();
            }
        }
    }

FileUtil转发附件

/**
     * Http响应内容为附件
     * @param file
     * @param response
     */
    public static void responseAttachment(String fileName ,InputStream in,HttpServletResponse response){
        if(response==null||in==null||fileName==null){
            return;
        }
        BufferedInputStream bis = null;
        BufferedOutputStream bos = null;
        byte[] buff = new byte[1024];
        int bytesRead;
        try{
            response.setHeader("Content-disposition", "attachment; filename="
                    + new String(fileName.getBytes("utf-8"), "ISO8859-1"));
            response.setHeader("Content-Length", String.valueOf(in.available()));
            bis = new BufferedInputStream(in);
            bos = new BufferedOutputStream(response.getOutputStream());
            while (-1 != (bytesRead = bis.read(buff, 0, buff.length))) {
                bos.write(buff, 0, bytesRead);
            }
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            if(bis!=null){
                try {
                    bos.close();
                    bis.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }

结论

URLConnection的响应流InputStream在没有处理之前就关闭connection会导致该输入流信息为空,getInputStream()的available总是为0。

猜测disconnection可能执行了输入流的关闭操作了。response响应头如果不设置Content-Length,客户端也能正确获取到响应文件的。

网上看到一种说法说如果将输入流关闭后,则对应的URLConnection也会自动关闭了。

还有一个问题是如果Connection没有执行disconnect()操作,会有什么后果呢?

HttpURLConnection解决Feign报400问题

问题描述

项目中使用Feign组件远程调用问题记录,本地代码执行正常,部署到服务器访问调用不了远程接口,报 feign.FeignException: status 400 reading,不太清楚是什么问题,分别用了httpclinet、resttemplate、feign,结果都失败报同一个问题,明明本地运行正常,线上就不正常了呢?

原因分析

网上查了很多报错的原因,但是都不符合,最后用了HttpURLConnection这个api 成功解决

解决方案

    //post请求
    public static <T> T doPost(String url, Object requestObj, Class<T> tClass) throws IOException {
        PrintWriter out = null;
        BufferedReader in = null;
        String result = "";
        try {
            // 打开和URL之间的连接
            HttpURLConnection conn = (HttpURLConnection) new URL(url).openConnection();
            // 设置通用的请求属性
            conn.setRequestMethod("POST");
            conn.setConnectTimeout(4 * 1000);
            conn.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
            // 发送POST请求必须设置如下两行
            conn.setDoOutput(true);
            conn.setDoInput(true);
            // 获取URLConnection对象对应的输出流
            out = new PrintWriter(new OutputStreamWriter(conn.getOutputStream(), "utf-8"));
            out.println(JSON.toJSONString(requestObj));
            // flush输出流的缓冲
            out.flush();
            InputStream is = null;
            if (conn.getResponseCode() >= 400) {
                is = conn.getErrorStream();
            } else {
                is = conn.getInputStream();
            }
            // 定义BufferedReader输入流来读取URL的响应
            in = new BufferedReader(new InputStreamReader(is,"utf-8"));
            String line;
            while ((line = in.readLine()) != null) {
                result += line;
            }
        } catch (Exception e) {
            System.out.println("发送 POST 请求出现异常!" + e);
            e.printStackTrace();
        }
        //使用finally块来关闭输出流、输入流
        finally {
            try {
                if (out != null) {
                    out.close();
                }
                if (in != null) {
                    in.close();
                }
            } catch (IOException ex) {
                ex.printStackTrace();
            }
        }
        log.info("流获取的对象:---"+result);
        T t = JSON.parseObject(result, tClass);
        return t;
    }
    //get请求
    public static JSONObject useGetMethod(String get_url){
        try {
            Map<String,Object> result = new HashMap<String,Object>();
            JSONObject jsonObject=null;
            URL url = new URL(get_url);
            HttpURLConnection connection = (HttpURLConnection) url.openConnection();
            connection.setRequestMethod("GET");
            //设置连接远程服务器的超时时间
            connection.setConnectTimeout(30000);
            //设置读取远程返回的数据时间
            connection.setReadTimeout(30000);
            connection.connect();
            int responseCode = connection.getResponseCode();
            if (responseCode == HttpURLConnection.HTTP_OK) {
                StringBuffer str = new StringBuffer();
                InputStream in = connection.getInputStream();
                BufferedReader br = new BufferedReader(new InputStreamReader(in, "utf-8"));
                try{
                    String line = "";
                    while((line = br.readLine()) != null) {
                        str.append(line);
                    }
                } finally {
                    br.close();
                    in.close();
                }
                jsonObject = JSONObject.parseObject(str.toString());
//                result.put("code", jsonObject.get("code"));
//                result.put("data", jsonObject.get("data"));
            }else{
//                System.out.println("错误状态码:"+responseCode);
//                result.put("code", responseCode);
//                result.put("message", "异常");
            }
            connection.disconnect();
            return jsonObject;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • Spring Cloud  Eureka服务治理的实现

    Spring Cloud Eureka服务治理的实现

    服务治理是微服务框架中最为核心和基础的模块,它主要是用来实现各个微服务实例的自动化注册与发现。这篇文章主要介绍了Spring Cloud Eureka服务治理的实现,感兴趣的小伙伴们可以参考一下
    2018-06-06
  • 基于java实现具有时效性文件链接

    基于java实现具有时效性文件链接

    这篇文章主要为大家详细介绍了如何基于java实现具有时效性的文件链接,文中的示例代码讲解详细,具有一定的借鉴价值,感兴趣的小伙伴可以了解一下
    2023-12-12
  • java创建一个类实现读取一个文件中的每一行显示出来

    java创建一个类实现读取一个文件中的每一行显示出来

    下面小编就为大家带来一篇java创建一个类实现读取一个文件中的每一行显示出来的实例。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-01-01
  • mybatis 返回Map类型key默认为大写问题

    mybatis 返回Map类型key默认为大写问题

    这篇文章主要介绍了mybatis 返回Map类型key默认为大写问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-11-11
  • java 线性表接口的实例详解

    java 线性表接口的实例详解

    这篇文章主要介绍了java 线性表接口的实现实例详解的相关资料,希望通过本能帮助到大家,需要的朋友可以参考下
    2017-09-09
  • java中JSON字符串转换为Map集合的两种方法

    java中JSON字符串转换为Map集合的两种方法

    本文主要介绍了java中JSON字符串转换为Map集合,包含了两种方法,这种需求可能涉及到从外部接口获取数据,或者在程序中处理配置信息等,感兴趣的可以了解一下
    2024-07-07
  • Mybatis-Plus中使用@DS注解动态选择数据源的源码解读

    Mybatis-Plus中使用@DS注解动态选择数据源的源码解读

    这篇文章主要介绍了Mybatis-Plus中使用@DS注解动态选择数据源的源码解读,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-07-07
  • 如何通过XML方式配置AOP过程解析

    如何通过XML方式配置AOP过程解析

    这篇文章主要介绍了如何通过XML方式配置AOP过程解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-07-07
  • IntelliJ IDEA修改新建文件自动生成注释的user名

    IntelliJ IDEA修改新建文件自动生成注释的user名

    今天小编就为大家分享一篇关于IntelliJ IDEA修改新建文件自动生成注释的user名,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧
    2018-10-10
  • redisson特性及优雅实现示例

    redisson特性及优雅实现示例

    这篇文章主要为大家介绍了redisson特性及优雅实现示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-11-11

最新评论