简体中文(ZH-CN) English(EN) 繁体中文(ZH-TW) 日本語(JA) 한국어(KO) Melayu(MS) Français(FR) Deutsch(DE)
Heim > Backend-Entwicklung > PHP-Tutorial > Hauptteil

php python ftp操作类

WBOY
Freigeben： 2016-07-25 08:51:01
Original
962 Leute haben es durchsucht
php python ftp操作类
  1. class Ftp {
  3. //FTP 连接资源
  4. private $link;
  6. //FTP连接时间
  7. public $link_time;
  9. //错误代码
  10. private $err_code = 0;
  12. //传送模式{文本模式:FTP_ASCII, 二进制模式:FTP_BINARY}
  13. public $mode = FTP_BINARY;
  15. /**
  16. 初始化类
  18. **/
  19. public function start($data)
  20. {
  21. if(empty($data['port'])) $data['port'] ='21';
  22. if(empty($data['pasv'])) $data['pasv'] =false;
  23. if(empty($data['ssl'])) $data['ssl'] = false;
  24. if(empty($data['timeout'])) $data['timeout'] = 30;
  25. return $this->connect($data['server'],$data['username'],$data['password'],$data['port'],$data['pasv'],$data['ssl'],$data['timeout']);
  26. }
  28. /**
  29. * 连接FTP服务器
  30. * @param string $host 　　 服务器地址
  31. * @param string $username　　　用户名
  32. * @param string $password　　　密码
  33. * @param integer $port　　　　 服务器端口，默认值为21
  34. * @param boolean $pasv 是否开启被动模式
  35. * @param boolean $ssl　　　　 　是否使用SSL连接
  36. * @param integer $timeout 超时时间　
  37. */
  38. public function connect($host, $username = '', $password = '', $port = '21', $pasv = false, $ssl = false, $timeout = 30) {
  39. $start = time();
  40. if ($ssl) {
  41. if (!$this->link = @ftp_ssl_connect($host, $port, $timeout)) {
  42. $this->err_code = 1;
  43. return false;
  44. }
  45. } else {
  46. if (!$this->link = @ftp_connect($host, $port, $timeout)) {
  47. $this->err_code = 1;
  48. return false;
  49. }
  50. }
  52. if (@ftp_login($this->link, $username, $password)) {
  53. if ($pasv)
  54. ftp_pasv($this->link, true);
  55. $this->link_time = time() - $start;
  56. return true;
  57. } else {
  58. $this->err_code = 1;
  59. return false;
  60. }
  61. register_shutdown_function(array(&$this, 'close'));
  62. }
  64. /**
  65. * 创建文件夹
  66. * @param string $dirname 目录名，
  67. */
  68. public function mkdir($dirname) {
  69. if (!$this->link) {
  70. $this->err_code = 2;
  71. return false;
  72. }
  73. $dirname = $this->ck_dirname($dirname);
  74. $nowdir = '/';
  75. foreach ($dirname as $v) {
  76. if ($v && !$this->chdir($nowdir . $v)) {
  77. if ($nowdir)
  78. $this->chdir($nowdir);
  79. @ftp_mkdir($this->link, $v);
  80. }
  81. if ($v)
  82. $nowdir .= $v . '/';
  83. }
  84. return true;
  85. }
  87. /**
  88. * 上传文件
  89. * @param string $remote 远程存放地址
  90. * @param string $local 本地存放地址
  91. */
  92. public function put($remote, $local) {
  93. if (!$this->link) {
  94. $this->err_code = 2;
  95. return false;
  96. }
  97. $dirname = pathinfo($remote, PATHINFO_DIRNAME);
  98. if (!$this->chdir($dirname)) {
  99. $this->mkdir($dirname);
  100. }
  101. if (@ftp_put($this->link, $remote, $local, $this->mode)) {
  102. return true;
  103. } else {
  104. $this->err_code = 7;
  105. return false;
  106. }
  107. }
  109. /**
  110. * 删除文件夹
  111. * @param string $dirname 目录地址
  112. * @param boolean $enforce 强制删除
  113. */
  114. public function rmdir($dirname, $enforce = false) {
  115. if (!$this->link) {
  116. $this->err_code = 2;
  117. return false;
  118. }
  119. $list = $this->nlist($dirname);
  120. if ($list && $enforce) {
  121. $this->chdir($dirname);
  122. foreach ($list as $v) {
  123. $this->f_delete($v);
  124. }
  125. } elseif ($list && !$enforce) {
  126. $this->err_code = 3;
  127. return false;
  128. }
  129. @ftp_rmdir($this->link, $dirname);
  130. return true;
  131. }
  133. /**
  134. * 删除指定文件
  135. * @param string $filename 文件名
  136. */
  137. public function delete($filename) {
  138. if (!$this->link) {
  139. $this->err_code = 2;
  140. return false;
  141. }
  142. if (@ftp_delete($this->link, $filename)) {
  143. return true;
  144. } else {
  145. $this->err_code = 4;
  146. return false;
  147. }
  148. }
  150. /**
  151. * 返回给定目录的文件列表
  152. * @param string $dirname 目录地址
  153. * @return array 文件列表数据
  154. */
  155. public function nlist($dirname) {
  156. if (!$this->link) {
  157. $this->err_code = 2;
  158. return false;
  159. }
  160. if ($list = @ftp_nlist($this->link, $dirname)) {
  161. return $list;
  162. } else {
  163. $this->err_code = 5;
  164. return false;
  165. }
  166. }
  168. /**
  169. * 在 FTP 服务器上改变当前目录
  170. * @param string $dirname 修改服务器上当前目录
  171. */
  172. public function chdir($dirname) {
  173. if (!$this->link) {
  174. $this->err_code = 2;
  175. return false;
  176. }
  177. if (@ftp_chdir($this->link, $dirname)) {
  178. return true;
  179. } else {
  180. $this->err_code = 6;
  181. return false;
  182. }
  183. }
  185. /**
  186. * 获取错误信息
  187. */
  188. public function get_error() {
  189. if (!$this->err_code)
  190. return false;
  191. $err_msg = array(
  192. '1' => 'Server can not connect',
  193. '2' => 'Not connect to server',
  194. '3' => 'Can not delete non-empty folder',
  195. '4' => 'Can not delete file',
  196. '5' => 'Can not get file list',
  197. '6' => 'Can not change the current directory on the server',
  198. '7' => 'Can not upload files'
  199. );
  200. return $err_msg[$this->err_code];
  201. }
  203. /**
  204. * 检测目录名
  205. * @param string $url 目录
  206. * @return 由 / 分开的返回数组
  207. */
  208. private function ck_dirname($url) {
  209. $url = str_replace('', '/', $url);
  210. $urls = explode('/', $url);
  211. return $urls;
  212. }
  214. /**
  215. * 关闭FTP连接
  216. */
  218. public function close() {
  219. return @ftp_close($this->link);
  220. }
  222. }
