java.io.IOException: Broken pipe

发布时间:2024年01月08日

做1个接口,处理前端请求图片跨域的问题。由于前端拿图片的时候,有跨域问题,所以让后台先拿到图片,然后再写给前台。本来下面的代码没什么太大的问题,但是如果前台请求的图片一多(1个页面中有很多图片),有些请求就会报错:java.io.IOException: Broken pipe…

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.StreamUtils;
import org.springframework.web.context.ServletContextAware;

import javax.servlet.ServletContext;
import javax.servlet.http.HttpServletResponse;
import java.io.InputStream;
import java.net.URL;
import java.net.URLConnection;

@Slf4j
@Service
public class FileServiceImpl implements IFileService {

    @Autowired
    private HttpServletResponse response;


    @Override
    public void getImg(String imageUrl) {

        URL target = null;
        
        try {

            target = new URL(imageUrl);

            URLConnection urlConnection = target.openConnection();

            //获取输入流
            InputStream inputStream = urlConnection.getInputStream();

            byte[] bytes = StreamUtils.copyToByteArray(inputStream);

            StreamUtils.copy(bytes, response.getOutputStream());

            response.getOutputStream().close();

        } catch (Exception e) {
            log.error("获取图片失败, 图片url: {}, 异常信息: {}", imageUrl, e);
        }

    }

}

因此,需要加上Content-Length响应头,由于没有告知客户端响应是否写完(当前返回的数据响应体大小),客户端就可能随时主动断开连接

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.StreamUtils;
import org.springframework.web.context.ServletContextAware;

import javax.servlet.ServletContext;
import javax.servlet.http.HttpServletResponse;
import java.io.InputStream;
import java.net.URL;
import java.net.URLConnection;

@Slf4j
@Service
public class FileServiceImpl implements IFileService, ServletContextAware {

    @Autowired
    private HttpServletResponse response;

    private ServletContext servletContext;

    @Override
    public void getImg(String imageUrl) {

        URL target = null;
        try {

            target = new URL(imageUrl);

            URLConnection urlConnection = target.openConnection();

            response.setHeader("Content-Type",servletContext.getMimeType(imageUrl));

            //获取输入流
            InputStream inputStream = urlConnection.getInputStream();

            byte[] bytes = StreamUtils.copyToByteArray(inputStream);

            // 必须告诉浏览器客户端当前数据的大小, 否则客户端可能会断开连接, 导致broke pipe异常
            response.setContentLength(bytes.length);

            StreamUtils.copy(bytes, response.getOutputStream());

            response.getOutputStream().close();

        } catch (Exception e) {
            log.error("获取图片失败, 图片url: {}, 异常信息: {}", imageUrl, e);
        }

    }

    @Override
    public void setServletContext(ServletContext servletContext) {
        this.servletContext = servletContext;
    }
}

文章来源:https://blog.csdn.net/qq_16992475/article/details/135459938
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。