1

私はFTPの初心者です.StreamWriterを使用してFTPでファイルに書き込もうとしています.ファイルに書き込んだ後、やらなければならない作業があるのでストリームを閉じたくありません.後で約1時間後に同じstreamWriterを使用して書き込もうとすると、上記のエラーが発生します。以下は私のコードスニペットです

public void WriteToFTP()
    {
        bool isConnectionEstablished = false;
        StreamWriter stream = null;
        try
        {
            for (int i = 1; i < 5; i++)
            {
                string message = string.Format("File - {0}.", i.ToString());
                if (!isConnectionEstablished)
                {
                    FtpWebRequest request = (FtpWebRequest)WebRequest.Create(new Uri("My FTP path"));
                    request.Credentials = new NetworkCredential("asdf", "asdf@123");
                    request.Proxy = null;
                    request.UseBinary = true;
                    request.ConnectionGroupName = string.Empty;
                    request.UsePassive = true;
                    request.EnableSsl = false;
                    isConnectionEstablished = true;
                    stream = new StreamWriter(request.GetRequestStream()) { AutoFlush = true };
                }
                stream.WriteLine(message);//Here i am getting the error for the i = 2(after doing my work)
                //Doing work which may take more than 1 hour.
            }
        }
        catch (Exception exe)
        {
            //The Error "Unable to write data to the transport connection: An existing connection was forcibly closed by the remote host" is being caught here.
        }
        finally
        {
            if (stream != null)
                stream.Close();
        }
    }
4

1 に答える 1

0

タイムアウトを無限大に設定する必要があります。-1 は無限大の値です。次の例を参照してください。

    FtpWebRequest reqFTP;

    string fileName = @"c:\downloadDir\localFileName.txt";
    FileInfo downloadFile = new FileInfo(fileName);
    string uri = "ftp://ftp.myftpsite.com/ftpDir/remoteFileName.txt";


    FileStream outputStream = new FileStream(fileName, FileMode.Append);

    reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri));
    reqFTP.Method = WebRequestMethods.Ftp.DownloadFile;
    reqFTP.UseBinary = true;
    reqFTP.KeepAlive = false;
    reqFTP.Timeout = -1;
    reqFTP.UsePassive = true;
    reqFTP.Credentials = new NetworkCredential("userName", "passWord");
    FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
    Stream ftpStream = response.GetResponseStream();
    long cl = response.ContentLength;
    int bufferSize = 2048;
    int readCount;
    byte[] buffer = new byte[bufferSize];
    readCount = ftpStream.Read(buffer, 0, bufferSize);
    Console.WriteLine("Connected: Downloading File");
    while (readCount > 0)
    {
        outputStream.Write(buffer, 0, readCount);
        readCount = ftpStream.Read(buffer, 0, bufferSize);
        Console.WriteLine(readCount.ToString());
    }

    ftpStream.Close();
    outputStream.Close();
    response.Close();
    Console.WriteLine("Downloading Complete");
于 2013-05-30T10:04:40.493 に答える