复制代码
  1. #!/usr/bin/python
  2. #coding=gbk
  3. '''
  4. ftp自动下载、自动上传脚本，可以递归目录操作
  5. '''
  7. from ftplib import FTP
  8. import os,sys,string,datetime,time
  9. import socket
  11. class MYFTP:
  12. def __init__(self, hostaddr, username, password, remotedir, port=21):
  13. self.hostaddr = hostaddr
  14. self.username = username
  15. self.password = password
  16. self.remotedir = remotedir
  17. self.port = port
  18. self.ftp = FTP()
  19. self.file_list = []
  20. # self.ftp.set_debuglevel(2)
  21. def __del__(self):
  22. self.ftp.close()
  23. # self.ftp.set_debuglevel(0)
  24. def login(self):
  25. ftp = self.ftp
  26. try:
  27. timeout = 60
  28. socket.setdefaulttimeout(timeout)
  29. ftp.set_pasv(True)
  30. print '开始连接到 %s' %(self.hostaddr)
  31. ftp.connect(self.hostaddr, self.port)
  32. print '成功连接到 %s' %(self.hostaddr)
  33. print '开始登录到 %s' %(self.hostaddr)
  34. ftp.login(self.username, self.password)
  35. print '成功登录到 %s' %(self.hostaddr)
  36. debug_print(ftp.getwelcome())
  37. except Exception:
  38. deal_error("连接或登录失败")
  39. try:
  40. ftp.cwd(self.remotedir)
  41. except(Exception):
  42. deal_error('切换目录失败')
  44. def is_same_size(self, localfile, remotefile):
  45. try:
  46. remotefile_size = self.ftp.size(remotefile)
  47. except:
  48. remotefile_size = -1
  49. try:
  50. localfile_size = os.path.getsize(localfile)
  51. except:
  52. localfile_size = -1
  53. debug_print('lo:%d re:%d' %(localfile_size, remotefile_size),)
  54. if remotefile_size == localfile_size:
  55. return 1
  56. else:
  57. return 0
  58. def download_file(self, localfile, remotefile):
  59. if self.is_same_size(localfile, remotefile):
  60. debug_print('%s 文件大小相同，无需下载' %localfile)
  61. return
  62. else:
  63. debug_print('>>>>>>>>>>>>下载文件 %s ... ...' %localfile)
  64. #return
  65. file_handler = open(localfile, 'wb')
  66. self.ftp.retrbinary('RETR %s'%(remotefile), file_handler.write)
  67. file_handler.close()
  69. def download_files(self, localdir='./', remotedir='./'):
  70. try:
  71. self.ftp.cwd(remotedir)
  72. except:
  73. debug_print('目录%s不存在，继续...' %remotedir)
  74. return
  75. if not os.path.isdir(localdir):
  76. os.makedirs(localdir)
  77. debug_print('切换至目录 %s' %self.ftp.pwd())
  78. self.file_list = []
  79. self.ftp.dir(self.get_file_list)
  80. remotenames = self.file_list
  81. #print(remotenames)
  82. #return
  83. for item in remotenames:
  84. filetype = item[0]
  85. filename = item[1]
  86. local = os.path.join(localdir, filename)
  87. if filetype == 'd':
  88. self.download_files(local, filename)
  89. elif filetype == '-':
  90. self.download_file(local, filename)
  91. self.ftp.cwd('..')
  92. debug_print('返回上层目录 %s' %self.ftp.pwd())
  93. def upload_file(self, localfile, remotefile):
  94. if not os.path.isfile(localfile):
  95. return
  96. if self.is_same_size(localfile, remotefile):
  97. debug_print('跳过[相等]: %s' %localfile)
  98. return
  99. file_handler = open(localfile, 'rb')
  100. self.ftp.storbinary('STOR %s' %remotefile, file_handler)
  101. file_handler.close()
  102. debug_print('已传送: %s' %localfile)
  103. def upload_files(self, localdir='./', remotedir = './'):
  104. if not os.path.isdir(localdir):
  105. return
  106. localnames = os.listdir(localdir)
  107. self.ftp.cwd(remotedir)
  108. for item in localnames:
  109. src = os.path.join(localdir, item)
  110. if os.path.isdir(src):
  111. try:
  112. self.ftp.mkd(item)
  113. except:
  114. debug_print('目录已存在 %s' %item)
  115. self.upload_files(src, item)
  116. else:
  117. self.upload_file(src, item)
  118. self.ftp.cwd('..')
  120. def get_file_list(self, line):
  121. ret_arr = []
  122. file_arr = self.get_filename(line)
  123. if file_arr[1] not in ['.', '..']:
  124. self.file_list.append(file_arr)
  126. def get_filename(self, line):
  127. pos = line.rfind(':')
  128. while(line[pos] != ' '):
  129. pos += 1
  130. while(line[pos] == ' '):
  131. pos += 1
  132. file_arr = [line[0], line[pos:]]
  133. return file_arr
  134. def debug_print(s):
  135. print (s)
  136. def deal_error(e):
  137. timenow = time.localtime()
  138. datenow = time.strftime('%Y-%m-%d', timenow)
  139. logstr = '%s 发生错误: %s' %(datenow, e)
  140. debug_print(logstr)
  141. file.write(logstr)
  142. sys.exit()
  144. if __name__ == '__main__':
  145. file = open("log.txt", "a")
  146. timenow = time.localtime()
  147. datenow = time.strftime('%Y-%m-%d', timenow)
  148. logstr = datenow
  149. # 配置如下变量
  150. hostaddr = 'localhost' # ftp地址
  151. username = 'test' # 用户名
  152. password = 'test' # 密码
  153. port = 21 # 端口号
  154. rootdir_local = '.' + os.sep + 'bak/' # 本地目录
  155. rootdir_remote = './' # 远程目录
  157. f = MYFTP(hostaddr, username, password, rootdir_remote, port)
  158. f.login()
  159. f.download_files(rootdir_local, rootdir_remote)
  161. timenow = time.localtime()
  162. datenow = time.strftime('%Y-%m-%d', timenow)
  163. logstr += " - %s 成功执行了备份\n" %datenow
  164. debug_print(logstr)
  166. file.write(logstr)
  167. file.close()
复制代码


Verwandte Etiketten：
php python ftp操作类
Quelle：php.cn
Vorheriger Artikel：php解决装箱问题 Nächster Artikel：判断客户端浏览器的类型
Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn
Neueste Artikel des Autors
Aktuelle Ausgaben
Mit Selenium möchten Sie im Unterricht auf die URL klicken und sie definieren Ich brauche heute noch einen Tipp. Ich versuche, Python/Selenium-Code zu erstellen und die...
Aus 2024-04-04 14:14:44
0
1
3492
verwandte Themen
Mehr>
Beliebte Empfehlungen
Beliebte Tutorials
Mehr>
Verwandte Tutorials
Beliebte Empfehlungen
Aktuelle Kurse
Neueste Downloads
Mehr>
Web-Effekte
Quellcode der Website
Website-Materialien
Frontend-Vorlage
Über uns Haftungsausschluss Sitemap
Chinesische PHP-Website：Online-PHP-Schulung für das Gemeinwohl，Helfen Sie PHP-Lernenden, sich schnell weiterzuentwickeln！