热门标签 | HotTags
当前位置:  开发笔记 > 运维 > 正文

Android编程使用HTTP协议与TCP协议实现上传文件的方法

这篇文章主要介绍了Android编程使用HTTP协议与TCP协议实现上传文件的方法,结合实例形式较为详细的分析了Android使用HTTP协议与TCP协议的具体步骤与实现文件传输的相关技巧,需要的朋友可以参考下

本文实例讲述了Android编程使用HTTP协议与TCP协议实现上传文件的方法。分享给大家供大家参考,具体如下:

Android上传文件有两种方式,第一种是基于Http协议的HttpURLConnection,第二种是基于TCP协议的Socket。 这两种方式的区别是使用HttpURLConnection上传时内部有缓存机制,如果上传较大文件会导致内存溢出。如果用TCP协议Socket方式上传就会解决这种弊端。

HTTP协议HttpURLConnection

1. 通过URL封装路径打开一个HttpURLConnection
2.设置请求方式以及头字段:Content-Type、Content-Length、Host
3.拼接数据发送

示例:

private static final String BOUNDARY = "---------------------------7db1c523809b2";//数据分割线
public boolean uploadHttpURLConnection(String username, String password, String path) throws Exception {
  //找到sdcard上的文件
  File file = new File(Environment.getExternalStorageDirectory(), path);
  //仿Http协议发送数据方式进行拼接
  StringBuilder sb = new StringBuilder();
  sb.append("--" + BOUNDARY + "\r\n");
  sb.append("Content-Disposition: form-data; name=\"username\"" + "\r\n");
  sb.append("\r\n");
  sb.append(username + "\r\n");
  sb.append("--" + BOUNDARY + "\r\n");
  sb.append("Content-Disposition: form-data; name=\"password\"" + "\r\n");
  sb.append("\r\n");
  sb.append(password + "\r\n");
  sb.append("--" + BOUNDARY + "\r\n");
  sb.append("Content-Disposition: form-data; name=\"file\"; filename=\"" + path + "\"" + "\r\n");
  sb.append("Content-Type: image/pjpeg" + "\r\n");
  sb.append("\r\n");
  byte[] before = sb.toString().getBytes("UTF-8");
  byte[] after = ("\r\n--" + BOUNDARY + "--\r\n").getBytes("UTF-8");
  URL url = new URL("http://192.168.1.16:8080/14_Web/servlet/LoginServlet");
  HttpURLConnection cOnn= (HttpURLConnection) url.openConnection();
  conn.setRequestMethod("POST");
  conn.setRequestProperty("Content-Type", "multipart/form-data; boundary=" + BOUNDARY);
  conn.setRequestProperty("Content-Length", String.valueOf(before.length + file.length() + after.length));
  conn.setRequestProperty("HOST", "192.168.1.16:8080");
  conn.setDoOutput(true);
  OutputStream out = conn.getOutputStream();
  InputStream in = new FileInputStream(file);
  out.write(before);
  byte[] buf = new byte[1024];
  int len;
  while ((len = in.read(buf)) != -1)
    out.write(buf, 0, len);
  out.write(after);
  in.close();
  out.close();
  return conn.getResponseCode() == 200;
}

TCP协议Socket

1.我们可以使用Socket发送TCP请求,将上传数据分段发送

示例:

public boolean uploadBySocket(String username, String password, String path) throws Exception {
  // 根据path找到SDCard中的文件
  File file = new File(Environment.getExternalStorageDirectory(), path);
  // 组装表单字段和文件之前的数据
  StringBuilder sb = new StringBuilder();
  sb.append("--" + BOUNDARY + "\r\n");
  sb.append("Content-Disposition: form-data; name=\"username\"" + "\r\n");
  sb.append("\r\n");
  sb.append(username + "\r\n");
  sb.append("--" + BOUNDARY + "\r\n");
  sb.append("Content-Disposition: form-data; name=\"password\"" + "\r\n");
  sb.append("\r\n");
  sb.append(password + "\r\n");
  sb.append("--" + BOUNDARY + "\r\n");
  sb.append("Content-Disposition: form-data; name=\"file\"; filename=\"" + path + "\"" + "\r\n");
  sb.append("Content-Type: image/pjpeg" + "\r\n");
  sb.append("\r\n");
  // 文件之前的数据
  byte[] before = sb.toString().getBytes("UTF-8");
  // 文件之后的数据
  byte[] after = ("\r\n--" + BOUNDARY + "--\r\n").getBytes("UTF-8");
  URL url = new URL("http://192.168.1.199:8080/14_Web/servlet/LoginServlet");
  // 由于HttpURLConnection中会缓存数据, 上传较大文件时会导致内存溢出, 所以我们使用Socket传输
  Socket socket = new Socket(url.getHost(), url.getPort());
  OutputStream out = socket.getOutputStream();
  PrintStream ps = new PrintStream(out, true, "UTF-8");
  // 写出请求头
  ps.println("POST /14_Web/servlet/LoginServlet HTTP/1.1");
  ps.println("Content-Type: multipart/form-data; boundary=" + BOUNDARY);
  ps.println("Content-Length: " + String.valueOf(before.length + file.length() + after.length));
  ps.println("Host: 192.168.1.199:8080");
  InputStream in = new FileInputStream(file);
  // 写出数据
  out.write(before);
  byte[] buf = new byte[1024];
  int len;
  while ((len = in.read(buf)) != -1)
    out.write(buf, 0, len);
  out.write(after);
  in.close();
  out.close();
  return true;
}

搭建服务器,完成上传功能

package cn.test.web.servlet;
import java.io.File;
import java.io.IOException;
import java.util.List;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.FileItemFactory;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
public class LoginServlet extends HttpServlet {
  private static final long serialVersiOnUID= 1L;
  @Override
  public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
    doPost(request, response);
  }
  @Override
  public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
    boolean isMultipart = ServletFileUpload.isMultipartContent(request);
    if (isMultipart)
      try {
        FileItemFactory factory = new DiskFileItemFactory();
        ServletFileUpload upload = new ServletFileUpload(factory);
        List items = upload.parseRequest(request);
        File dir = new File(request.getSession().getServletContext().getRealPath("/WEB-INF/upload"));
        //创建目录
        dir.mkdir();
        for (FileItem item : items)
          if (item.isFormField())
            System.out.println(item.getFieldName() + ": " + item.getString());
          else{
            item.write(new File(dir,item.getName().substring(item.getName().lastIndexOf("\\")+1)));
          }
      } catch (Exception e) {
        e.printStackTrace();
      }
    else {
      System.out.println(request.getMethod());
      System.out.println(request.getParameter("username"));
      System.out.println(request.getParameter("password"));
    }
  }
}

希望本文所述对大家Android程序设计有所帮助。


推荐阅读
  • Eclipse 中 Maven 的基础配置指南
    本文详细介绍了如何在 Eclipse 环境中配置 Maven,包括环境变量的设置、Maven 插件的安装与配置等关键步骤,旨在帮助开发者顺利搭建开发环境。 ... [详细]
  • 本文介绍了如何在Ubuntu 16.04系统上配置Nginx服务器,以便能够通过网络访问存储在服务器上的图片资源。这解决了在网页开发中需要使用自定义在线图标的需求。 ... [详细]
  • Zookeeper面试常见问题解析
    本文详细介绍了Zookeeper中的ZAB协议、节点类型、ACL权限控制机制、角色分工、工作状态、Watch机制、常用客户端、分布式锁实现、默认通信框架以及消息广播和领导选举的流程。 ... [详细]
  • Linux环境下Redmine快速搭建指南
    本文将详细介绍如何在Linux操作系统中使用Bitnami Redmine安装包快速搭建Redmine项目管理平台,帮助读者轻松完成环境配置。 ... [详细]
  • 深入探讨PHP中的输出缓冲技术(Output Buffering)
    本文深入解析了PHP中输出缓冲(Output Buffering)的原理及其在Web开发中的应用,特别是如何通过输出缓冲技术有效管理HTTP头部信息,提高代码的灵活性与健壮性。 ... [详细]
  • 本文介绍了ThinkPHP框架的基本概念及其主要特性。作为一款遵循Apache许可证的开源框架,ThinkPHP不仅支持多种平台和Web服务器,还提供了丰富的功能以适应不同的开发需求。 ... [详细]
  • 本文深入探讨了Redis中的两种主要持久化方式——RDB(Redis Database)和AOF(Append Only File),并详细解析了两者的实现机制、优缺点以及在实际应用中的选择策略。 ... [详细]
  • 开发笔记:哈希的应用
    开发笔记:哈希的应用 ... [详细]
  • 解决Vue项目离线创建问题
    当使用vue-cli工具通过命令`vue init webpack demo`创建Vue项目时,可能会遇到连接超时错误,这通常是因为网络问题导致无法访问远程服务器。本文将介绍如何通过离线方式成功创建Vue项目。 ... [详细]
  • 本文探讨了在使用阿里云RDS实例时遇到的一个时区问题。该问题导致系统时间与预期时间相差13小时。通过深入分析,发现问题是由于名为CST的时区存在多种解释,特别是在MySQL和Java之间进行时区协商时出现的误解。 ... [详细]
  • 本文档详细介绍了2017年8月31日关于MySQL数据库备份与恢复的教学内容,包括MySQL日志功能、备份策略、备份工具及实战演练。 ... [详细]
  • 本文探讨了在使用basicHttpBinding通过HTTPS发送请求时遇到的握手失败问题,分析了可能的原因及解决方案。 ... [详细]
  • C# 对象转 JSON 字符串的方法与应用
    本文介绍如何在 C# 中使用一般处理程序(ASHX)将对象转换为 JSON 字符串,并通过设置响应类型为 application/json 来确保客户端能够正确解析返回的数据。同时,文章还提供了 HTML 页面中不依赖 jQuery 的 AJAX 方法来接收和处理这些 JSON 数据的具体实现。 ... [详细]
  • 一面问题:MySQLRedisKafka线程算法mysql知道哪些存储引擎,它们的区别mysql索引在什么情况下会失效mysql在项目中的优化场景&# ... [详细]
  • 本文详细介绍了ejabberd中的验证码服务、接收器以及服务器间通信的监督者和工作进程,包括它们的启动方式和主要功能。 ... [详细]
author-avatar
KING逊咖
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有