Android实现TCP断点上传 后台C#服务接收

终端实现大文件上传一直都是比较难的技术,其中涉及到后端与前端的交互,稳定性和流量大小,而且实现原理每个人都有自己的想法,后端主流用的比较多的是Http来实现,因为大多实现过断点下载。但稳定性不能保证,一旦断开,无法续传。所以得采用另一种流行的做法,TCP上传大文件。

网上查找了一些资料,大多数是断点下载,然后就是单独的C#端的上传接收,或是HTTP的,或是只有android端的,由于任务紧所以之前找的首选方案当然是Http先来实现文件上传,终端采用Post方法,将文件直接传至后端,后端通过File来获得。

android端: 

RequestParams params = new RequestParams();
 File file = getTempFile();//获得本地文件
  try {
   params.put("file", file);
  } catch (FileNotFoundException e1) {
   e1.printStackTrace();
  }
  AsyncHttpUtil.post(URL + "/UpLoad", params, new JsonHttpResponseHandler() {
……

后端:
 var file = Request.Files["file"];
  file.SaveAs(upFileName);
还有其它更好的处理方法,也可以传流进来,不通过file文件格式。 在网络好的情况下没什么问题,但网络差点后来经常上传一半掉线或多个客户端上传出现连不上的情况,对于大文件极不稳定,所以赶紧研发TCP协议文件断点上传。

也有网友实现了Http断点上传,既然大文件不行,那就将文件分割成小文件来上传,纯NET的主要方法:

上传:

 bool result = true;
   long cruuent = 0;

   FileStream fStream = new FileStream(fileName, FileMode.Open, FileAccess.Read);
   BinaryReader bReader = new BinaryReader(fStream); 

   //模拟断点上传,第一次只上传 100 个字节
   long length = 100;

   fileName = fileName.Substring(fileName.LastIndexOf('\\') + 1);

   #region 开始上传文件
   try
   {

    byte[] data;
    #region 分割文件上传
    for (; cruuent <= length; cruuent = cruuent + byteCount)
    {
     if (cruuent + byteCount > length)
     {
      data = new byte[Convert.ToInt64((length - cruuent))];
      bReader.Read(data, 0, Convert.ToInt32((length - cruuent)));
     }
     else
     {
      data = new byte[byteCount];
      bReader.Read(data, 0, byteCount);
     }
     try
     {
      Hashtable parms = new Hashtable();
      parms.Add("fileName", fileName);
      parms.Add("npos", cruuent.ToString());

      byte[] byRemoteInfo = PostData(serverPath + "UpLoadServer.aspx", data, parms);

     }
     catch (Exception ex)
     {
      msg = ex.ToString();
      result = false;
      break;
     }
    #endregion
    }
   }
   catch (Exception ex)
   {
    msg = ex.ToString();
    result = false;
   }
   finally
   {
    bReader.Close();
    fStream.Close();

   }

   GC.Collect();

先将文件分割成小流,npos为断点的位置,即已经上传了的大小,然后循环上传所有包。
后台接收:

 /// <summary>
 /// 保存文件(从URL参数中获取文件名、当前指针,将文件流保存到当前指针后)
 /// 如果是第一次上传,则当前指针为0,代码执行与续传一样,只不过指针没有偏移
 /// </summary>
 public void SaveUpLoadFile()
 {

  string fileName = Request.Params["fileName"];
  long npos = Convert.ToInt64(Request.Params["npos"]);

  int upLoadLength = Convert.ToInt32(Request.InputStream.Length);

  string path = Server.MapPath("/UpLoadServer");
  fileName = path + "//UpLoad//" + fileName;

  FileStream fStream = new FileStream(fileName, FileMode.OpenOrCreate, FileAccess.ReadWrite);
  //偏移指针
  fStream.Seek(npos, SeekOrigin.Begin);

  //从客户端的请求中获取文件流
  BinaryReader bReader = new BinaryReader(Request.InputStream);
  try
  {
   byte[] data = new byte[upLoadLength];
   bReader.Read(data, 0, upLoadLength);
   fStream.Write(data, 0, upLoadLength);
  }
  catch
  {
   //TODO 添加异常处理
  }
  finally
  {
   //释放流
   fStream.Close();
   bReader.Close();
  }
 }

重点在 fStream.Seek(npos, SeekOrigin.Begin); 从断点位置接收保存。

有兴趣的可以自己实现。

现在主要讲讲客户端TCP上传,后台TCP接收,主要思路为:android端读取本地文件将文件名,文件大小上传至服务器(文件名必须是全局唯一),服务器将根据文件名查询是否上传过,若是上传过,将已传文件的大小即断点位置传给终端,终端接收后先保存断点位置,然后从断点位置读取文件断续上传,直到全部完成。若没上传过则服务器创建缓存文件接收。

看看代码Android:

String head = "Length=" + uploadFile.length() + ";filename=" + filename

 Socket socket = new Socket("192.168.0.123", 7080);
     OutputStream outStream = socket.getOutputStream();
     outStream.write(head.getBytes());//发送

     PushbackInputStream inStream = new PushbackInputStream(socket.getInputStream());
     String response = StreamTool.readLine(inStream);//读取
     String[] items = response.split(";");

 final String position = items[0].substring(items[0].indexOf("=") + 1);//断点位置
      final String serviceurl = items[1].substring(items[1].indexOf("=") + 1);//保存到服务器路径

RandomAccessFile fileOutStream = new RandomAccessFile(uploadFile, "r");
      fileOutStream.seek(Integer.valueOf(position));//从断点位置开始读取文件
      byte[] buffer = new byte[1024];
      int len = -1;
      int length = Integer.valueOf(position);//已经上传的大小,用于本地显示
      while ( (len = fileOutStream.read(buffer)) != -1) {
       outStream.write(buffer, 0, len);
       length += len;
       Message msg = new Message();
       msg.getData().putInt("size", length);
       // 更新上传的进度       handler.sendMessage(msg);

      } if (length == uploadFile.length()) {//如果相等,则说明上传成功} fileOutStream.close(); outStream.close(); inStream.close(); socket.close();

后端处理:

 private static TcpListener listener;//服务器监听
 IPAddress ipHost = IPAddress.Any;
 listener = new TcpListener(ipHost, 7080);
     listener.Start();//开启监听

 Socket remoteSocketClient = listener.AcceptSocket();
     device = new Device(remoteSocketClient);
//开启一个线程去处理
     threaddev = new Thread(new ThreadStart(device.Scan));
     device.curentThread = threaddev;
     threaddev.IsBackground = true;
     threaddev.Start();

Scan处理方法:

string[] items = strGetContent.Split(';');
     string filelength = items[0].Substring(items[0].IndexOf("=") + 1);
     string filename = items[1].Substring(items[1].IndexOf("=") + 1);
 //文件保存完整路径
       filePath = Path.Combine(directoryPath, filename);
//断点位置
      long position = 0;
      if (File.Exists(filePath))
      {
       using (FileStream reader = new FileStream(filePath, FileMode.Open, FileAccess.Read, FileShare.None))
       {
        position = reader.Length;
       }
      }
//返回消息
 response = "position=" + position + ";serviceurl=" + dirPath + "/" + filename) ;

      //服务器收到客户端的请求信息后,给客户端返回响应信息:;position=0
      //serviceurl 服务生保存的文件位置 /PlayFiles/video/2016/07/04/1141142221.mp4
      bufferSend = Encoding.UTF8.GetBytes(response);
      remoteSocketClient.Send(bufferSend);

然后处理续传内容:

//获得文件内容
      byte[] buffer = new byte[BufferSize];
      int received = 0;
      long receive, length = long.Parse(filelength);
      FileInfo file = new FileInfo(filePath);
      using (FileStream writer = file.Open(file.Exists ? FileMode.Append : FileMode.CreateNew, FileAccess.Write, FileShare.None))
      {
       receive = writer.Length;
       while (receive < length)
       {
        if ((received = remoteSocketClient.Receive(buffer)) == 0)
        {
         Program.MessageAdd(" IP【" + remoteSocketClient.RemoteEndPoint.ToString() + "】接收暂停!");
         break;
        }
        writer.Write(buffer, 0, received);
        writer.Flush();
        receive += (long)received;
       }

      }

if (receive == length)
      {
       Program.MessageAdd(" IP【" + remoteSocketClient.RemoteEndPoint.ToString() + "】接收" + filename + "完成!");
}

主要原理还是从断点位置上传和接收。

这里只是讲了最主要的代码功能,还有很多细节处理,比如终端要显示进度,所以还要保存进度,后端文件的保存会不会错位,还有多文件上传会不会乱,多客户端上传是创建新线程还是有线程池来处理等等 。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我们。

(0)

相关推荐

  • Android使用socket创建简单TCP连接的方法

    本文实例讲述了Android使用socket创建简单TCP连接的方法.分享给大家供大家参考,具体如下: 不管是在Java还是Android编程中,通信都是及其重要的一部分.有连接的socket编程,重要性自然毋庸置疑. 这里以一个简单的demo演示一个最基本的socket编程. 先写服务端.服务端是Java代码.笔者懒得装eclipse等编程软件,就是直接notepad编程,dos运行的.服务端一般是新建一个绑定端口的serversocket,监听客户端请求(死循环监听).当接收到客户端消息时,

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

    本文实例讲述了Android编程使用HTTP协议与TCP协议实现上传文件的方法.分享给大家供大家参考,具体如下: Android上传文件有两种方式,第一种是基于Http协议的HttpURLConnection,第二种是基于TCP协议的Socket. 这两种方式的区别是使用HttpURLConnection上传时内部有缓存机制,如果上传较大文件会导致内存溢出.如果用TCP协议Socket方式上传就会解决这种弊端. HTTP协议HttpURLConnection 1. 通过URL封装路径打开一个Ht

  • Android TCP 文件客户端与服务器DEMO介绍

    主要功能是: 1.TCP服务器提供文件下载服务,服务器支持多线程. 2.TCP Client从服务器上下载指定的文件,Client也支持多线程. 首先是服务器,服务器是在PC机上,JAVA运行环境,主要参考网上的代码,自己做了支持多线程处理,代码如下: 复制代码 代码如下: //file:DownloadServer.java import java.net.*;import java.io.*;class ServerOneDownload extends Thread {    privat

  • Android下使用TCPDUMP实现数据抓包教程

    如果想分析Android下 某个APP的网络数据交互,需要在Android手机上抓包,最常用的抓包工具非tcpdump莫属,用tcpdump生成Wireshark识别的 pcap文件,然后将pcap文件下载到电脑上,用电脑上的Wireshark加载pcap文件,通过Wireshark分析tcpdump抓取的数据. 一.安装tcpdump 为Android手机安装tcpdump,首先必须将Android手机root,现在市面上常用的root工具都很傻瓜很强大,推荐使用root精灵,将手机root以

  • Android编程实现TCP、UDP客户端通信功能示例

    本文实例讲述了Android编程实现TCP.UDP客户端通信功能.分享给大家供大家参考,具体如下: 在进行Android开发的过程中,免不了,要开发TCP/UDP通讯的程序,下面这两段代码,分别介绍了TCP/UCP通过的一个实例: 代码一 TCP通讯: private void tcpdata() { try { Socket s = new Socket("192.168.0.25", 65500); // outgoing stream redirect to socket Out

  • android的UDP编程实例

    一.有的手机不能直接接收UDP包,可能是手机厂商在定制Rom的时候把这个功能给关掉了.1.可先在oncreate()方法里面实例化一个WifiManager.MulticastLock 对象lock:具体如下: 复制代码 代码如下: WifiManager manager = (WifiManager) this                .getSystemService(Context.WIFI_SERVICE);WifiManager.MulticastLock lock= manag

  • Android中实现TCP和UDP传输实例

    TCP和UDP在网络传输中非常重要,在Android开发中同样重要. 首先我们来看一下什么是TCP和UDP. 什么是TCP? TCP:Transmission Control Protocol 传输控制协议TCP是一种面向连接(连接导向)的.可靠的.基于字节流的运输层(Transport layer)通信协议,由IETF的RFC 793说明(specified).在简化的计算机网络OSI模型中,它完成第四层传输层所指定的功能.应用层向TCP层发送用于网间传输的.用8位字节表示的数据流,然后TCP

  • Android编程实现TCP客户端的方法

    本文实例讲述了Android编程实现TCP客户端的方法.分享给大家供大家参考,具体如下: 因为项目上需要实现一个TCP Client 端:在网上找好多例子基本上都是阻塞方式完成: 我的实现例子:由Activity 及sever 来实现,在sever 创建一个线程来监听接受数据.收到数据,通过广播发送给Activity; 服务端我没有去实现,你可以下载TCP Socket 调试工具v2.2:创建个9005端口:客户端:访问的IP为10.0.2.2 AnetTest.java: /** * Copy

  • Android中使用tcpdump、wireshark进行抓包并分析技术介绍

    本文主要介绍如何使用tcpdump和wireshark对Android应用程序进行抓包并分析,需要说明的是在抓包之前,你的Android设备必须root过了,另外你的电脑必须有Android SDK环境. 下载并安装tcpdump tcpdump链接:http://www.tcpdump.org/ 选择一个版本下载并解压提取出其中呃tcpdump文件,然后push到你的手机上去: 复制代码 代码如下: adb push c:\tcpdump /data/local/tcpdump 进一步操作:

  • Android实现TCP客户端接收数据的方法

    本文实例讲述了Android实现TCP客户端接收数据的方法.分享给大家供大家参考,具体如下: 配合log4net使用,用来接收调试信息.因此,此客户端只管通过TCP接收字符串数据,然后显示在界面上. 接收TCP数据 try { Socket s = new Socket("192.168.1.5", 8240); InputStream inputStream = s.getInputStream(); DataInputStream input = new DataInputStre

  • Android网络编程之UDP通信模型实例

    什么是Android UDP? UDP是User Datagram Protocol的简称,中文名是用户数据包协议,是OSI参考模型中一种无连接的传输层协议,提供面向事务的简单不可靠信息传送服务.它是IETF RFC 768是UDP的正式规范.在网络中它与TCP协议一样用于处理数据包.在OSI模型中,在第四层-传输层,处于IP协议的上一层.UDP有不提供数据报分组.组装和不能对数据包的排序的缺点,也就是说,当报文发送之后,是无法得知其是否安全完整到达的.UDP用来支持那些需要在计算机之间传输数据

随机推荐