получение большого файла с использованием сокета Windows Phone

Я работаю над отправкой файла из настольного приложения в приложение для Windows Phone, используя сокет.

Я разработал приложение сервера сокетов для настольных компьютеров и приложение для Windows Phone (клиент сокетов), оба хорошо работают с файлом размером менее 1 МБ, что означает, что я могу передать файл размером менее 1 МБ в приложение для Windows Phone из настольного приложения.

И теперь моя проблема заключается в отправке большого файла, что приводит к сбою приложения, я отладил приложение, но оно зависнет после некоторой итерации.

Пожалуйста, проверьте приведенный ниже фрагмент кода для логики получения файлов на стороне Windows Phone.

Код :

    public string Receive()
    {
        string response = "Operation Timeout";
        int bytestrn = 0;
        int cnt = 0;
        byte[] data = new byte[2048 * 5000];
        if (socketClient != null)
        {                
            SocketAsyncEventArgs socketAsyncEventArgs = new SocketAsyncEventArgs();
            socketAsyncEventArgs.RemoteEndPoint = socketClient.RemoteEndPoint;
            socketAsyncEventArgs.SetBuffer(new Byte[MAX_BUFFER_SIZE*20000], 0, MAX_BUFFER_SIZE*20000);

            socketAsyncEventArgs.Completed += new EventHandler<SocketAsyncEventArgs>(delegate(object sender, SocketAsyncEventArgs e)
            {
                cnt++;
                if (e.SocketError == SocketError.Success)
                {                      

                    try
                    {
                        bytestrn += e.BytesTransferred;
                        if (e.BytesTransferred > 0)
                        {

                            if (bytestrn >= 2501829)                                
                            {
                                Buffer.BlockCopy(e.Buffer, 0, data, bytestrn - e.BytesTransferred, e.BytesTransferred);                                    
                                int fileNameLen = BitConverter.ToInt32(data, 0);
                                string fileName = Encoding.UTF8.GetString(data, 4, fileNameLen);
                                IsoFileName = fileName;
                                IsolatedStorageFile myIsolatedStorage = IsolatedStorageFile.GetUserStoreForApplication();

                                using (BinaryWriter writeFile = new BinaryWriter(new IsolatedStorageFileStream(IsoFileName, FileMode.Create, FileAccess.Write, myIsolatedStorage)))
                                {
                                    writeFile.Write(data, 4 + fileNameLen, bytestrn - 4 - fileNameLen);                                        
                                    writeFile.Close();
                                }
                                clientDone.Set();
                            }
                            else
                            {
                                if (cnt == 1)
                                {
                                    Buffer.BlockCopy(e.Buffer, 0, data, 0, e.BytesTransferred);
                                    //e.Buffer.CopyTo(data, 0);
                                }
                                else
                                {
                                    Buffer.BlockCopy(e.Buffer, 0, data, bytestrn - e.BytesTransferred, e.BytesTransferred);
                                    //e.Buffer.CopyTo(data, bytestrn - e.BytesTransferred);
                                }

                                clientDone.Reset();
                                socketClient.ReceiveAsync(e);
                                clientDone.WaitOne();
                            }
                            string test = "if";
                        }
                        else
                        {
                            clientDone.Set();
                            string test = "else";
                        }
                        //clientDone.Set();
                    }
                    catch (Exception exp)
                    {
                        string hi = "hi";
                    }                        
                }
                else
                {
                    response = e.SocketError.ToString();
                }

                clientDone.Set();
            });

            clientDone.Reset();
            socketClient.ReceiveAsync(socketAsyncEventArgs);
            clientDone.WaitOne();
        }
        else
        {
            response = "Socket is not initialized";
        }  // end of: if (socketClient != null)

        return response;
    }

Прошу ответить поскорее...

Спасибо.


person shoaib mijaki    schedule 25.03.2013    source источник


Ответы (1)


Отправляйте данные по частям [4096] байт за передачу. Для этого вам нужно рукопожатие как на клиенте, так и на сервере.

person Shashi    schedule 25.03.2013