Jc.FTP 2.0.2

Jc.FTP

ftp服务，客户端模块

服务端

创建FTP服务

 void FTPServer()
 {
     //the PKCS7 certificate file 
     string CertificatePath=null;
     
     //the PKCS7 certificate password
     string CertificatePassword=null;
     
     //根目录
     string BasePath = "/Users/jackerkun/Downloads";
     
     //密钥
     X509Certificate certificate = null;
     if (!string.IsNullOrEmpty(CertificatePath))
     {
         certificate = new X509Certificate(CertificatePath, CertificatePassword);
     }

     //文件夹对象
     var fileProviderFactory = new SimpleFileProviderFactory(BasePath);
     
     //数据链接对象
     var dataConnectionFactory =
         certificate == null
             ? new LocalDataConnectionFactory()
             : (IDataConnectionFactory) new SslLocalDataConnectionFactory(certificate);
     
     //SSL安全认证对象
     var controlConnectionSslFactory = certificate == null ? null : new ControlConnectionSslFactory(certificate);

     //匿名用户
     //var authenticator = new AnonymousAuthenticator();
     
     //单用户
     //var authenticator = new SingleAuthenticator("admin", "admin"); 
     
     //多用户
     var authenticator = new MultiAuthenticator(new List<KeyValuePair<string, string>>()
     {
         new KeyValuePair<string, string>("admin", "admin"),
         new KeyValuePair<string, string>("CEX", "CEX")
     });
     
     //IP节点
     var endpoiint = new IPEndPointData
     {
         Address = IPAddress.Any,
         Port = 21,
     };
   
     //启动服务:支持多个重载
     var server = new JcFTPServer(
         endpoiint,
         fileProviderFactory,
         authenticator,
         dataConnectionFactory,
         controlConnectionSslFactory
         );
     
     //增加连接监听
     server.Tracer.UserConnected += new FtpTracer.UserEventHandler(FtpConnect);
     //增加断开监听
     server.Tracer.UserDisconnected += new FtpTracer.UserEventHandler(FtpDisconnected);
     //增加指令监听
     server.Tracer.CommandInvoked += new FtpTracer.FtpCommandInvokedHandler(FtpCommand);
     //增加回复指令监听
     server.Tracer.ReplyInvoked += new FtpTracer.FtpReplyInvokedHandler(FtpReply);
     var cancelSource = new CancellationTokenSource();
     var serverInter= server.RunAsync(cancelSource.Token)
         .ContinueWith(result =>
         {
             if (result.Exception != null)
             {
                 Console.WriteLine($"Server at {endpoiint} has stopped because of: \n{result.Exception.Message}\n");
             }
             else
             {
                 Console.WriteLine($"Server at {endpoiint} has stopped successfully.");
             }
         });
     
     //停止
     //cancelSource.Cancel();
     //Task.WaitAll(serverInter);

     //获取已经链接的ip
     //var connectUsers=server.Tracer.ConnectedUsersView;
 }
 
 void FtpDisconnected(IPEndPoint ipEndPoint)
 {
     Console.WriteLine("Disconnected>"+ipEndPoint.Address);
 }

 void FtpConnect(IPEndPoint ipEndPoint)
 {
     Console.WriteLine("Connected>"+ipEndPoint.Address);
 }
 
 void FtpCommand(string command, IPEndPoint remoteAddress)
 {
     Console.WriteLine($"Command>{command}:{remoteAddress.Address}");
 }

 void FtpReply(string replyCode, IPEndPoint remoteAddress)
 {
     Console.WriteLine($"Reply>{replyCode}:{remoteAddress.Address}");
 } 

客户端

void FTPTest()
{
    JcFTPClient _ftphelper = new JcFTPClient(new Uri("ftp://127.0.0.1:21"), "CEX", "CEX");
    //添加事件
   _ftphelper.FtpError              += Ftphelper_FtpError;
   _ftphelper.FileDownloadCompleted += Ftphelper_FileDownloadCompleted;
   _ftphelper.FileDownloading       += Ftphelper_FileDownloading;
   _ftphelper.FileUploadCompleted   += Ftphelper_FileUploadCompleted;
   _ftphelper.FileUploading         += Ftphelper_FileUploading;
    //开始链接
    if (true == _ftphelper.Connect())
    {
       //切换目录
       _ftphelper.GotoDirectory("/");
       var res = _ftphelper.ListFilesAndFolders();
       var filDownload= _ftphelper.DownloadFileAsync(res[0].FullName, "/Users/jackerkun/Downloads/1.docx", false);
    }
}

//文件下载中回调
void Ftphelper_FileDownloading(object sender, EventArgs e)
{
}

//文件上传中回调
void Ftphelper_FileUploading(object sender, EventArgs e)
{
}

//错误回调
void Ftphelper_FtpError(object sender, EventArgs e)
{
}

//文件下载完成
void Ftphelper_FileDownloadCompleted(object sender, EventArgs e)
{
}

//文件上传完成
void Ftphelper_FileUploadCompleted(object sender, EventArgs e)
{
}