/*
FTPFactory.cs
Better view with tab space=4
Written by Jaimon Mathew (jaimonmathew@rediffmail.com)
Rolander,Dan (Dan.Rolander@marriott.com) has modified the
download
method to cope with file name with path information. He also
provided
the XML comments so that the library provides Intellisense
descriptions.
use the following line to compile
csc /target:library /out:FTPLib.dll /r:System.DLL FTPFactory.cs
*/
using System;
using System.Threading;
using System.Net;
using System.IO;
using System.Text;
using System.Net.Sockets;
using System.Configuration;
namespace AudioCollect
{
/// <summary>
/// FTPFactory 的摘要说明。
/// </summary>
public class FTPFactory
{
static readonly log4net.ILog log = log4net.LogManager.GetLogger("log4net");
private string
remoteHost,remotePath,remoteUser,remotePass,mes;
private int remotePort,bytes;
private Socket clientSocket;
private int retValue;
private Boolean debug;
private Boolean logined;
private string reply;
private static int BLOCK_SIZE = 512;
Byte[] buffer = new Byte[BLOCK_SIZE];
Encoding ASCII = Encoding.ASCII;
public FTPFactory()
{
string FTPRemoteIP = ConfigurationSettings.AppSettings["FTPRemoteIP"];
int FTPRemotePort = Convert.ToInt32( ConfigurationSettings.AppSettings["FTPRemotePort"] );
string FTPUser = ConfigurationSettings.AppSettings["FTPUser"];
string FTPPassword = ConfigurationSettings.AppSettings["FTPPassword"];
remoteHost = FTPRemoteIP;
remotePath = ".";
remoteUser = FTPUser;
remotePass = FTPPassword;
remotePort =FTPRemotePort;
debug = false;
logined = false;
}
///
/// Set the name of the FTP server to connect to.
///
/// Server name
public void setRemoteHost(string remoteHost)
{
this.remoteHost = remoteHost;
}
///
/// Return the name of the current FTP server.
///
/// Server name
public string getRemoteHost()
{
return remoteHost;
}
///
/// Set the port number to use for FTP.
///
/// Port number
public void setRemotePort(int remotePort)
{
this.remotePort = remotePort;
}
///
/// Return the current port number.
///
/// Current port number
public int getRemotePort()
{
return remotePort;
}
///
/// Set the remote directory path.
///
/// The remote directory path
public void setRemotePath(string remotePath)
{
this.remotePath = remotePath;
}
///
/// Return the current remote directory path.
///
/// The current remote directory path.
public string getRemotePath()
{
return remotePath;
}
///
/// Set the user name to use for logging into the remote server.
///
/// Username
public void setRemoteUser(string remoteUser)
{
this.remoteUser = remoteUser;
}
///
/// Set the password to user for logging into the remote server.
///
/// Password
public void setRemotePass(string remotePass)
{
this.remotePass = remotePass;
}
///
/// Return a string array containing the remote directory's file list.
///
///
///
public string[] getFileList(string mask)
{
if(!logined)
{
login();
}
Socket cSocket = createDataSocket();
sendCommand("NLST " + mask);
if(!(retValue == 150 || retValue == 125))
{
throw new IOException(reply.Substring(4));
}
mes = "";
Thread.Sleep(700);
while(true)
{
if(cSocket.Connected)
{
int bytes = cSocket.Receive(buffer, buffer.Length, 0);
mes += ASCII.GetString(buffer, 0, bytes);
if(bytes < buffer.Length)
{
break;
}
}
else
{
log.Info("socket 连接断了！");
}
}
log.Info(mes);
char[] seperator = {'\n'};
string[] mess = mes.Split(seperator);
foreach(string fileName in mess)
{
log.Info(fileName);
}
cSocket.Close();
readReply();
if(retValue != 226)
{
throw new IOException(reply.Substring(4));
}
return mess;
}
public string[] getFileList()
{
if(!logined)
{
login();
}
Socket cSocket = createDataSocket();
sendCommand("LIST ");
if(!(retValue == 150 || retValue == 125))
{
throw new IOException(reply.Substring(4));
}
mes = "";
while(true)
{
int bytes = cSocket.Receive(buffer, buffer.Length, 0);
mes += ASCII.GetString(buffer, 0, bytes);
if(bytes < buffer.Length)
{
break;
}
}
log.Info(mes);
char[] seperator = {'\n'};
string[] mess = mes.Split(seperator);
cSocket.Close();
readReply();
if(retValue != 226)
{
throw new IOException(reply.Substring(4));
}
return mess;
}
///
/// Return the size of a file.
///
///
///
public long getFileSize(string fileName)
{
if(!logined)
{
login();
}
sendCommand("SIZE " + fileName);
long size=0;
if(retValue == 213)
{
size = Int64.Parse(reply.Substring(4));
}
else
{
throw new IOException(reply.Substring(4));
}
return size;
}
///
/// Login to the remote server.
///
public void login()
{
clientSocket = new
Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);
IPEndPoint ep = new
IPEndPoint(Dns.Resolve(remoteHost).AddressList[0], remotePort);
try
{
clientSocket.Connect(ep);
}
catch(Exception)
{
throw new IOException("Couldn't connect to remote server");
}
readReply();
if(retValue != 220)
{
close();
throw new IOException(reply.Substring(4));
}
if(debug)
Console.WriteLine("USER "+remoteUser);
sendCommand("USER "+remoteUser);
if( !(retValue == 331 || retValue == 230) )
{
cleanup();
throw new IOException(reply.Substring(4));
}
if( retValue != 230 )
{
if(debug)
Console.WriteLine("PASS xxx");
sendCommand("PASS "+remotePass);
if( !(retValue == 230 || retValue == 202) )
{
cleanup();
throw new IOException(reply.Substring(4));
}
}
logined = true;
Console.WriteLine("Connected to "+remoteHost);
chdir(remotePath);
}
///
/// If the value of mode is true, set binary mode for downloads.
/// Else, set Ascii mode.
///
///
public void setBinaryMode(Boolean mode)
{
if(mode)
{
sendCommand("TYPE I");
}
else
{
sendCommand("TYPE A");
}
if (retValue != 200)
{
throw new IOException(reply.Substring(4));
}
}
///
/// Download a file to the Assembly's local directory,
/// keeping the same file name.
///
///
public void download(string remFileName)
{
download(remFileName,"",false);
}
///
/// Download a remote file to the Assembly's local directory,
/// keeping the same file name, and set the resume flag.
///
///
///
public void download(string remFileName,Boolean resume)
{
download(remFileName,"",resume);
}
///
/// Download a remote file to a local file name which can include
/// a path. The local file name will be created or overwritten,
/// but the path must exist.
///
///
///
public void download(string remFileName,string locFileName)
{
download(remFileName,locFileName,false);
}
///
/// Download a remote file to a local file name which can include
/// a path, and set the resume flag. The local file name will be
/// created or overwritten, but the path must exist.
///
///
///
///
public void download(string remFileName,string
locFileName,Boolean resume)
{
if(!logined)
{
login();
}
setBinaryMode(false);
Console.WriteLine("Downloading file "+remFileName+" from "+remoteHost + "//"+remotePath);
if (locFileName.Equals(""))
{
locFileName = remFileName;
}
if(!File.Exists(locFileName))
{
Stream st = File.Create(locFileName);
st.Close();
}
FileStream output = new
FileStream(locFileName,FileMode.Create);
Socket cSocket = createDataSocket();
long offset = 0;
if(resume)
{
offset = output.Length;
if(offset > 0 )
{
setBinaryMode(false);
sendCommand("REST "+offset);
if(retValue != 350)
{
//throw new IOException(reply.Substring(4));
//Some servers may not support resuming.
offset = 0;
}
}
if(offset > 0)
{
if(debug)
{
Console.WriteLine("seeking to " + offset);
}
long npos = output.Seek(offset,SeekOrigin.Begin);
Console.WriteLine("new pos="+npos);
}
}
sendCommand("RETR " + remFileName);
if(!(retValue == 150 || retValue == 125))
{
throw new IOException(reply.Substring(4));
}
while(true)
{
bytes = cSocket.Receive(buffer, buffer.Length, 0);
output.Write(buffer,0,bytes);
if(bytes <= 0)
{
break;
}
}
output.Close();
if (cSocket.Connected)
{
cSocket.Close();
}
Console.WriteLine("");
readReply();
if( !(retValue == 226 || retValue == 250) )
{
throw new IOException(reply.Substring(4));
}
}
///
/// Upload a file.
///
///
public void upload(string fileName)
{
upload(fileName,false);
}
///
/// Upload a file and set the resume flag.
///
///
///
public void upload(string fileName,Boolean resume)
{
if(!logined)
{
login();
}
Socket cSocket = createDataSocket();
long offset=0;
if(resume)
{
try
{
setBinaryMode(true);
offset = getFileSize(fileName);
}
catch(Exception)
{
offset = 0;
}
}
if(offset > 0 )
{
sendCommand("REST " + offset);
if(retValue != 350)
{
//throw new IOException(reply.Substring(4));
//Remote server may not support resuming.
offset = 0;
}
}
/*==========================*/
sendCommand("STOR "+Path.GetFileName(fileName));
if( !(retValue == 125 || retValue == 150) )
{
throw new IOException(reply.Substring(4));
}
// open input stream to read source file
FileStream input = new FileStream(fileName,FileMode.Open);
if(offset != 0)
{
if(debug)
{
Console.WriteLine("seeking to " + offset);
}
input.Seek(offset,SeekOrigin.Begin);
}
Console.WriteLine("Uploading file "+fileName+" to "+remotePath);
while ((bytes = input.Read(buffer,0,buffer.Length)) > 0)
{
cSocket.Send(buffer, bytes, 0);
}
input.Close();
Console.WriteLine("");
if (cSocket.Connected)
{
cSocket.Close();
}
readReply();
if( !(retValue == 226 || retValue == 250) )
{
throw new IOException(reply.Substring(4));
}
}
///
/// Delete a file from the remote FTP server.
///
///
public void deleteRemoteFile(string fileName)
{
if(!logined)
{
login();
}
sendCommand("DELE "+fileName);
if(retValue != 250)
{
throw new IOException(reply.Substring(4));
}
}
///
/// Rename a file on the remote FTP server.
///
///
///
public void renameRemoteFile(string oldFileName,string
newFileName)
{
if(!logined)
{
login();
}
sendCommand("RNFR "+oldFileName);
if(retValue != 350)
{
throw new IOException(reply.Substring(4));
}
// known problem
// rnto will not take care of existing file.
// i.e. It will overwrite if newFileName exist
sendCommand("RNTO "+newFileName);
if(retValue != 250)
{
throw new IOException(reply.Substring(4));
}
}
///
/// Create a directory on the remote FTP server.
///
///
public void mkdir(string dirName)
{
if(!logined)
{
login();
}
sendCommand("MKD "+dirName);
if(retValue != 250)
{
throw new IOException(reply.Substring(4));
}
}
///
/// Delete a directory on the remote FTP server.
///
///
public void rmdir(string dirName)
{
if(!logined)
{
login();
}
sendCommand("RMD "+dirName);
if(retValue != 250)
{
throw new IOException(reply.Substring(4));
}
}
///
/// Change the current working directory on the remote FTP server.
///
///
public void chdir(string dirName)
{
if(dirName.Equals("."))
{
return;
}
if(!logined)
{
login();
}
sendCommand("CWD "+dirName);
if(retValue != 250)
{
throw new IOException(reply.Substring(4));
}
this.remotePath = dirName;
Console.WriteLine("Current directory is "+remotePath);
}
///
/// Close the FTP connection.
///
public void close()
{
if( clientSocket != null )
{
sendCommand("QUIT");
}
cleanup();
Console.WriteLine("Closing...");
}
///
/// Set debug mode.
///
///
public void setDebug(Boolean debug)
{
this.debug = debug;
}
private void readReply()
{
mes = "";
reply = readLine();
retValue = Int32.Parse(reply.Substring(0,3));
}
private void cleanup()
{
if(clientSocket!=null)
{
clientSocket.Close();
clientSocket = null;
}
logined = false;
}
private string readLine()
{
while(true)
{
bytes = clientSocket.Receive(buffer, buffer.Length, 0);
mes += ASCII.GetString(buffer, 0, bytes);
if(bytes < buffer.Length)
{
break;
}
}
char[] seperator = {'\n'};
string[] mess = mes.Split(seperator);
if(mes.Length > 2)
{
mes = mess[mess.Length-2];
}
else
{
mes = mess[0];
}
if(!mes.Substring(3,1).Equals(" "))
{
return readLine();
}
if(debug)
{
for(int k=0;k < mess.Length-1;k++)
{
Console.WriteLine(mess[k]);
}
}
return mes;
}
private void sendCommand(String command)
{
Byte[] cmdBytes =
Encoding.ASCII.GetBytes((command+"\r\n").ToCharArray());
clientSocket.Send(cmdBytes, cmdBytes.Length, 0);
readReply();
}
private Socket createDataSocket()
{
sendCommand("PASV");
if(retValue != 227)
{
throw new IOException(reply.Substring(4));
}
int index1 = reply.IndexOf('(');
int index2 = reply.IndexOf(')');
string ipData =
reply.Substring(index1+1,index2-index1-1);
int[] parts = new int[6];
int len = ipData.Length;
int partCount = 0;
string buf="";
for (int i = 0; i < len && partCount <= 6; i++)
{
char ch = Char.Parse(ipData.Substring(i,1));
if (Char.IsDigit(ch))
buf+=ch;
else if (ch != ',')
{
throw new IOException("Malformed PASV reply: " +
reply);
}
if (ch == ',' || i+1 == len)
{
try
{
parts[partCount++] = Int32.Parse(buf);
buf="";
}
catch (Exception)
{
throw new IOException("Malformed PASV reply: " +
reply);
}
}
}
string ipAddress = parts[0] + "."+ parts[1]+ "." +
parts[2] + "." + parts[3];
int port = (parts[4] << 8) + parts[5];
Socket s = new
Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);
s.SetSocketOption (SocketOptionLevel.Socket, SocketOptionName.SendTimeout, 5000);
IPEndPoint ep = new
IPEndPoint(Dns.Resolve(ipAddress).AddressList[0], port);
try
{
s.Connect(ep);
}
catch(Exception)
{
throw new IOException("Can't connect to remote server");
}
return s;
}
}
}
分享到：
相关推荐
/* FTPFactory.cs Better view with tab space=4 Written by Jaimon Mathew (jaimonmathew@rediffmail.com) Rolander,Dan (Dan.Rolander@marriott.com) has modified the download method to ...
c#实现FTP服务器， 功能 ①、按标准FTP协议登录FTP服务器，进行身份验证； ②、显示远程目录、文件列表，进行目录切换； ③、目录、文件列表的排序显示（文件名、时间、类型）； ④、能上传文件、下载、删除文件...
C#ie实现自动下载示例、C#Socket基本编程、C# WinForm制作异形窗体与控件、C# 编写定时关机程序、C#对注册表的操作、C# 简单文本文件读写、C# ...c#读取硬盘序列号、C#编写发送电子邮件、C#版ftp方法实现类的代码.........
C# 语言中 FTP（File Transfer Protocol，文件传输协议）操作类是指通过 C# 语言实现对 FTP 服务器的连接、文件上传、下载、删除、修改等操作。该类通常包括连接 FTP 服务器、上传文件、下载文件、删除文件、修改...
这是使用c#实现FTP功能的工具类，包含socket技术。
在C#中，我们可以利用System.Net命名空间下的FtpWebRequest和FtpWebResponse类来实现这一功能。以下是一些关键步骤： 1. 创建FtpWebRequest对象，设置URL（FTP服务器地址）和方法（如GET或PUT）。 2. 设置认证信息...
C#中的System.Net命名空间提供了FTP相关的类，如FtpWebRequest和FtpWebResponse，它们可以帮助我们创建FTP客户端，而构建FTP服务器则需要自定义实现。 首先，让我们看看FTP服务器端的实现。在C#中，没有内置的FTP...
C#帮助类（Helper class）是一种用于封装常用功能的类。它通常包含一组静态方法，这些方法能够执行特定的任务或提供通用的功能。帮助类的目的是为了提高代码的可重用性和可维护性，避免重复编写相似的功能代码。 ...
总结，使用C#和FTP实现客户端程序的自动更新需要理解FTP工作原理、文件I/O操作以及错误处理策略。通过上述步骤，可以构建一个可靠的自动更新机制，确保用户始终保持软件的最新状态。在实际应用中，还可以结合其他...
总结来说，C# FTP操作类是为了方便开发者在ASP.NET应用中实现FTP功能，它提供了连接、文件上传/下载、目录管理等关键操作，并通过封装降低了操作复杂性，提升了代码的可读性和可维护性。通过熟练掌握和使用这些类，...
C#语言封装的FTP操作类，方便用户在程序中对FTP进行操作
在C#中，开发FTP服务端通常会用到.NET框架提供的System.Net和System.IO命名空间，这两个命名空间中包含了大量的类和方法，可以用于实现网络通信和文件的读写操作。在实现服务端时，开发者需要熟悉如何使用Socket编程...
在C#中，我们可以利用System.Net命名空间下的FtpWebRequest和FtpWebResponse类来实现FTP操作。 2. **WPF基础知识**： WPF是.NET Framework的一部分，提供了一个用于构建桌面应用程序的丰富且灵活的UI框架。它基于...
在C#中，主要使用`System.Net.FtpWebRequest`和`System.Net.FtpWebResponse`类来实现这些步骤。 首先，你需要创建一个`FtpWebRequest`对象，指定FTP服务器的URL和HTTP方法（通常为`GET`，表示下载）。例如： ```...
c# 操作FTP文件类，代码实现了从ftp服务器下载文件的功能
首先，我们需要创建一个自定义的FtpServer.FtpSite类，继承自FtpServer.Site，并重写必要的方法，如OnConnect、OnAuthenticate和OnExecuteCommand。 1. **身份验证**：FTP服务器需要验证每个连接的客户端。这可以...
本文将详细讲解如何使用C#实现下载FTP指定目录下的所有文件及子目录中的文件。首先，我们需要引入必要的命名空间： ```csharp using System; using System.IO; using System.Net; ``` 接下来，定义一个方法来执行...
总之，通过结合 `WebClient` 类的异步方法和事件处理，我们可以轻松地在C#中实现FTP文件下载并显示进度。确保在编写代码时考虑到用户体验，提供流畅的进度反馈，以及充分的错误处理机制，以提高应用程序的稳定性和...
// 假设这个类已经实现了获取FTP目录信息的功能 StringBuilder result = new StringBuilder(); FtpWebRequest reqFTP; try { reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(path)); reqFTP....
C#中，我们可以使用System.Net命名空间下的FtpWebRequest和FtpWebResponse类来实现FTP操作。以下是一些关键步骤： 1. **创建FtpWebRequest对象**：首先，你需要创建一个FtpWebRequest对象，指定FTP服务器的URL、FTP...