c++服务器与android通过socket网络编程进行文件传输解决方案

Admin

@author：郑海波
注：该博文隶属于项目《基于C/S模式的android手机与PC机通信系统的开发》。
项目视频演示：http://v.youku.com/v_show/id_XNDgyNzcwNjY4.html
项目下载地址：http://dl.vmall.com/c0unoqaz9o
编程思想：
C++作为服务器，android作为客户端，通过android设备的wifi使手机与电脑连接于同一个局域网内，然后建立基于TCP/IP协议的socket连接。然后进行文件传输。
Java与c++数据类型的匹配问题
《C++服务器与java进行socket通信案例》这篇博文讲述了有关int型等数据类型的转换。主要思路是：将所有的数据类型都转化为byte流，对byte流进行传输。在这里，c++服务器用char类型的数组，android用byte数组进行文件传输。
首先看一下服务器端的C++核心代码：
[文件传输的线程函数]
[c++ core codes]

1. DWORD WINAPI GetFileForAndroidThread(LPVOID lparam)
   
2. {
   
3.         GetFileLparam *mData=(GetFileLparam*)lparam;
   
4.         COMMAND cmd;
   
5.         FILEINFO fi;
   
6.         memset((char*)&fi, 0, sizeof(fi));
   
7.         memset((char*)&cmd, 0, sizeof(cmd));
   
8.         cmd.ID = mData->command.ID;
   
9.         CFile file;
   
10.         int nChunkCount = 0;
    
11.         if(file.Open((char*)mData->command.lparam, CFile::modeRead|CFile::typeBinary))//打开要传输的文件
    
12.         {
    
13.                 int FileLen = file.GetLength();//获得文件的大小
    
14.                 fi.FileLen = file.GetLength();
    
15.                 strcpy((char*)fi.FileName, file.GetFileName());
    
16.                 memcpy((char*)&cmd.lparam, (char*)&fi, sizeof(fi));
    
17.                 send(mData->client, (char*)&cmd, sizeof(cmd), 0);//将文件名和文件发小发送给客户端
    
18.                 CString str="";
    
19.                 str.Format("filename=%s,filelen=%d",fi.FileName,fi.FileLen);
    
20.                 mData->pServerDlg->m_listOutput.AddString(str);
    
21.                 nChunkCount = FileLen/CHUNK_SIZE_FOR_ANDROID;//计算总共要发送多少块数据
    
22.                 if(FileLen%CHUNK_SIZE_FOR_ANDROID != 0)
    
23.                         nChunkCount++;
    
24.                 char *date = new char[CHUNK_SIZE_FOR_ANDROID];//为每块数据申请内存空间
    
25.                 CString temp;
    
26.                 for(int i=0; i<nChunkCount; i++)//循环发送每一块的数据
    
27.                 {
    
28.                         temp.Format("send the count%d",i);
    
29.             mData->pServerDlg->m_listOutput.AddString(temp);
    
30.                        
    
31.                         int nLeft;//定义剩余的数据长度
    
32.                        
    
33.                         if(i+1 == nChunkCount)
    
34.                                 nLeft = FileLen-CHUNK_SIZE_FOR_ANDROID*(nChunkCount-1);
    
35.                         else
    
36.                                 nLeft = CHUNK_SIZE_FOR_ANDROID;
    
37.                         int idx = 0;
    
38.                         file.Read(date, CHUNK_SIZE_FOR_ANDROID);
    
39.                        
    
40.                         while(nLeft>0)//直到第i块数据发送完
    
41.                         {
    
42.                                 int ret = send(mData->client, &date[idx], nLeft, 0);//发送数据
    
43.                                 if(ret == SOCKET_ERROR)
    
44.                                         mData->pServerDlg->m_listOutput.AddString("send data error,please try again! NUPT");
    
45.                                
    
46.                                 nLeft -= ret;
    
47.                                 idx += ret;
    
48.                         }
    
49.                 }
    
50.                 file.Close();//关闭文件
    
51.                 delete[] date;//释放内存空间
    
52.         }
    
53.     return 0;//返回
    
54. }
    
55. 
    

复制代码

其次，再看一下android客户端的java核心代码：

1. [由一个线程类，专门用于接收文件]
   
