Android實(shí)現(xiàn)TCP斷點(diǎn)上傳 后臺(tái)C#服務(wù)接收
終端實(shí)現(xiàn)大文件上傳一直都是比較難的技術(shù),其中涉及到后端與前端的交互,穩(wěn)定性和流量大小,而且實(shí)現(xiàn)原理每個(gè)人都有自己的想法,后端主流用的比較多的是Http來(lái)實(shí)現(xiàn),因?yàn)榇蠖鄬?shí)現(xiàn)過斷點(diǎn)下載。但穩(wěn)定性不能保證,一旦斷開,無(wú)法續(xù)傳。所以得采用另一種流行的做法,TCP上傳大文件。
網(wǎng)上查找了一些資料,大多數(shù)是斷點(diǎn)下載,然后就是單獨(dú)的C#端的上傳接收,或是HTTP的,或是只有android端的,由于任務(wù)緊所以之前找的首選方案當(dāng)然是Http先來(lái)實(shí)現(xiàn)文件上傳,終端采用Post方法,將文件直接傳至后端,后端通過File來(lái)獲得。
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);
還有其它更好的處理方法,也可以傳流進(jìn)來(lái),不通過file文件格式。 在網(wǎng)絡(luò)好的情況下沒什么問題,但網(wǎng)絡(luò)差點(diǎn)后來(lái)經(jīng)常上傳一半掉線或多個(gè)客戶端上傳出現(xiàn)連不上的情況,對(duì)于大文件極不穩(wěn)定,所以趕緊研發(fā)TCP協(xié)議文件斷點(diǎn)上傳。
也有網(wǎng)友實(shí)現(xiàn)了Http斷點(diǎn)上傳,既然大文件不行,那就將文件分割成小文件來(lái)上傳,純NET的主要方法:
上傳:
bool result = true;
long cruuent = 0;
FileStream fStream = new FileStream(fileName, FileMode.Open, FileAccess.Read);
BinaryReader bReader = new BinaryReader(fStream);
//模擬斷點(diǎn)上傳,第一次只上傳 100 個(gè)字節(jié)
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為斷點(diǎn)的位置,即已經(jīng)上傳了的大小,然后循環(huán)上傳所有包。
后臺(tái)接收:
/// <summary>
/// 保存文件(從URL參數(shù)中獲取文件名、當(dāng)前指針,將文件流保存到當(dāng)前指針后)
/// 如果是第一次上傳,則當(dāng)前指針為0,代碼執(zhí)行與續(xù)傳一樣,只不過指針沒有偏移
/// </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 + "http://UpLoad//" + fileName;
FileStream fStream = new FileStream(fileName, FileMode.OpenOrCreate, FileAccess.ReadWrite);
//偏移指針
fStream.Seek(npos, SeekOrigin.Begin);
//從客戶端的請(qǐng)求中獲取文件流
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();
}
}
重點(diǎn)在 fStream.Seek(npos, SeekOrigin.Begin); 從斷點(diǎn)位置接收保存。
有興趣的可以自己實(shí)現(xiàn)。
現(xiàn)在主要講講客戶端TCP上傳,后臺(tái)TCP接收,主要思路為:android端讀取本地文件將文件名,文件大小上傳至服務(wù)器(文件名必須是全局唯一),服務(wù)器將根據(jù)文件名查詢是否上傳過,若是上傳過,將已傳文件的大小即斷點(diǎn)位置傳給終端,終端接收后先保存斷點(diǎn)位置,然后從斷點(diǎn)位置讀取文件斷續(xù)上傳,直到全部完成。若沒上傳過則服務(wù)器創(chuàng)建緩存文件接收。
看看代碼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());//發(fā)送
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);//斷點(diǎn)位置
final String serviceurl = items[1].substring(items[1].indexOf("=") + 1);//保存到服務(wù)器路徑
RandomAccessFile fileOutStream = new RandomAccessFile(uploadFile, "r");
fileOutStream.seek(Integer.valueOf(position));//從斷點(diǎn)位置開始讀取文件
byte[] buffer = new byte[1024];
int len = -1;
int length = Integer.valueOf(position);//已經(jīng)上傳的大小,用于本地顯示
while ( (len = fileOutStream.read(buffer)) != -1) {
outStream.write(buffer, 0, len);
length += len;
Message msg = new Message();
msg.getData().putInt("size", length);
// 更新上傳的進(jìn)度 handler.sendMessage(msg);
} if (length == uploadFile.length()) {//如果相等,則說明上傳成功} fileOutStream.close(); outStream.close(); inStream.close(); socket.close();
后端處理:
private static TcpListener listener;//服務(wù)器監(jiān)聽
IPAddress ipHost = IPAddress.Any;
listener = new TcpListener(ipHost, 7080);
listener.Start();//開啟監(jiān)聽
Socket remoteSocketClient = listener.AcceptSocket();
device = new Device(remoteSocketClient);
//開啟一個(gè)線程去處理
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);
//斷點(diǎn)位置
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) ;
//服務(wù)器收到客戶端的請(qǐng)求信息后,給客戶端返回響應(yīng)信息:;position=0
//serviceurl 服務(wù)生保存的文件位置 /PlayFiles/video/2016/07/04/1141142221.mp4
bufferSend = Encoding.UTF8.GetBytes(response);
remoteSocketClient.Send(bufferSend);
然后處理續(xù)傳內(nèi)容:
//獲得文件內(nèi)容
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 + "完成!");
}
主要原理還是從斷點(diǎn)位置上傳和接收。
這里只是講了最主要的代碼功能,還有很多細(xì)節(jié)處理,比如終端要顯示進(jìn)度,所以還要保存進(jìn)度,后端文件的保存會(huì)不會(huì)錯(cuò)位,還有多文件上傳會(huì)不會(huì)亂,多客戶端上傳是創(chuàng)建新線程還是有線程池來(lái)處理等等 。
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
- 快速解決C# android base-64 字符數(shù)組的無(wú)效長(zhǎng)度問題
- C#之Android手機(jī)App開發(fā)
- C#開發(fā)Android百度地圖手機(jī)應(yīng)用程序(多地圖展示)
- Android仿微信菜單(Menu)(使用C#和Java分別實(shí)現(xiàn))
- Android下拉列表(Spinner)效果(使用C#和Java分別實(shí)現(xiàn))
- Android相冊(cè)效果(使用C#和Java分別實(shí)現(xiàn))
- C#采用Winform實(shí)現(xiàn)類似Android的Listener
- 詳解C#開發(fā)Android應(yīng)用程序的流程
相關(guān)文章
android基礎(chǔ)總結(jié)篇之九:Intent應(yīng)用詳解
這篇文章主要介紹了android基礎(chǔ)總結(jié)篇之九:Intent應(yīng)用詳解,有需要的可以了解一下。2016-11-11
Android形狀圖形與狀態(tài)列表圖形及九宮格圖片超詳細(xì)講解
這篇文章主要介紹了Android形狀圖形與狀態(tài)列表圖形及九宮格圖片的應(yīng)用方法,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)吧2022-09-09
Android開發(fā)壁紙的驗(yàn)證設(shè)置和確認(rèn)功能實(shí)現(xiàn)demo
android?wallpaper包括鎖屏壁紙和桌面壁紙,壁紙又區(qū)分靜態(tài)和動(dòng)態(tài)兩種。本文詳細(xì)介紹靜態(tài)壁紙?jiān)O(shè)置和確認(rèn),有需要的朋友可以借鑒參考下,希望能夠有所幫助2022-04-04
Flutter 實(shí)現(xiàn)網(wǎng)易云音樂字幕的代碼
這篇文章主要介紹了Flutter 實(shí)現(xiàn)網(wǎng)易云音樂字幕的代碼,本文通過實(shí)例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2020-04-04
Android 將網(wǎng)絡(luò)的Url資源轉(zhuǎn)換為Drawable資源方式
這篇文章主要介紹了Android 將網(wǎng)絡(luò)的Url資源轉(zhuǎn)換為Drawable資源方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過來(lái)看看吧2020-03-03
Android黑科技之讀取用戶短信+修改系統(tǒng)短信數(shù)據(jù)庫(kù)
這篇文章主要介紹了Android黑科技之讀取用戶短信+修改系統(tǒng)短信數(shù)據(jù)庫(kù) 的相關(guān)資料,需要的朋友可以參考下2015-12-12
Android編程計(jì)算函數(shù)時(shí)間戳的相關(guān)方法總結(jié)
這篇文章主要介紹了Android編程計(jì)算函數(shù)時(shí)間戳的相關(guān)方法,結(jié)合實(shí)例形式總結(jié)分析了Android Java、Native、Kernel時(shí)間戳計(jì)算相關(guān)操作技巧,需要的朋友可以參考下2017-05-05
Android項(xiàng)目仿UC瀏覽器和360手機(jī)衛(wèi)士消息常駐欄(通知欄)
本篇文章主要介紹了Android項(xiàng)目仿UC瀏覽器和360手機(jī)衛(wèi)士消息常駐欄(通知欄),可以仿照360的通知欄,有興趣的可以了解一下。2016-11-11

