码迷,mamicode.com
首页 > 编程语言 > 详细

采用HttpClient3.x上传文件 spring 文件上传

时间:2016-06-07 22:40:22      阅读:347      评论:0      收藏:0      [点我收藏+]

标签:spring 文件长传 httpclient3.x 文件上传

最近,项目需要调用第三方的系统上传图片,在长传图片的同时,还需要携带其他的请求参数;整体的流程是:网页----》spring mvc---》业务处理----》调用第三方系统上传图片;

在此期间遇到的问题是:在调用第三方系统上传图片时,除了图片文件参数外,其他参数期望通过request.getParameter()方法能够访问到,采用了很多方式,都不行,最终通过不断的尝试,测试成功,特贡献出来供需要的人员参考!

  1. 采用spring 的MultipartFile进行文件上传,代码如下

        

@Note(note = "bigAnt:上传文件", author = "zhangwenbo")
    @RequestMapping("midifyPicture")
    @ResponseBody
    public SimpleMessage<Object> modifyPicture(@RequestParam("file") MultipartFile file, HttpServletRequest req) {

        logger.info("modifyHeaderPicture has invoked.filename is " + file.getOriginalFilename());

        SimpleMessage<Object> sm = new SimpleMessage<Object>();

        int index = file.getOriginalFilename().lastIndexOf(".");

        String imageSupportType = SpiConfig.getPropValue("IMAGE_SUPPORT_TYPE");

        if (imageSupportType.indexOf("," + file.getOriginalFilename().substring(index + 1) + ",") < 0) {
            sm.set("message", "file type is error.the support type is " + imageSupportType.substring(1, imageSupportType.length() - 1));

            logger.info("the file type is error.the req file type is " + file.getOriginalFilename().substring(index + 1));

            return sm;
        }

        File fileIO = null;

        try {
            fileIO = File.createTempFile(file.getOriginalFilename().substring(0, index), file.getOriginalFilename().substring(index + 1));

            if (!fileIO.exists()) {
                fileIO.createNewFile();
            }

            file.transferTo(fileIO);

        } catch (IOException e) {
            logger.warn("transferto file fail.", e);
        }

        Map<String, Object> postBody = new HashMap<String, Object>();

        postBody.put("loginname", req.getSession().getAttribute(BigAntHelper.SESSION_USER_ID));

        BigAntBaseRes uploadResult = BigAntClient.getInstance().uploadPicture(postBody, file.getOriginalFilename(), fileIO);

        logger.info("upload return msg is " + uploadResult);

        if (null != uploadResult) {
            if ("1".equals(uploadResult.getStatus().trim())) {
                sm.set("data", uploadResult.getData());
            } else {
                sm.set("message", uploadResult.getMsg());
            }
        } else {
            sm.set("message", "upload fail");
        }
        return sm;
    }


    2.采用HTTPCLIENT3.x上传文件,代码如下

   

/**
     * 长传文件<br/>
     * @param postBody
     * @param filename
     * @param file
     * @return
     */
    public BigAntBaseRes uploadPicture(Map<String,Object> postBody,String filename,File file){
        logger.info("upload file");
        postBody.put("token",SpiConfig.getPropValue("BIGANT_BASE_TOKEN"));
        postBody.put("op", "uploadAvater");
        return UploadFileClient.uploadFile(BigAntHelper.getUploadUrl(), postBody, filename, file,BigAntBaseRes.class);
    }
    
    /**
     * 长传文件<br/>
     *
     * @param url
     *            目标服务的url<br/>
     * @param reqParams
     *            请求参数<br/>
     * @param filename
     *            需要上传的文件名称<br/>
     * @param file
     *            需要上传的文件<br/>
     * @return
     */
    public static <T> T uploadFile(String url, Map<String, Object> reqParams, String filename, File file, Class<T> returnClass) {

        HttpClient client = new HttpClient();

        logger.info("URL:" + url + " and the filename is " + filename);

        HttpConnectionManagerParams managerParams = client.getHttpConnectionManager().getParams();

        managerParams.setConnectionTimeout(10000);

        PostMethod post = new PostMethod(url);

        HttpMethodParams params = post.getParams();

        params.setParameter(HttpMethodParams.HTTP_CONTENT_CHARSET, "UTF-8");

        params.setContentCharset("UTF-8");

        // 设置消息体

        List<Part> requestPart = new ArrayList<Part>();

        if (null != reqParams && reqParams.size() > 0) {
            Iterator<String> it = reqParams.keySet().iterator();

            while (it.hasNext()) {
                String key = it.next();

                if (null != reqParams.get(key)) {
                    try {
                        requestPart.add(new StringPart(key, URLEncoder.encode(reqParams.get(key).toString(), "UTF-8")));

                        logger.info("key:" + key + " and value is :" + URLEncoder.encode(reqParams.get(key).toString(), "UTF-8"));

                    } catch (Exception e) {
                        logger.warn("parse the send msg fail.", e);
                    }
                }
            }
        }

        try {
            // 设置文件内容
            requestPart.add(new FilePart(filename, file));

            post.setRequestEntity(new MultipartRequestEntity(requestPart.toArray(new Part[1]), post.getParams()));

            int status = client.executeMethod(post);

            String result = post.getResponseBodyAsString();

            if (status == HttpStatus.SC_OK) {
                logger.info("return result of uploading file is " + result);
            } else {
                if (null != result) {
                    result = "upload fail";
                }
                logger.warn("upload file fail.");
            }

            Gson gson = new Gson();

            T returnResult = gson.fromJson(result, returnClass);

            return returnResult;
        } catch (Exception e) {
            e.printStackTrace();
            logger.warn("upload file fail.the filename is " + filename, e);
        } finally {
            if (null != post) {
                post.releaseConnection();
            }
        }
        return null;
    }


本文出自 “java” 博客,请务必保留此出处http://zwbjava.blog.51cto.com/2789897/1787016

采用HttpClient3.x上传文件 spring 文件上传

标签:spring 文件长传 httpclient3.x 文件上传

原文地址:http://zwbjava.blog.51cto.com/2789897/1787016

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!