Android和PC端通过局域网文件同步 Android和PC端通过局域网文件同步

public class FileOptions {
   public String name;
   public String path;
   public long size;
}
 
//Activity
public class MainActivity extends Activity {
   private TextView tvMsg;
   private EditText logShow, filePath;
   private Handler handler;
   private SocketManager socketManager;
   
   @Override
   protected void onCreate(Bundle savedInstanceState) {
      super.onCreate(savedInstanceState);
      setContentView(R.layout. activity_main);
      
      tvMsg = (TextView)findViewById(R.id. tvMsg);
      logShow = (EditText)findViewById(R.id. log_show);
      handler = new Handler(){
         @Override
         public void handleMessage(Message msg) {
           switch(msg. what){
           case 0:
              SimpleDateFormat format = new SimpleDateFormat("hh:mm:ss" );
              logShow.append( "\n[" + format.format(new Date()) + "]" + msg.obj .toString());
              break;
           case 1:
              tvMsg.setText( "请在PC端输入IP：" + GetIpAddress() + " 端口:" + msg.obj .toString());
              break;
           case 2:
             Toast. makeText(getApplicationContext(), msg.obj.toString(), Toast. LENGTH_SHORT).show();
              break;
           }
        }
      };
      socketManager = new SocketManager( handler);
   }
   @Override
   protected void onDestroy() {
      super.onDestroy();
      System. exit(0);
   }
   public String GetIpAddress() {  
     WifiManager wifiManager = (WifiManager) getSystemService(WIFI_SERVICE );  
     WifiInfo wifiInfo = wifiManager.getConnectionInfo();  
     int i = wifiInfo.getIpAddress();
     return (i & 0xFF) + "." +  
       ((i >> 8 ) & 0xFF) + "." +  
       ((i >> 16 ) & 0xFF)+ "." +  
        ((i >> 24 ) & 0xFF );  
   }  
}
 
//socket管理
public class SocketManager {
   private static final String FILE_PATH= "/glass";
   private static final String TAG = "SocketManager";
   private ServerSocket server;
   private Handler handler = null;
   private List<FileOptions> fileList;
 
   public SocketManager(Handler handler) {
      this. handler = handler;
      int port = 9999;
      while (port > 9000) {
         try {
           server = new ServerSocket(port);
           break;
        } catch (Exception e) {
           port--;
        }
      }
      SendMessage(1, port);
      Thread receiveFileThread = new Thread( new Runnable() {
         @Override
         public void run() {
           while ( true) { // 接收文件
              ReceiveFile();
           }
        }
      });
      receiveFileThread.start();
   }
 
   void SendMessage( int what, Object obj) {
      if ( handler != null) {
        Message. obtain( handler, what, obj).sendToTarget();
      }
   }
 
   // 接收文件
   void ReceiveFile() {
      Socket socketPC= null;
      try {
        GetAllFiles();
        socketPC = server.accept();
        InetAddress netAddr = socketPC.getInetAddress();
        String ipaddr = netAddr.getHostAddress();
        Log. w( TAG, ipaddr);
        OutputStream outputStream = socketPC.getOutputStream();
        JSONArray jsonArr= new JSONArray();
         for( int i=0;i< fileList.size();i++){
           try {
              JSONObject jsonObj= new JSONObject();
              jsonObj.put( "name", fileList.get(i). name);
              jsonObj.put( "path", fileList.get(i). path);
              jsonObj.put( "size", fileList.get(i). size);
              jsonArr.put(jsonObj);
           } catch (JSONException e) {
              // TODO Auto-generated catch block
              e.printStackTrace();
           }
        }
        
        String sendStr=jsonArr.toString();
         byte[] sendBuf=sendStr.getBytes( "GB2312");
        outputStream.write(sendBuf, 0, sendBuf. length);
        outputStream.flush();
        SendMessage(0, " 发送文件索引完成" );
        outputStream.close();
        socketPC.close();
        
         for( int i=0;i< fileList.size();i++){
           Socket fileSendSocket = server.accept();
           File fsend= new File( fileList.get(i). path);
           FileInputStream fis= new FileInputStream(fsend);
           OutputStream fos = fileSendSocket.getOutputStream();
           byte[] buf = new byte[1024];
           while ( true) { 
           int read = 0; 
           if (fis != null) { 
             read = fis.read(buf); 
           } 
           if (read == -1) { 
             break; 
           } 
           fos.write(buf,0,read); 
         }
           fos.flush();
           SendMessage(0, fileList.get(i). name+ "--文件传输完成" );
           fis.close();
           fos.close();
           fileSendSocket.close();
        }
        
      } catch (IOException e) {
         // TODO Auto-generated catch block
        e.printStackTrace();
      }
   }
 
