`
godsend_jin
  • 浏览: 40086 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
社区版块
存档分类
最新评论

httpclient通过附件形式传递,客户端和服务端实现方法

阅读更多

1、客户端发送实现

 

package url;

import io.IoStreamUtil;

import java.io.File;
import java.io.IOException;
import java.io.InputStream;

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.mime.MultipartEntity;
import org.apache.http.entity.mime.content.FileBody;
import org.apache.http.entity.mime.content.StringBody;
import org.apache.http.impl.client.DefaultHttpClient;

/**
 * httpclient上传文件
 * @author linwei
 *
 */
public class MultipartEntityUtil {

 public static String postFile(File file,String url) throws ClientProtocolException, IOException {

  FileBody bin = null;
  HttpClient httpclient = new DefaultHttpClient();
  HttpPost httppost = new HttpPost(url);
  if(file != null) {
   bin = new FileBody(file);
  }

  StringBody username = new StringBody("13696900475");
  StringBody password = new StringBody("13696900475");
//请记住,这边传递汉字会出现乱码,解决方法如下,设置好编码格式就好
                //new StringBody("汉字",Charset.forName("UTF-8"))); 
  
     MultipartEntity reqEntity = new MultipartEntity();
     reqEntity.addPart("username", username);
     reqEntity.addPart("password", password);
     reqEntity.addPart("data", bin);
    
     httppost.setEntity(reqEntity);
     System.out.println("执行: " + httppost.getRequestLine());
    
     HttpResponse response = httpclient.execute(httppost);
     System.out.println("statusCode is " + response.getStatusLine().getStatusCode());
     HttpEntity resEntity = response.getEntity();
     System.out.println("----------------------------------------");
     System.out.println(response.getStatusLine());
     if (resEntity != null) {
       System.out.println("返回长度: " + resEntity.getContentLength());
       System.out.println("返回类型: " + resEntity.getContentType());
       InputStream in = resEntity.getContent();
       System.out.println("in is " + in);
       System.out.println(IoStreamUtil.getStringFromInputStream(in));
     }
     if (resEntity != null) {
       resEntity.consumeContent();
     }
  return null;
 }
 
 public static void main(String[] args) throws ClientProtocolException, IOException {
 
  File file = new File("d:/rss.xml");
  String url = "http://localhost:8080/webtest/servlet/URLTest";
  postFile(file,url);
 }
 
}

 

2、服务端接收实现

 

//commons-fileupload.jar  commons-io
request.setCharacterEncoding("UTF-8");
boolean isMultipart = ServletFileUpload.isMultipartContent(request);
          FileItemFactory factory = new DiskFileItemFactory(); 
            ServletFileUpload upload = new ServletFileUpload(factory); 
            try {  
                List items = upload.parseRequest(request); 
                Iterator iter = items.iterator(); 
                while (iter.hasNext()) { 
                    FileItem item = (FileItem) iter.next(); 
                    if (item.isFormField()) { 
                        //普通文本信息处理 
                        String paramName = item.getFieldName(); 
                        String paramValue = item.getString(); 
                        System.out.println(paramName + ":" + paramValue); 
                    } else { 
                        //上传文件信息处理 
                        String fileName = item.getName(); 
                        byte[] data = item.get(); 
                        String filePath = "d:/ssssss.txt"; 
                        FileOutputStream fos = new FileOutputStream(filePath); 
                        fos.write(data); 
                        fos.close(); 
                    } 
                }  
            } catch (FileUploadException e) { 
                e.printStackTrace(); 
            } 
        } 
 

分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics