Simpel FTP Klient

FTP Forbindelsen skal arbejde i en tråd, således at denne klasse kan arbejde uafhængigt af andre enheder.

using System;
using System.IO;
using System.Text;
using System.Net.Sockets;
using System.Threading;

public class FtpClient
{
    private TcpClient ctrl;
    private NetworkStream ctrlstm;
    private TcpClient data;
    private NetworkStream datastm;
    private static void Send(NetworkStream stm, string line)
    {
        byte[] b = Encoding.Default.GetBytes(line);
        stm.Write(b, 0, b.Length);
    }
    private static string Receive(NetworkStream stm)
    {
        byte[] b = new byte[100000];
        int ix = 0;
        int n;
        while(stm.DataAvailable)
        {
            n = stm.Read(b, ix, b.Length - ix);
            ix += n;
        }
        return Encoding.Default.GetString(b, 0, ix);
    }
    public static string Command(NetworkStream stm, string cmd)
    {
        Send(stm, cmd + "\r\n");
        Thread.Sleep(50);
        return Receive(stm);
    }
    private void SetupData()
    {
        string dataaddr = Command(ctrlstm, "PASV");
        string[] addrparts = dataaddr.Split("()".ToCharArray())[1].Split(",".ToCharArray());
        string datahost = addrparts[0] + "." + addrparts[1] + "." + addrparts[2] + "." + addrparts[3];
        int dataport = int.Parse(addrparts[4]) * 256 + int.Parse(addrparts[5]);
        data = new TcpClient(datahost, dataport);
        datastm = data.GetStream();
    }
    public FtpClient(string host, string username, string password)
    {
        ctrl = new TcpClient(host, 21); 
        ctrlstm = ctrl.GetStream();
        Command(ctrlstm, "USER " + username);
        Command(ctrlstm, "PASS " + password);
    }
    public string Dir()
    {
        SetupData();
        Command(ctrlstm, "LIST");
        string res = Receive(datastm);
        Receive(ctrlstm);
        datastm.Close();
        data.Close();
        return res;
    }
    public string ShortDir()
    {
        SetupData();
        Command(ctrlstm, "NLST");
        string res = Receive(datastm);
        Receive(ctrlstm);
        datastm.Close();
        data.Close();
        return res;
    }
    public void MkDir(string dir)
    {
        Command(ctrlstm, "MKD " + dir);
    }
    public void RmDir(string dir)
    {
        Command(ctrlstm, "RMD " + dir);
    }
    public void ChDir(string dir)
    {
        Command(ctrlstm, "CWD " + dir);
    }
    public void UpLoad(string filename, bool binary)
    {
        if(binary)
        {
            Command(ctrlstm, "TYPE I");
        }
        else
        {
            Command(ctrlstm, "TYPE A");
        }
        SetupData();
        Command(ctrlstm, "STOR " + filename);
        Receive(ctrlstm);
        FileStream f = new FileStream(filename, FileMode.Open);
        byte[] b = new byte[100000];
        int ix = 0;
        int n;
        while(ix < f.Length)
        {
            n = f.Read(b, 0, b.Length);
            datastm.Write(b, 0, n);
            Thread.Sleep(100);
            ix += n;
        }
        f.Close();
        datastm.Close();
        data.Close();
    }
    public void DownLoad(string filename, bool binary)
    {
        if(binary)
        {
            Command(ctrlstm, "TYPE I");
        }
        else
        {
            Command(ctrlstm, "TYPE A");
        }
        SetupData();
        Command(ctrlstm, "RETR " + filename);
        Receive(ctrlstm);
        FileStream f = new FileStream(filename, FileMode.Create);
        byte[] b = new byte[100000];
        int n;
        while(datastm.DataAvailable)
        {
            n = datastm.Read(b, 0, b.Length);
            f.Write(b, 0, n);
            Thread.Sleep(100);
        }
        f.Close();
        datastm.Close();
        data.Close();
    }
    public void Logout()
    {
        Command(ctrlstm, "QUIT");
        ctrlstm.Close();
        ctrl.Close();
    }
}

class TestClass
{
    public static void Main(string[] args)
    {
        FtpClient cli = new FtpClient("localhost", "anonymous", "arne@");
        Console.WriteLine(cli.ShortDir());
        Console.WriteLine(cli.Dir());
        Directory.SetCurrentDirectory("C:\\");
        cli.DownLoad("z.zip", true);
        cli.MkDir("subdir");
        cli.ChDir("subdir");
        cli.UpLoad("z.zip", true);
        cli.Logout();
    }
}

(jeg har lidt ekstra funktionalitet liggende i VB.NET som nemt kan backportes til C#)

Hvis du ikke har fidus til min kode så:
  http://www.csharphelp.com/archives/archive9.html
  http://www.c-sharpcorner.com/Code/2003/April/FtpClient.asp

Jeg tester lige.

arne_v << jeg kunne godt tænke mig et par kommentarer i sourcen :)

Når jeg benytter:
Console.WriteLine(cli.ShortDir());
Console.WriteLine(cli.Dir());