   public void SendFile(ArrayList<String> fileName, ArrayList<String> path,
        String ipAddress, int port) {
      try {
         for ( int i = 0; i < fileName.size(); i++) {
           Socket name = new Socket(ipAddress, port);
           OutputStream outputName = name.getOutputStream();
           OutputStreamWriter outputWriter = new OutputStreamWriter(
                outputName);
           BufferedWriter bwName = new BufferedWriter(outputWriter);
           bwName.write(fileName.get(i));
           bwName.close();
           outputWriter.close();
           outputName.close();
           name.close();
           SendMessage(0, "正在发送" + fileName.get(i));
 
           Socket data = new Socket(ipAddress, port);
           OutputStream outputData = data.getOutputStream();
           FileInputStream fileInput = new FileInputStream(path.get(i));
           int size = -1;
           byte[] buffer = new byte[1024];
           while ((size = fileInput.read(buffer, 0, 1024)) != -1) {
              outputData.write(buffer, 0, size);
           }
           outputData.close();
           fileInput.close();
           data.close();
           SendMessage(0, fileName.get(i) + " 发送完成" );
        }
        SendMessage(0, "所有文件发送完成" );
      } catch (Exception e) {
        SendMessage(0, "发送错误:\n" + e.getMessage());
      }
   }
   //待优化
   private void GetAllFiles(){
      fileList= new ArrayList<FileOptions>();
      File rootPath= new File(Environment.getExternalStorageDirectory().getPath()+ FILE_PATH);
      File[] files = rootPath.listFiles(); // 列出所有文件
      for( int i=0;i<files. length;i++){
         if(files[i].isFile()){
           FileOptions fp= new FileOptions();
           fp. name=files[i].getName();
           fp. path=files[i].getPath();
           fp. size=files[i].length();
           fileList.add(fp);
        }
      }
   }
}

