社区 学习 工具库 休闲
搜索
简体中文
首页 > 后端开发 > php教程 > php python ftp操作类

php python ftp操作类

WBOY
发布： 2016-07-25 08:51:01
原创
1029 人浏览过
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()
复制代码


相关标签：
php python ftp操作类
来源：php.cn
上一篇：php解决装箱问题 下一篇：判断客户端浏览器的类型
本站声明
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn
作者最新文章
最新问题
使用selenium想要点击并在类中定义URL 今天我需要另一个提示。我正在尝试构建Python/Selenium代码，想法是单击www.thewebsiteIwantoclickon下面是我正在处理的HTML示例。类entit...
来自于 2024-04-04 14:14:44
0
1
3492
相关专题
更多>
热门推荐
热门教程
更多>
相关教程
热门推荐
最新课程
最新下载
更多>
网站特效
网站源码
网站素材
前端模板