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

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

终端实现大文件上传一直都是比较难的技术,其中涉及到后端与前端的交互,稳定性和流量大小,而且实现原理每个人都有自己的想法,后端主流用的比较多的是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 + "完成!");
}

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

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

目录
相关文章
|
9天前
|
数据管理 API 数据库
探索Android Jetpack:现代安卓开发的利器
Android Jetpack是谷歌为简化和优化安卓应用开发而推出的一套高级组件库。本文深入探讨了Jetpack的主要构成及其在应用开发中的实际运用,展示了如何通过使用这些工具来提升开发效率和应用性能。
|
2天前
|
存储 Java 数据库连接
Android Java开发异步
【6月更文挑战第15天】
|
1天前
|
Java 开发工具 Android开发
探索安卓与iOS开发的核心差异
【6月更文挑战第20天】在移动应用开发的广阔天地中,安卓和iOS两大平台各自占据半壁江山。本文将深入探讨这两大操作系统在开发过程中的主要区别,包括编程语言、开发工具、用户界面设计哲学、系统架构以及市场分布等方面。通过对这些关键差异的分析,旨在为开发者提供一份实用的指南,帮助他们在面对项目决策时,能够更加明智地选择合适的平台,并针对特定平台优化他们的应用。
|
3天前
|
Java Android开发 Swift
探索Android与iOS开发的差异:平台选择对项目成功的影响
【6月更文挑战第18天】在移动应用开发的广阔天地中,Android和iOS两大平台各据一方,它们在市场份额、用户群体及开发环境上各有千秋。本文将深入分析这两个操作系统的开发差异,探讨如何根据项目需求选择合适的平台,并讨论跨平台解决方案的可行性与挑战。我们将通过实际案例,揭示平台选择对项目成功的关键性影响,为开发者提供决策支持。
|
3天前
|
安全 IDE Android开发
探索Android与iOS开发的差异:平台特性与编程实践
【6月更文挑战第17天】在移动应用开发的广阔天地中,Android和iOS两大平台各自占据半壁江山。它们在用户群体、系统架构以及开发环境上的差异,为开发者带来了不同的挑战和机遇。本文深入探讨了这两个平台在技术实现、界面设计、性能优化等方面的主要区别,并提供了实用的开发建议,旨在帮助开发者更好地理解各自平台的特性,从而创造出更加优秀的移动应用。
|
3天前
|
Dart IDE Linux
开发Android应用程序
开发Android应用程序
9 1
|
4天前
|
安全 JavaScript 前端开发
kotlin开发安卓app,JetPack Compose框架,给webview新增一个按钮,点击刷新网页
在Kotlin中开发Android应用,使用Jetpack Compose框架时,可以通过添加一个按钮到TopAppBar来实现WebView页面的刷新功能。按钮位于右上角,点击后调用`webViewState?.reload()`来刷新网页内容。以下是代码摘要:
|
4天前
|
人工智能 安全 物联网
【Android】安卓开发的前景
【Android】安卓开发的前景
14 1
|
6天前
|
安全 Android开发 iOS开发
探索Android与iOS开发的差异:平台特性与用户体验的对比分析
在移动应用开发的广阔天地中,Android和iOS两大阵营各据一方。本文将深入探讨这两个操作系统在开发环境、编程语言、用户界面设计及市场分布等方面的主要区别。通过比较分析,我们将揭示各自平台的特有优势,并讨论如何根据目标受众和业务需求选择适合的开发平台。
|
7天前
|
安全 Java Android开发
探索Android与iOS开发的差异与挑战
在移动应用开发的广阔天地里,Android和iOS两大平台各自占据半壁江山。本文将深入探讨这两个平台的开发环境、工具、语言以及设计理念的差异,并分析这些差异给开发者带来的挑战。我们将从多个角度出发,包括用户界面设计、性能优化、安全性考量、以及市场分布等方面,为读者提供一个全面的视角,以理解在这两个平台上进行开发时需要考虑的关键因素。