2. private class ThreadRecvAndWriteFile extends Thread {
   
3.                 String filename;
   
4.                 int FileLen;
   
5.                 FileOutputStream file;
   
6. 
   
7.                 // private byte []byteArrayData=new byte[CHUNK_SIZE];
   
8.                 public ThreadRecvAndWriteFile(String filename, int FileLen) {
   
9.                         this.filename = "/sdcard/" + filename;
   
10.                         this.FileLen = FileLen;
    
11.                 }
    
12. 
    
13.                 public void errorPro() {
    
14.                         byte errorDate[] = new byte[NetWorkErrorByte];
    
15.                         int errorLeft = NetWorkErrorByte;
    
16.                         int e_ret = 0;
    
17.                         int e_idx = 0;
    
18.                         while (errorLeft > 0) {
    
19.                                 // int ret=recv(server,&date[idx],nLeft,0);
    
20. 
    
21.                                 try {
    
22.                                         e_ret = app.mGlobalSocket.getInputStream().read(errorDate,
    
23.                                                         e_idx, errorLeft);
    
24.                                 } catch (Exception e) {
    
25.                                 }
    
26.                                 e_idx += e_ret;
    
27.                                 errorLeft -= e_ret;
    
28.                         }
    
29.                         for (int i = 0; i < errorDate.length; i++) {
    
30.                                 if (errorDate[i] != 0) {
    
31.                                         try {
    
32.                                                 file.write(errorDate, i, NetWorkErrorByte - i);
    
33.                                                 file.flush();
    
34.                                                 FileLen -= (NetWorkErrorByte - i);
    
35.                                                 break;
    
36.                                         } catch (IOException e) {
    
37.                                                 // TODO Auto-generated catch block
    
38.                                                 e.printStackTrace();
    
39.                                         }
    
40.                                 }
    
41.                         }
    
42.                 }
    
43. 
    
44.                 public void run() {
    
45.                         isFileDownload = false;
    
46.                         isDownloading=true;
    
47.                         if (!app.isLink) {
    
48.                                 return;
    
49.                         }
    
50.                         try {
    
51.                                 NetDataTypeTransform mTransform = new NetDataTypeTransform();
    
52.                                 File mFile = new File(filename);
    
53.                                 file = new FileOutputStream(mFile);
    
54.                                 errorPro();
    
55.                                 int nChunkCount = FileLen / CHUNK_SIZE_FOR_ANDROID;
    
56.                                 if (FileLen % CHUNK_SIZE_FOR_ANDROID != 0) {
    
57.                                         nChunkCount++;
    
58.                                 }
    
59.                                 mHandler.sendEmptyMessage(-1);
    
60. 
    
61.                                 for (int i = 0; i < nChunkCount; i++) {
    
62.                                         mHandler.sendEmptyMessage(i);
    
63.                                         byte date[] = new byte[CHUNK_SIZE_FOR_ANDROID];
    
64.                                         int nLeft;
    
65.                                         if (i + 1 == nChunkCount)// 最后一块
    
66.                                                 nLeft = FileLen - CHUNK_SIZE_FOR_ANDROID
    
67.                                                                 * (nChunkCount - 1);
    
68.                                         else
    
69.                                                 nLeft = CHUNK_SIZE_FOR_ANDROID;
    
70.                                         int idx = 0;
    
71.                                         int ret = 0;
    
72.                                         while (nLeft > 0) {
    
73.                                                 // int ret=recv(server,&date[idx],nLeft,0);
    
74.                                                 ret = 0;
    
75.                                                 try {
    
76.                                                         ret = app.mGlobalSocket.getInputStream().read(date,
    
77.                                                                         idx, nLeft);
    
78.                                                 } catch (Exception e) {
    
79.                                                         mHandler.sendEmptyMessage(-7);
    
80.                                                 }
    
81.                                                 idx += ret;
    
82.                                                 nLeft -= ret;
    
83.                                         }
    
84.                                         file.write(date, 0, idx);
    
85.                                         file.flush();
    
86.                                         Log.d("WriteFiles", "have recv count" + i);
    
87.                                 }
    
88.                                 file.close();
    
89.                                 File checkFile = new File(filename);
    
90.                                 if (checkFile.length() < FileLen) {
    
91.                                         isFileDownload = false;
    
92.                                         mHandler.sendEmptyMessage(0);
    
93.                                         return;
    
94.                                 } else {
    
95.                                         isFileDownload = true;
    
96.                                 }
    
97.                                 isDownloading=false;
    
98.                                 mHandler.sendEmptyMessage(MaxProgress);
    
99.                                 // Toast.makeText(app.getApplicationContext(),"文件以保存到"+filename,Toast.LENGTH_SHORT).show();
    
100.                         } catch (IOException e) {
     
101.                                 // TODO Auto-generated catch block
     
102.                                 e.printStackTrace();
     
103.                         }
     
104.                 }
     
105.         }

复制代码

解释：为什么会有public void errorPro()函数。之前的编程过程中，并没有这个函数。而且，在模拟器上测试的时候，没有出现任何的问题。然而，当android程序安装在手机上之后，我就发现：每次下载的文件都不能使用，打不开！但是文件的大小却和源文件相同。当时，我的推断是：肯定是在无线传输过程中出现了差错！要知道，对于一个可执行程序而言，即便有1bit出错，程序也不能正常运行。然而，事情并不是这样的！！既然服务器和客户端建立的是基于TCP/IP协议的连接，那么它们之间的传输应该是可靠的！于是，我便用二进制文件比较器，对下载的文件和源文件进行对比，发现了一个奇怪的现象：下载的文件的前684个字节竟然全为0，而后面的字节才和源文件一致，并且文件缺少源文件的684个字节。于是，我就编写了一个errorPro()函数，将前面的全0字节给忽略掉，而不影响文件的传输。最终，代码在模拟器上和手机上都运行的很好！而且下载很大的文件时，也没有出错！我现在还不知道为什么会有684字节的全0出现在文件头部，而在模拟器上测试时却没有。以后想清楚之后，在此补充完整。
附加：对于这个软件中的截图查看功能，也要用到下载模块。修改完这个bug之后，每次都能成功的查看电脑的桌面了。