//PC端主要源码
//数据传输线程
DWORD WINAPI RecvThread(LPVOID lpParameter)
{
   SOCKET recvSocket = (SOCKET)lpParameter;
    int ret = 0,strLen=0;
    char recvBuffer[MAX_LEN],*pRecvAllData;
   Json::Reader reader;
   Json::Value jsonArr;
   
    while ( true )
   {
       /*
      
      */
      pRecvAllData=( char *)malloc(MAX_LEN);
       while ((ret = recv(recvSocket, recvBuffer, MAX_LEN, 0))>0){
         strLen+=ret;
         pRecvAllData=( char *)realloc(pRecvAllData,strLen);
         memcpy(pRecvAllData+strLen-ret,recvBuffer,ret);
      };
      
       if (!reader.parse(pRecvAllData, jsonArr)){
         Sleep(1000);
          continue ;
      }
       int jsonSize = jsonArr.size();
      CString strItem;
      fileList.RemoveAll();
       for (int j = 0; j < jsonSize; ++j) 
      { 
         std::string name = jsonArr[j][ "name" ].asString();
         std::string path = jsonArr[j][ "path" ].asString();
          int size = jsonArr[j][ "size" ].asInt();
         strItem.Format(TEXT( "%d" ), j+1);
         pFileRecvDlg->m_fileListCtrl.InsertItem(j,strItem.GetBuffer(0));
         pFileRecvDlg->m_fileListCtrl.SetItemText(j,0,strItem.GetBuffer(0));
         strItem=name.c_str();
         fileStr filest;
         filest.name=name;
         filest.size=size;
         fileList.AddTail(filest);
         pFileRecvDlg->m_fileListCtrl.SetItemText(j,1,strItem.GetBuffer(0));
      }
      free(pRecvAllData);
      closesocket(recvSocket);
 
      CRect rect;
      pFileRecvDlg->GetClientRect(&rect);
      pFileRecvDlg->ClientToScreen(rect);
       if (!pProgressDlg->IsWindowVisible()){
         pProgressDlg->ShowWindow(SW_SHOW);
      }
      pProgressDlg->SetWindowPos(NULL,rect.left+100,rect.top+100,0,0,SWP_NOSIZE);
      pFileRecvDlg->GetDlgItem(IDC_BUTTON_CONNECT)->EnableWindow(FALSE);
       // 发送文件名
       for (int i=0;i<jsonSize;i++){
         SOCKET nameSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
          int ret = connect(nameSocket,( struct sockaddr*)&ServerAddr, sizeof (ServerAddr));
          if ( ret == SOCKET_ERROR ){
            AfxMessageBox(_T( "connect 失败 "));
         } else {
         }
         FILE *fp;
          int tempCount=0;
         fileStr flst=fileList.GetAt(fileList.FindIndex(i));
         fopen_s(&fp,flst.name.c_str(), "wb+" );
         
         pProgressDlg->setFile(flst.name,flst.size);
          while ((ret = recv(nameSocket, recvBuffer, MAX_LEN, 0))!=0){
            fwrite(recvBuffer, sizeof (char ),ret,fp);
            tempCount+=ret;
            pProgressDlg->updateProgress(tempCount);
         }
         _fcloseall( );
         closesocket(nameSocket);
      }
      pFileRecvDlg->GetDlgItem(IDC_BUTTON_CONNECT)->EnableWindow(TRUE);
      pProgressDlg->ShowWindow(SW_HIDE);
   }
    return 0;
}
//连接按钮的响应函数
void CGlassFileRecvDlg::OnBnClickedButtonConnect()
{
    // TODO: 在此添加控件通知处理程序代码
    if (UpdateData()){
      BYTE nField0,nField1,nField2,nField3;
      m_IpAddrCtrl.GetAddress(nField0,nField1,nField2,nField3);
      WSADATA Ws;
      SOCKET CientSocket;
       int Ret = 0;
       int AddrLen = 0;
      HANDLE hThread = NULL;
       char SendBuffer[MAX_PATH];
 
       //Init Windows Socket
       if ( WSAStartup(MAKEWORD(2,2), &Ws) != 0 )
      {
          return ;
      }
       //Create Socket
      CientSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
       if ( CientSocket == INVALID_SOCKET )
      {
         MessageBox(_T( "socket 创建失败 " ));
          return ;
      }
 
       char strAddr[50],tempStr[10];
      memset(strAddr,0, sizeof (strAddr));
      memset(tempStr,0, sizeof (tempStr));
      itoa(nField0,tempStr,10);
      strcat(strAddr,tempStr);
      strcat(strAddr, "." );
      itoa(nField1,tempStr,10);
      strcat(strAddr,tempStr);
      strcat(strAddr, "." );
      itoa(nField2,tempStr,10);
      strcat(strAddr,tempStr);
      strcat(strAddr, "." );
      itoa(nField3,tempStr,10);
      strcat(strAddr,tempStr);
 
      ServerAddr.sin_family = AF_INET;
      ServerAddr.sin_addr.s_addr = inet_addr(strAddr);
      ServerAddr.sin_port = htons(m_port);
      memset(ServerAddr.sin_zero, 0x00, 8);
 
      Ret = connect(CientSocket,( struct sockaddr*)&ServerAddr, sizeof (ServerAddr));
       if ( Ret == SOCKET_ERROR ){
         MessageBox(_T( "connect 失败 "));
          return ;
      } else {
         HANDLE hThread = CreateThread(NULL, 0, RecvThread, (LPVOID)CientSocket, 0, NULL);
          if ( hThread == NULL ){
            MessageBox(_T( " 创建线程失败 "));
             return ;
         }
         CloseHandle(hThread);
      }
   }
}