Så får jeg en IndexOutOfBounds Exception.

Sandsyneligvis fordi din login fejler

Nej, for jeg kan sagtens: cli.MkDir("subdir");

Hvilken del af koden er ikke umiddelbart forståelig ?

og har tjekket på serveren. Mappen er oprettet.

Prøv at sætte Sleep i Command metoden lidt op så f.eks. til 200

(http://www.csharphelp.com/archives/archive9.html) -- Prøvede jeg faktisk før jeg oprettede dette spm. Jeg kunne kun få det til at lykkes af og til. Ofte hang det ved oprettelse af forbindelse.

Er det en langsom FTP server du skal have fat i ?

Det med Sleep hjalp ikke.
Jeg forsøger at connecte til en ProFTPd på en Debian maskine. Hvis jeg benytter en anden klient her på min PC så går det hurtigt.

Det sjove med FTPFactory er at det er rimelig langsomt, og det kun er af og til at der bliver oprettet forbindelse. Meget mystisk.

Supporterer din FTP server PASV mode ?

Fordi min kode virker kun med PASV !

Det gør den, ja.

Så må du jo nok til at debugge lidt.

    public static string Command(NetworkStream stm, string cmd)
    {
Console.WriteLine("SEND: " + cmd);
        Send(stm, cmd + "\r\n");
        Thread.Sleep(50);
        string resp = Receive(stm);
Console.WriteLine("RECV: " + resp);
        return resp;
    }

har du prøvet edtFTPnet
http://www.enterprisedt.com/index.html

den har jeg gode erfaringe med

arne << jeg debugger i morgen. Jeg vender tilbage. Tak for nu.

Kommet videre ?

Ja. Jeg kan virkelig ikke få det til at virke. Jeg har debugget og debugget. Forstår det ikke. Jeg har også prøvet sourcen fra de url du smed. En af dem (http://www.csharphelp.com/archives/archive9.html) kan jeg nogle gange få til at virke. Andre gange står den bare og 'hænger' jeg kan se på min ftp server at der er forbindelse men at klienten er IDLE, selvom jeg har sat den til at uploade en stor fil. Og filen findes ikke på serveren. :( I'm lost.

Kan du copy paste outpyt fra mit 27/01-2005 22:52:46 forslag, så kan jeg muligvis
sige noget ?

SEND: USER krogh
RECV:
SEND: PASS ****** (Har jeg fjernet :P )
RECV:
SEND: TYPE I
RECV:
SEND: PASV
RECV:

Herefter kommer følgende:
Project Project12.exe encountered unhandled exception class System.IndexOutOfRangeException. Process stopped. Use Step or Run to continue.

Jeg har lige prøvet at udfører de 4 kommandoer ved brug af telnet til ftp serveren. Der får jeg ingen fejl.

Får du et svar ?

Der er jo ikke noget svar fra serveren i ovenstående !

Prøv:

    public FtpClient(string host, string username, string password)
    {
        ctrl = new TcpClient(host, 21);
        ctrlstm = ctrl.GetStream();
        Thread.Sleep(250);
        Command(ctrlstm, "USER " + username);
        Command(ctrlstm, "PASS " + password);
        Thread.Sleep(250);
    }

Jeg får ikke noget svar når jeg bruger sourcen, nej.

Men nu oprettes forbindelsen.

Hvordan tester jeg så om den kan downloade en given fil til mit drev E.

F.eks. har jeg irfan.exe liggende i roden af min ftp konto.

Directory.SetCurrentDirectory("E:\\");
        cli.DownLoad("irfan.exe", true);

formoder jeg

Jeg prøvede lige at lave en: Console.WriteLine(cli.Dir());
Der fik jeg så igen min Exception.

-- gav også samme exception.

Hvilken Sleep tid kører du med i Command ?

200

Kan det hjælpe dig hvis jeg opretter en konto på min ftp server til dig?

måske ja

IP: 212.242.201.104 brugernavn: arne_v :: PASSWORD: dit brugernavn

Jeg benytter desuden C#Builder Personal fra borland.

Jeg prøver lige.

Jeg har også en C#Builder installeret omend jeg ikke bruger den meget.

Jeg kan lave en ShortDir og Dir men der ligger ingen filer ...

Nej. Mappen er tom.

FtpClient cli = new FtpClient("10.0.0.200", "arne_v", "arne_v");
Console.WriteLine(cli.ShortDir());
Console.WriteLine(cli.Dir());

Har jeg lige prøvet. Lykkes ikke for mig. Jeg får den der exception.

Kan du evt poste den source du lige benyttede?

Behøves ikke. Har vist fundet fejlen.

using System;
using System.IO;
using System.Text;
using System.Net.Sockets;
using System.Threading;

public class FtpClient
{
    private TcpClient ctrl;
    private NetworkStream ctrlstm;
    private TcpClient data;
    private NetworkStream datastm;
    private static void Send(NetworkStream stm, string line)
    {
        byte[] b = Encoding.Default.GetBytes(line);
        stm.Write(b, 0, b.Length);
    }
    private static string Receive(NetworkStream stm)
    {
        byte[] b = new byte[100000];
        int ix = 0;
        int n;
        while(stm.DataAvailable)
        {
            n = stm.Read(b, ix, b.Length - ix);
            ix += n;
        }
        return Encoding.Default.GetString(b, 0, ix);
    }

    public static string Command(NetworkStream stm, string cmd)
    {
Console.WriteLine("SEND: " + cmd);
        Send(stm, cmd + "\r\n");
        Thread.Sleep(200);
        string resp = Receive(stm);
Console.WriteLine("RECV: " + resp);
        return resp;
    }
    private void SetupData()
    {
        string dataaddr = Command(ctrlstm, "PASV");
        string[] addrparts = dataaddr.Split("()".ToCharArray())[1].Split(",".ToCharArray());
        string datahost = addrparts[0] + "." + addrparts[1] + "." + addrparts[2] + "." + addrparts[3];
        int dataport = int.Parse(addrparts[4]) * 256 + int.Parse(addrparts[5]);
        data = new TcpClient(datahost, dataport);
        datastm = data.GetStream();
    }
    public FtpClient(string host, string username, string password)
    {
        ctrl = new TcpClient(host, 21);
        ctrlstm = ctrl.GetStream();
        Command(ctrlstm, "USER " + username);
        Command(ctrlstm, "PASS " + password);
    }
    public string Dir()
    {
        SetupData();
        Command(ctrlstm, "LIST");
        string res = Receive(datastm);
        Receive(ctrlstm);
        datastm.Close();
        data.Close();
        return res;
    }
    public string ShortDir()
    {
        SetupData();
        Command(ctrlstm, "NLST");
        string res = Receive(datastm);
        Receive(ctrlstm);
        datastm.Close();
        data.Close();
        return res;
    }
    public void MkDir(string dir)
    {
        Command(ctrlstm, "MKD " + dir);
    }
    public void RmDir(string dir)
    {
        Command(ctrlstm, "RMD " + dir);
    }
    public void ChDir(string dir)
    {
        Command(ctrlstm, "CWD " + dir);
    }
    public void UpLoad(string filename, bool binary)
    {
        if(binary)
        {
            Command(ctrlstm, "TYPE I");
        }
        else
        {
            Command(ctrlstm, "TYPE A");
        }
        SetupData();
        Command(ctrlstm, "STOR " + filename);
        Receive(ctrlstm);
        FileStream f = new FileStream(filename, FileMode.Open);
        byte[] b = new byte[100000];
        int ix = 0;
        int n;
        while(ix < f.Length)
        {
            n = f.Read(b, 0, b.Length);
            datastm.Write(b, 0, n);
            Thread.Sleep(100);
            ix += n;
        }
        f.Close();
        datastm.Close();
        data.Close();
    }
    public void DownLoad(string filename, bool binary)
    {
        if(binary)
        {
            Command(ctrlstm, "TYPE I");
        }
        else
        {
            Command(ctrlstm, "TYPE A");
        }
        SetupData();
        Command(ctrlstm, "RETR " + filename);
        Receive(ctrlstm);
        FileStream f = new FileStream(filename, FileMode.Create);
        byte[] b = new byte[100000];
        int n;
        while(datastm.DataAvailable)
        {
            n = datastm.Read(b, 0, b.Length);
            f.Write(b, 0, n);
            Thread.Sleep(100);
        }
        f.Close();
        datastm.Close();
        data.Close();
    }
    public void Logout()
    {
        Command(ctrlstm, "QUIT");
        ctrlstm.Close();
        ctrl.Close();
    }
}

class TestClass
{
    public static void Main(string[] args)
    {
        FtpClient cli = new FtpClient("212.242.201.104", "arne_v", "arne_v");
        Console.WriteLine(cli.ShortDir());
        Console.WriteLine(cli.Dir());
        cli.Logout();
    }
}

SEND: USER arne_v
RECV: 220 ProFTPD 1.2.5rc1 Server (Net4all.dk) [net4all]
331 Password required for arne_v.

SEND: PASS arne_v
RECV: 230 User arne_v logged in.

SEND: PASV
RECV: 227 Entering Passive Mode (212,242,201,104,108,24)

SEND: NLST
RECV: 550 No files found.


SEND: PASV
RECV: 227 Entering Passive Mode (212,242,201,104,108,25)

SEND: LIST
RECV: 150 Opening ASCII mode data connection for file list
226-Transfer complete.
226 Quotas off


SEND: QUIT
RECV: 221 Goodbye.

OK - så du har også hul igennem nu ?

Jep. Jeg prøvede bare for sjov at bruge min eksterne IP i stedet for min interne. Jeg kan kun bruge min eksterne. (Dog har jeg lige forsøgt med et FTP program at benytte den interne ip, det lykkes fint).

Smid et svar - du fortjener point :)

ok

Jeg skal understrege at min kode er ikke production quality. Den viser hvordan
man gør. Diverse fejl håndtering skal ligges ind for at den bliver robust.

Jep. Bl.a. hvis man forsøger at hente / sende en fil der ikke findes :)

Tak for hjælpen.