首页 / PYTHON / phppythonftp操作类

phppythonftp操作类

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了phppythonftp操作类，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含9945字，纯文字阅读大概需要15分钟。

内容图文

php python ftp操作类
  1. <?php
  2. class Ftp {
  4. //FTP 连接资源
  5. private $link;
  7. //FTP连接时间
  8. public $link_time;
  10. //错误代码
  11. private $err_code = 0;
  13. //传送模式{文本模式:FTP_ASCII, 二进制模式:FTP_BINARY}
  14. public $mode = FTP_BINARY;
  16. /**
  17. 初始化类
  19. **/
  20. public function start($data)
  21. {
  22. if(empty($data['port'])) $data['port'] ='21';
  23. if(empty($data['pasv'])) $data['pasv'] =false;
  24. if(empty($data['ssl'])) $data['ssl'] = false;
  25. if(empty($data['timeout'])) $data['timeout'] = 30;
  26. return $this->connect($data['server'],$data['username'],$data['password'],$data['port'],$data['pasv'],$data['ssl'],$data['timeout']);
  27. }
  29. /**
  30. * 连接FTP服务器
  31. * @param string $host 　　 服务器地址
  32. * @param string $username　　　用户名
  33. * @param string $password　　　密码
  34. * @param integer $port　　　　 服务器端口，默认值为21
  35. * @param boolean $pasv 是否开启被动模式
  36. * @param boolean $ssl　　　　 　是否使用SSL连接
  37. * @param integer $timeout 超时时间　
  38. */
  39. public function connect($host, $username = '', $password = '', $port = '21', $pasv = false, $ssl = false, $timeout = 30) {
  40. $start = time();
  41. if ($ssl) {
  42. if (!$this->link = @ftp_ssl_connect($host, $port, $timeout)) {
  43. $this->err_code = 1;
  44. return false;
  45. }
  46. } else {
  47. if (!$this->link = @ftp_connect($host, $port, $timeout)) {
  48. $this->err_code = 1;
  49. return false;
  50. }
  51. }
  53. if (@ftp_login($this->link, $username, $password)) {
  54. if ($pasv)
  55. ftp_pasv($this->link, true);
  56. $this->link_time = time() - $start;
  57. return true;
  58. } else {
  59. $this->err_code = 1;
  60. return false;
  61. }
  62. register_shutdown_function(array(&$this, 'close'));
  63. }
  65. /**
  66. * 创建文件夹
  67. * @param string $dirname 目录名，
  68. */
  69. public function mkdir($dirname) {
  70. if (!$this->link) {
  71. $this->err_code = 2;
  72. return false;
  73. }
  74. $dirname = $this->ck_dirname($dirname);
  75. $nowdir = '/';
  76. foreach ($dirname as $v) {
  77. if ($v && !$this->chdir($nowdir . $v)) {
  78. if ($nowdir)
  79. $this->chdir($nowdir);
  80. @ftp_mkdir($this->link, $v);
  81. }
  82. if ($v)
  83. $nowdir .= $v . '/';
  84. }
  85. return true;
  86. }
  88. /**
  89. * 上传文件
  90. * @param string $remote 远程存放地址
  91. * @param string $local 本地存放地址
  92. */
  93. public function put($remote, $local) {
  94. if (!$this->link) {
  95. $this->err_code = 2;
  96. return false;
  97. }
  98. $dirname = pathinfo($remote, PATHINFO_DIRNAME);
  99. if (!$this->chdir($dirname)) {
  100. $this->mkdir($dirname);
  101. }
  102. if (@ftp_put($this->link, $remote, $local, $this->mode)) {
  103. return true;
  104. } else {
  105. $this->err_code = 7;
  106. return false;
  107. }
  108. }
  110. /**
  111. * 删除文件夹
  112. * @param string $dirname 目录地址
  113. * @param boolean $enforce 强制删除
  114. */
  115. public function rmdir($dirname, $enforce = false) {
  116. if (!$this->link) {
  117. $this->err_code = 2;
  118. return false;
  119. }
  120. $list = $this->nlist($dirname);
  121. if ($list && $enforce) {
  122. $this->chdir($dirname);
  123. foreach ($list as $v) {
  124. $this->f_delete($v);
  125. }
  126. } elseif ($list && !$enforce) {
  127. $this->err_code = 3;
  128. return false;
  129. }
  130. @ftp_rmdir($this->link, $dirname);
  131. return true;
  132. }
  134. /**
  135. * 删除指定文件
  136. * @param string $filename 文件名
  137. */
  138. public function delete($filename) {
  139. if (!$this->link) {
  140. $this->err_code = 2;
  141. return false;
  142. }
  143. if (@ftp_delete($this->link, $filename)) {
  144. return true;
  145. } else {
  146. $this->err_code = 4;
  147. return false;
  148. }
  149. }
  151. /**
  152. * 返回给定目录的文件列表
  153. * @param string $dirname 目录地址
  154. * @return array 文件列表数据
  155. */
  156. public function nlist($dirname) {
  157. if (!$this->link) {
  158. $this->err_code = 2;
  159. return false;
  160. }
  161. if ($list = @ftp_nlist($this->link, $dirname)) {
  162. return $list;
  163. } else {
  164. $this->err_code = 5;
  165. return false;
  166. }
  167. }
  169. /**
  170. * 在 FTP 服务器上改变当前目录
  171. * @param string $dirname 修改服务器上当前目录
  172. */
  173. public function chdir($dirname) {
  174. if (!$this->link) {
  175. $this->err_code = 2;
  176. return false;
  177. }
  178. if (@ftp_chdir($this->link, $dirname)) {
  179. return true;
  180. } else {
  181. $this->err_code = 6;
  182. return false;
  183. }
  184. }
  186. /**
  187. * 获取错误信息
  188. */
  189. public function get_error() {
  190. if (!$this->err_code)
  191. return false;
  192. $err_msg = array(
  193. '1' => 'Server can not connect',
  194. '2' => 'Not connect to server',
  195. '3' => 'Can not delete non-empty folder',
  196. '4' => 'Can not delete file',
  197. '5' => 'Can not get file list',
  198. '6' => 'Can not change the current directory on the server',
  199. '7' => 'Can not upload files'
  200. );
  201. return $err_msg[$this->err_code];
  202. }
  204. /**
  205. * 检测目录名
  206. * @param string $url 目录
  207. * @return 由 / 分开的返回数组
  208. */
  209. private function ck_dirname($url) {
  210. $url = str_replace('', '/', $url);
  211. $urls = explode('/', $url);
  212. return $urls;
  213. }
  215. /**
  216. * 关闭FTP连接
  217. */
  219. public function close() {
  220. return @ftp_close($this->link);
  221. }
  223. }
  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()

内容总结

以上是互联网集市为您收集整理的phppythonftp操作类全部内容，希望文章能够帮你解决phppythonftp操作类所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/164258.html

来源：【匿名】