class1.cs

ftp 上传 下载 批量上传 批量下载

			{
				Connect();
			}
			SendCommand("RNFR "+strOldFileName);
			if(iReplyCode != 350)
			{
				throw new IOException(strReply.Substring(4));
			}
			//  如果新文件名与原有文件重名,将覆盖原有文件
			SendCommand("RNTO "+strNewFileName);
			if(iReplyCode != 250)
			{
				throw new IOException(strReply.Substring(4));
			}
		}
		#endregion

		#region 上传和下载
		/// <summary>
		/// 下载一批文件
		/// </summary>
		/// <param name="strFileNameMask">文件名的匹配字符串</param>
		/// <param name="strFolder">本地目录(不得以\结束)</param>
		public void Get(string strFileNameMask,string strFolder)
		{
			if(!bConnected)
			{
				Connect();
			}
			string[] strFiles = Dir(strFileNameMask);
			foreach(string strFile in strFiles)
			{
				if(!strFile.Equals(""))//一般来说strFiles的最后一个元素可能是空字符串
				{
					Get(strFile,strFolder,strFile);
				}
			}
		}
    

		/// <summary>
		/// 下载一个文件
		/// </summary>
		/// <param name="strRemoteFileName">要下载的文件名</param>
		/// <param name="strFolder">本地目录(不得以\结束)</param>
		/// <param name="strLocalFileName">保存在本地时的文件名</param>
		public void Get(string strRemoteFileName,string strFolder,string strLocalFileName)
		{
			if(!bConnected)
			{
				Connect();
			}
			SetTransferType(TransferType.Binary);
			if (strLocalFileName.Equals(""))
			{
				strLocalFileName = strRemoteFileName;
			}
			if(!File.Exists(strLocalFileName))
			{
				Stream st = File.Create(strLocalFileName);
				st.Close();
			}
			FileStream output = new 
				FileStream(strFolder + "\\" + strLocalFileName,FileMode.Create);
			Socket socketData = CreateDataSocket();
			SendCommand("RETR " + strRemoteFileName);
			if(!(iReplyCode == 150 || iReplyCode == 125
				|| iReplyCode == 226 || iReplyCode == 250))
			{
				throw new IOException(strReply.Substring(4));
			}
			while(true)
			{
				int iBytes = socketData.Receive(buffer, buffer.Length, 0);
				output.Write(buffer,0,iBytes);
				if(iBytes <= 0)
				{
					break;
				}
			}
			output.Close();
			if (socketData.Connected)
			{
				socketData.Close();
			}
			if(!(iReplyCode == 226 || iReplyCode == 250))
			{
				ReadReply();
				if(!(iReplyCode == 226 || iReplyCode == 250))
				{
					throw new IOException(strReply.Substring(4));
				}
			}
		}
    

		/// <summary>
		/// 上传一批文件
		/// </summary>
		/// <param name="strFolder">本地目录(不得以\结束)</param>
		/// <param name="strFileNameMask">文件名匹配字符(可以包含*和?)</param>
		public void Put(string strFolder,string strFileNameMask)
		{
			string[] strFiles = Directory.GetFiles(strFolder,strFileNameMask);
			foreach(string strFile in strFiles)
			{
				//strFile是完整的文件名(包含路径)
				Put(strFile);
			}
		}
    

		/// <summary>
		/// 上传一个文件
		/// </summary>
		/// <param name="strFileName">本地文件名</param>
		public void Put(string strFileName)
		{
			if(!bConnected)
			{
				Connect();
			}
			Socket socketData = CreateDataSocket();
			SendCommand("STOR "+Path.GetFileName(strFileName));
			if( !(iReplyCode == 125 || iReplyCode == 150) )
			{
				throw new IOException(strReply.Substring(4));
			}
			FileStream input = new 
				FileStream(strFileName,FileMode.Open);
			int iBytes = 0;
			while ((iBytes = input.Read(buffer,0,buffer.Length)) > 0)
			{
				socketData.Send(buffer, iBytes, 0);
			}
			input.Close();
			if (socketData.Connected)
			{
				socketData.Close();
			}
			if(!(iReplyCode == 226 || iReplyCode == 250))
			{
				ReadReply();
				if(!(iReplyCode == 226 || iReplyCode == 250))
				{
					throw new IOException(strReply.Substring(4));
				}
			}
		}
    
		#endregion

		#region 目录操作
		/// <summary>
		/// 创建目录
		/// </summary>
		/// <param name="strDirName">目录名</param>
		public void MkDir(string strDirName)
		{
			if(!bConnected)
			{
				Connect();
			}
			SendCommand("MKD "+strDirName);
			if(iReplyCode != 257)
			{
				throw new IOException(strReply.Substring(4));
			}
		}
    
 
		/// <summary>
		/// 删除目录
		/// </summary>
		/// <param name="strDirName">目录名</param>
		public void RmDir(string strDirName)
		{
			if(!bConnected)
			{
				Connect();
			}
			SendCommand("RMD "+strDirName);
			if(iReplyCode != 250)
			{
				throw new IOException(strReply.Substring(4));
			}
		}
    
 
		/// <summary>
		/// 改变目录
		/// </summary>
		/// <param name="strDirName">新的工作目录名</param>
		public void ChDir(string strDirName)
		{
			if(strDirName.Equals(".") || strDirName.Equals(""))
			{
				return;
			}
			if(!bConnected)
			{
				Connect();
			}
			SendCommand("CWD "+strDirName);
			if(iReplyCode != 250)
			{
				throw new IOException(strReply.Substring(4));
			}
            strRemotePath = strDirName;
		}
    
		#endregion

		#region 内部变量
		/// <summary>
		/// 服务器返回的应答信息(包含应答码)
		/// </summary>
		private string strMsg;
		/// <summary>
		/// 服务器返回的应答信息(包含应答码)
		/// </summary>
		private string strReply;
		/// <summary>
		/// 服务器返回的应答码
		/// </summary>
		private int iReplyCode;
		/// <summary>
		/// 进行控制连接的socket
		/// </summary>
		private Socket socketControl;
		/// <summary>
		/// 传输模式
		/// </summary>
		private TransferType trType;
		/// <summary>
		/// 接收和发送数据的缓冲区
		/// </summary>
		private static int BLOCK_SIZE = 512;
		Byte[] buffer = new Byte[BLOCK_SIZE];
		/// <summary>
		/// 编码方式
		/// </summary>
		Encoding ASCII = Encoding.ASCII;
		#endregion

		#region 内部函数
		/// <summary>
		/// 将一行应答字符串记录在strReply和strMsg
		/// 应答码记录在iReplyCode
		/// </summary>
		private void ReadReply()
		{
			strMsg = "";
			strReply = ReadLine();
			iReplyCode = Int32.Parse(strReply.Substring(0,3));
		}

		/// <summary>
		/// 建立进行数据连接的socket
		/// </summary>
		/// <returns>数据连接socket</returns>
		private Socket CreateDataSocket()
		{
			SendCommand("PASV");
			if(iReplyCode != 227)
			{
				throw new IOException(strReply.Substring(4));
			}
			int index1 = strReply.IndexOf('(');
			int index2 = strReply.IndexOf(')');
			string ipData = 
				strReply.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 strReply: " + 
						strReply);
				}
				if (ch == ',' || i+1 == len)
				{
					try
					{
						parts[partCount++] = Int32.Parse(buf);
						buf="";
					}
					catch (Exception)
					{
						throw new IOException("Malformed PASV strReply: " + 
							strReply);
					}
				}
			}
			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);
			IPEndPoint ep = new 
				IPEndPoint(IPAddress.Parse(ipAddress), port);
			try
			{
				s.Connect(ep);
			}
			catch(Exception)
			{
				throw new IOException("Can't connect to remote server");
			}
			return s;
		}


		/// <summary>
		/// 关闭socket连接(用于登录以前)
		/// </summary>
		private void CloseSocketConnect()
		{
			if(socketControl!=null)
			{
				socketControl.Close();
				socketControl = null;
			}
			bConnected = false;
		}
 
		/// <summary>
		/// 读取Socket返回的所有字符串
		/// </summary>
		/// <returns>包含应答码的字符串行</returns>
		private string ReadLine()
		{
			while(true)
			{
				int iBytes = socketControl.Receive(buffer, buffer.Length, 0);
				strMsg += ASCII.GetString(buffer, 0, iBytes);
				if(iBytes < buffer.Length)
				{
					break;
				}
			}
			char[] seperator = {'\n'};
			string[] mess = strMsg.Split(seperator);
			if(strMsg.Length > 2)
			{
				strMsg = mess[mess.Length-2];
				//seperator[0]是10,换行符是由13和0组成的,分隔后10后面虽没有字符串,
				//但也会分配为空字符串给后面(也是最后一个)字符串数组,
				//所以最后一个mess是没用的空字符串
				//但为什么不直接取mess[0],因为只有最后一行字符串应答码与信息之间有空格
			}
			else
			{
				strMsg = mess[0];
			}
			if(!strMsg.Substring(3,1).Equals(" "))//返回字符串正确的是以应答码(如220开头,后面接一空格,再接问候字符串)
			{
				return ReadLine();
			}
			return strMsg;
		}


		/// <summary>
		/// 发送命令并获取应答码和最后一行应答字符串
		/// </summary>
		/// <param name="strCommand">命令</param>
		private void SendCommand(String strCommand)
		{
			Byte[] cmdBytes = 
				Encoding.Default.GetBytes((strCommand+"\r\n").ToCharArray());
			socketControl.Send(cmdBytes, cmdBytes.Length, 0);
			ReadReply();
		}

		#endregion
    }
}