查看: 383|回复: 0

[Java学习] Java下http下载文件客户端和上传文件客户端实例代码

发表于 2018-1-5 08:00:00

一、下载客户端代码

  1. package javadownload;
  2. import java.io.ByteArrayOutputStream;
  3. import java.io.File;
  4. import java.io.FileOutputStream;
  5. import java.io.InputStream;
  6. import java.net.HttpURLConnection;
  7. import java.net.URL;
  8. /**
  9. * @说明 导出虚拟机
  10. * @author wxt
  11. * @version 1.0
  12. * @since
  13. */
  14. public class GetVM {
  15. /**
  16. * 测试
  17. * @param args
  18. */
  19. public static void main(String[] args) {
  20. String url = "http://192.168.5.102:8845/xx";
  21. byte[] btImg = getVMFromNetByUrl(url);
  22. if(null != btImg && btImg.length > 0){
  23. System.out.println("读取到:" + btImg.length + " 字节");
  24. String fileName = "ygserver";
  25. writeImageToDisk(btImg, fileName);
  26. }else{
  27. System.out.println("没有从该连接获得内容");
  28. }
  29. }
  30. /**
  31. * 将vm 写入到磁盘
  32. * @param vm 数据流
  33. * @param fileName 文件保存时的名称
  34. */
  35. public static void writeImageToDisk(byte[] vm, String fileName){
  36. try {
  37. File file = new File("./" + fileName);
  38. FileOutputStream fops = new FileOutputStream(file);
  39. fops.write(vm);
  40. fops.flush();
  41. fops.close();
  42. System.out.println("下载完成");
  43. } catch (Exception e) {
  44. e.printStackTrace();
  45. }
  46. }
  47. /**
  48. * 根据地址获得数据的字节流
  49. * @param strUrl 网络连接地址
  50. * @return
  51. */
  52. public static byte[] getVMFromNetByUrl(String strUrl){
  53. try {
  54. URL url = new URL(strUrl);
  55. HttpURLConnection conn = (HttpURLConnection)url.openConnection();
  56. conn.setRequestMethod("GET");
  57. conn.setConnectTimeout(5 * 1000);
  58. InputStream inStream = conn.getInputStream();//通过输入流获取数据
  59. byte[] btImg = readInputStream(inStream);//得到的二进制数据
  60. return btImg;
  61. } catch (Exception e) {
  62. e.printStackTrace();
  63. }
  64. return null;
  65. }
  66. /**
  67. * 从输入流中获取数据
  68. * @param inStream 输入流
  69. * @return
  70. * @throws Exception
  71. */
  72. public static byte[] readInputStream(InputStream inStream) throws Exception{
  73. ByteArrayOutputStream outStream = new ByteArrayOutputStream();
  74. byte[] buffer = new byte[1024];
  75. int len = 0;
  76. while( (len=inStream.read(buffer)) != -1 ){
  77. outStream.write(buffer, 0, len);
  78. }
  79. inStream.close();
  80. return outStream.toByteArray();
  81. }
  82. }
复制代码

上述代码只适合下载小文件,如果下载大文件则会出现 Exception in thread "main" java.lang.OutOfMemoryError: Java heap space 错误,所以如果下载大文件需要对上述代码进行改造,代码如下:

  1. package javadownload;
  2. import java.io.ByteArrayOutputStream;
  3. import java.io.File;
  4. import java.io.FileOutputStream;
  5. import java.io.InputStream;
  6. import java.net.HttpURLConnection;
  7. import java.net.URL;
  8. /**
  9. * @说明 导出虚拟机
  10. * @author wxt
  11. * @version 1.0
  12. * @since
  13. */
  14. public class GetBigFile {
  15. /**
  16. * 测试
  17. * @param args
  18. */
  19. public static void main(String[] args) {
  20. String url = "http://192.168.5.76:8080/export?uuid=123";
  21. String fileName="yserver";
  22. getVMFromNetByUrl(url,fileName);
  23. }
  24. /**
  25. * 根据地址获下载文件
  26. * @param strUrl 网络连接地址
  27. * @param fileName 下载文件的存储名称
  28. */
  29. public static void getVMFromNetByUrl(String strUrl,String fileName){
  30. try {
  31. URL url = new URL(strUrl);
  32. HttpURLConnection conn = (HttpURLConnection)url.openConnection();
  33. conn.setRequestMethod("GET");
  34. conn.setConnectTimeout(5 * 1000);
  35. InputStream inStream = conn.getInputStream();//通过输入流获取数据
  36. byte[] buffer = new byte[4096];
  37. int len = 0;
  38. File file = new File("./" + fileName);
  39. FileOutputStream fops = new FileOutputStream(file);
  40. while( (len=inStream.read(buffer)) != -1 ){
  41. fops.write(buffer, 0, len);
  42. }
  43. fops.flush();
  44. fops.close();
  45. } catch (Exception e) {
  46. e.printStackTrace();
  47. }
  48. }
  49. }
