0

ソケットを使用して、デスクトップ アプリケーションから Windows Phone アプリケーションにファイルを送信する作業を行っています。

私はデスクトップ ソケット サーバー アプリと Windows Phone アプリ (ソケット クライアント) を開発しました。どちらも 1MB 未満のファイルでうまく動作しています。つまり、1MB 未満のファイルをデスクトップ アプリから 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;
    }

早く返事をくれ...

ありがとう。

4

1 に答える 1

0

転送ごとにチャック単位の [4096] バイトでデータを送信します。このためには、クライアントとサーバーの両方でハンドシェイクが必要です。

于 2013-03-25T13:01:14.140 に答える