最代码网站
首页>问答>httpClient文件上传为啥无法进入服务端方法?
Ava100的gravatar头像
Ava100 2017-08-02 21:57:02
等

httpClient文件上传为啥无法进入服务端方法?

死都进不去http://127.0.0.1:8888/upload/processUpload这个方法中，各路大神知道怎么进去吗？

client:

import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.Charset;
import java.util.Map;
import java.util.Set;

import javax.ws.rs.Path;

import org.apache.http.Consts;
import org.apache.http.HttpEntity;
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.mime.MultipartEntityBuilder;
import org.apache.http.entity.mime.content.FileBody;
import org.apache.http.entity.mime.content.StringBody;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import org.springframework.beans.factory.annotation.Autowired;

import ******.UploadService;

public class UploadClient {
    
    private static UploadClient uploadClient;
    
    public static UploadClient getInstance(){
        if (uploadClient == null) {
            uploadClient = new UploadClient();
        } 
        return uploadClient;
    }
    
    @Autowired 
    UploadService uploadService;
    
     /** 
     * 上传文件 
     *  
     * @param serverUrl 
     *            服务器地址 
     * @param localFilePath 
     *            本地文件路径 
     * @param serverFieldName 
     * @param params 
     * @return 
     * @throws Exception 
     */  
    public String uploadFileImpl(String serverUrl, String localFilePath,  
            String serverFieldName, Map<String, String> params)  
            throws Exception {  
        String respStr = null;  
        CloseableHttpClient httpclient = HttpClients.createDefault();  
        try {  
            HttpPost httppost = new HttpPost(serverUrl);  
            FileBody binFileBody = new FileBody(new File(localFilePath));  
  
            MultipartEntityBuilder multipartEntityBuilder = MultipartEntityBuilder  
                    .create();  
            // add the file params  
            multipartEntityBuilder.addPart(serverFieldName, binFileBody);  
            // 设置上传的其他参数  
            setUploadParams(multipartEntityBuilder, params);  
  
            HttpEntity reqEntity = multipartEntityBuilder.build();  
            httppost.setEntity(reqEntity);    
            CloseableHttpResponse response = httpclient.execute(httppost);  
            try {  
                System.out.println(response.getStatusLine());  
                HttpEntity resEntity = response.getEntity();  
                respStr = getRespString(resEntity);  
                EntityUtils.consume(resEntity);  
            } finally {  
                response.close();  
            }  
        } finally {  
            httpclient.close();  
        }  
        System.out.println("resp=" + respStr);  
        return respStr;  
    }  
  
    /** 
     * 设置上传文件时所附带的其他参数 
     *  
     * @param multipartEntityBuilder 
     * @param params 
     */  
    private void setUploadParams(MultipartEntityBuilder multipartEntityBuilder,  
            Map<String, String> params) {  
        if (params != null && params.size() > 0) {  
            Set<String> keys = params.keySet();  
            for (String key : keys) {  
                multipartEntityBuilder  
                        .addPart(key, new StringBody(params.get(key),  
                                ContentType.TEXT_PLAIN));  
            }  
        }  
    }  
  
    /** 
     * 将返回结果转化为String 
     *  
     * @param entity 
     * @return 
     * @throws Exception 
     */  
    private String getRespString(HttpEntity entity) throws Exception {  
        if (entity == null) {  
            return null;  
        }  
        InputStream is = entity.getContent();  
        StringBuffer strBuf = new StringBuffer();  
        byte[] buffer = new byte[4096];  
        int r = 0;  
        while ((r = is.read(buffer)) > 0) {  
            strBuf.append(new String(buffer, 0, r, "UTF-8"));  
        }  
        return strBuf.toString();  
    }  
}  
    
    server:

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;


public interface UploadService {
    /**
     * 文件上传
     * 
     * @param input
     * @return
     */
    public void processUpload(HttpServletRequest request, HttpServletResponse response) throws Exception;
}


    serverImpl:

import java.io.File;
import java.util.Iterator;
import java.util.List;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.ws.rs.Consumes;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;

import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.FileUploadException;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Controller;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.alibaba.dubbo.rpc.protocol.rest.support.ContentType;
import com.alibaba.fastjson.JSON;

import *******.UploadService;
import *****.UploadClient;
import ******.CarApiServiceImpl;

@Path("/upload")
@Service("uploadService")
public class uploadServerImpl implements UploadService {
    public static final Logger log4j = LoggerFactory
            .getLogger(uploadServerImpl.class);
    @Autowired
    private UploadClient uploadClient;
    