复制代码

二、上传文件客户端:

  1. package javadownload;
  2. import java.io.DataInputStream;
  3. import java.io.DataOutputStream;
  4. import java.io.File;
  5. import java.io.FileInputStream;
  6. import java.io.IOException;
  7. import java.io.OutputStream;
  8. import java.net.HttpURLConnection;
  9. import java.net.URL;
  10. public class FileUpload {
  11. /**
  12. * 发送请求
  13. *
  14. * @param url
  15. * 请求地址
  16. * @param filePath
  17. * 文件在服务器保存路径(这里是为了自己测试方便而写,可以将该参数去掉)
  18. * @return
  19. * @throws IOException
  20. */
  21. public int send(String url, String filePath) throws IOException {
  22. File file = new File(filePath);
  23. if (!file.exists() || !file.isFile()) {
  24. return -1;
  25. }
  26. /**
  27. * 第一部分
  28. */
  29. URL urlObj = new URL(url);
  30. HttpURLConnection con = (HttpURLConnection) urlObj.openConnection();
  31. /**
  32. * 设置关键值
  33. */
  34. con.setRequestMethod("POST"); // 以Post方式提交表单,默认get方式
  35. con.setDoInput(true);
  36. con.setDoOutput(true);
  37. con.setUseCaches(false); // post方式不能使用缓存
  38. // 设置请求头信息
  39. con.setRequestProperty("Connection", "close");//Keep-Alive
  40. con.setRequestProperty("Charset", "UTF-8");
  41. // 设置边界
  42. String BOUNDARY = "----------" + System.currentTimeMillis();
  43. con.setRequestProperty("Content-Type", "multipart/form-data; boundary="
  44. + BOUNDARY);
  45. // 请求正文信息
  46. // 第一部分:
  47. StringBuilder sb = new StringBuilder();
  48. sb.append("--"); // ////////必须多两道线
  49. sb.append(BOUNDARY);
  50. sb.append("\r\n");
  51. sb.append("Content-Disposition: form-data;name=\"file_name\";filename=\""
  52. + file.getName() + "\"\r\n");
  53. sb.append("Content-Type:application/octet-stream\r\n\r\n");
  54. sb.append("Connection:close\r\n\r\n");
  55. byte[] head = sb.toString().getBytes("utf-8");
  56. // 获得输出流
  57. OutputStream out = new DataOutputStream(con.getOutputStream());
  58. out.write(head);
  59. // 文件正文部分
  60. DataInputStream in = new DataInputStream(new FileInputStream(file));
  61. int bytes = 0;
  62. byte[] bufferOut = new byte[1024];
  63. while ((bytes = in.read(bufferOut)) != -1) {
  64. out.write(bufferOut, 0, bytes);
  65. }
  66. in.close();
  67. // 结尾部分
  68. byte[] foot = ("\r\n--" + BOUNDARY + "--\r\n").getBytes("utf-8");// 定义最后数据分隔线
  69. out.write(foot);
  70. out.flush();
  71. out.close();
  72. /**
  73. * 读取服务器响应,必须读取,否则提交不成功
  74. */
  75. return con.getResponseCode();
  76. /**
  77. * 下面的方式读取也是可以的
  78. */
  79. // try {
  80. // // 定义BufferedReader输入流来读取URL的响应
  81. // BufferedReader reader = new BufferedReader(new InputStreamReader(
  82. // con.getInputStream()));
  83. // String line = null;
  84. // while ((line = reader.readLine()) != null) {
  85. // System.out.println(line);
  86. // }
  87. // } catch (Exception e) {
  88. // System.out.println("发送POST请求出现异常!" + e);
  89. // e.printStackTrace();
  90. // }
  91. }
  92. public static void main(String[] args) throws IOException {
  93. FileUpload up = new FileUpload();
  94. System.out.println(up.send("http://192.168.5.102:8845/xx",
  95. "./vif.xml"));
  96. ;
  97. }
  98. }
复制代码

总结

以上所述是小编给大家介绍的Java下http下载文件客户端和上传文件客户端实例代码,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对程序员之家网站的支持!



回复

使用道具 举报