    @POST
    @Path("/processUpload")
    @Produces({ ContentType.APPLICATION_JSON_UTF_8 })
    @Consumes({ MediaType.APPLICATION_JSON })
    @Transactional(readOnly = false)
    @Override
    public void processUpload(HttpServletRequest request, HttpServletResponse response){

       request.setCharacterEncoding("utf-8"); 
        response.setCharacterEncoding("utf-8");  
          
        //检测是不是存在上传文件  
        boolean isMultipart = ServletFileUpload.isMultipartContent(request);  
          
        if(isMultipart){  
            DiskFileItemFactory factory = new DiskFileItemFactory();  
            
            String path = request.getRealPath("/file_upload_path");//得到上传文件的存放目录
            File dir = new File(path);
            if(!dir.exists()) {
                    dir.mkdirs(); 
            }
            
            
            //指定在内存中缓存数据大小,单位为byte,这里设为1Mb  
            factory.setSizeThreshold(1024*1024);  
           
            //设置一旦文件大小超过getSizeThreshold()的值时数据存放在硬盘的目录   
            factory.setRepository(new File("D:\\temp"));  
            
            // Create a new file upload handler  
            ServletFileUpload upload = new ServletFileUpload(factory);  
           
            // 指定单个上传文件的最大尺寸,单位:字节，这里设为50Mb    
            upload.setFileSizeMax(50 * 1024 * 1024);    
            
            //指定一次上传多个文件的总尺寸,单位:字节，这里设为50Mb  
            upload.setSizeMax(50 * 1024 * 1024);     
            upload.setHeaderEncoding("UTF-8");
              
            List<FileItem> items = null;  
              
            try {  
                // 解析request请求  
                items = upload.parseRequest(request);  
            } catch (FileUploadException e) {  
                e.printStackTrace();  
            }  
            
            if(items!=null){  
                //解析表单项目  
                Iterator<FileItem> iter = items.iterator();  
                while (iter.hasNext()) {  
                    FileItem item = iter.next(); 
                    
                    //如果是普通表单属性  
                    if (item.isFormField()) {  
                        //相当于input的name属性   <input type="text" name="content">  
                        String name = item.getFieldName();
                        
                        //input的value属性  
                        String value = item.getString();
                        
                        System.out.println("属性:" + name + " 属性值:" + value);  
                    }  
                    //如果是上传文件  
                    else {  
                        //属性名  
                        String fieldName = item.getFieldName();  
                        
                        //上传文件路径  
                        String fileName = item.getName();  
                        fileName = fileName.substring(fileName.lastIndexOf("/") + 1);// 获得上传文件的文件名  
                        
                        try {  
                            item.write(new File(dir, fileName));  
                        } catch (Exception e) {  
                            e.printStackTrace();  
                        }  
                    } 
                }  
            }  
        }  
        
        response.addHeader("token", "hello");
    }
   
}


test:

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.text.ParseException;
import java.util.LinkedHashMap;
import java.util.Map;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.util.EntityUtils;
import org.aspectj.weaver.patterns.ThisOrTargetAnnotationPointcut;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;

import *****.UploadService;

public class UploadTest {
    
    @Value("${file.upload.path}")
    private String file_upload_path;
    
    @Autowired
    UploadService uploadService;
    
    @Autowired
    static UploadClient uploadClient;
    
    public static void main(String[] args) throws ClientProtocolException, IOException, ParseException {
        try {  
            Map<String,String> uploadParams = new LinkedHashMap<String, String>();  
            uploadParams.put("userImageContentType", "image");  
            uploadParams.put("userImageFileName", "testaa.png");  
            uploadClient.getInstance().uploadFileImpl(  
                    "http://127.0.0.1:8888/upload/processUpload", "F:\\testpics\\aa.jpg",  
                    "file_upload_path", uploadParams);  
            
            HttpClient httpClient = new DefaultHttpClient();
HttpPost httpPost = new HttpPost("http://localhost:8888/upload/processUpload");
            
        } catch (Exception e) {  
            e.printStackTrace();  
        }  
    }
}


    

最代码问答评论总数1个评论 1个牛币 httpClienthttpClient文件上传
所有回答列表(3)
最代码官方的gravatar头像
最代码官方  LV168 2017年8月2日

1.确认服务端http://127.0.0.1:8888/upload/processUpload可访问

包括软件层程序正常，硬件网络层ip可以访问

2.通过其他方式测试服务端是否正常

比如写一个html网页，表单模拟http get和post请求

3.服务端增加日志

总之想办法确认客户端和服务端是否可以正常连通。

评论(0)
Ava100的gravatar头像
Ava100  LV2 2017年8月4日

感谢提供思路，正在解决中。。。。。

评论(0)
tian269mu的gravatar头像
tian269mu  LV4 2017年8月7日

肯定报错了,如果开发工具那看不到,在浏览器中f12,查看请求对应结果

评论(0)
发布回答
相关问答
最近浏览
miaoshi  LV16 2018年1月26日
xueyiblood  LV1 2017年12月4日
zuidaima_kyu  LV1 2017年10月18日
liangxiang  LV6 2017年10月12日
jiangD  LV2 2017年9月8日
beihe  LV4 2017年8月26日
守城兵  LV8 2017年8月23日
zhaoshuting  LV5 2017年8月22日
sowang  LV9 2017年8月21日
Ckxlnd  LV13 2017年8月18日
顶部 客服 微信二维码 底部
>扫描二维码关注最代码为好友扫描二维码关注最代码为好友
帮助|联系我|友情链接|网站地图|RSS订阅分享源代码|RSS订阅问答|最新分享源代码|最新问答 京ICP备12032064号-2