python网络编程学习（四）

多用途客户端协议
一、ftp
功能：上传下载文件，删除命名文件，建立删除目录，自动压缩，保存目录
1.代码：

#coding=utf-8
'''连接远程ftp服务器，显示问候语，并打印当前工作目录'''
from ftplib import FTPf = FTP('ftp.ibiblio.org')
print "Welcome:", f.getwelcome()
f.login()#匿名登陆print "CWD:", f.pwd()
f.quit()

运行结果：

D:\python\python.exe E:/code/python/chap4/connect.py
Welcome: 220 ProFTPD Server
CWD: /

Process finished with exit code 0

2.以ascii形式下载文件
ftp以两种形式传输文件，ASCII和二进制文件
代码1：

#coding=utf-8from ftplib import FTPdef writeline(data):fd.write(data + "\n")#f = FTP('ftp.kernel.org')
f=FTP('ftp.ibiblio.org')
f.login()f.cwd('/pub/linux/kernel')#在远处系统转换目录
fd = open('README', 'wt')
f.retrlines('RETR README', writeline)
#开始传输，第一个参数指定一个在远程系统运行的命令，后一个文件名；第二个参数是函数，客户端每收到一行数据运行一次函数；
#如果省略，数据会被输出到标准输出设备上。
fd.close()f.quit()

运行结果：

README文件：
README for kernel

What you'll find here: kernel sources and patches

注：使用python实现一个基于socket的c/s模式文件传输程序。出现error: [Errno 10061]错误。查找资料提示是”目标机器积极拒绝连接”。
原因说法不过有3种:
检查目的地址或端口号书写出错。
人工检查一下代码便可排除。
目标防火墙未关闭。
使用ping命令,验证目标是否有回应,必要时可用telnet,nmap等工具尝试验证目标端口开放情况。
软件或网络状况原因。
查看python是否有联网权限,当前网络是否畅通等。
3.以二进制形式下载文件
代码：

#coding=utf-8from ftplib import FTPf = FTP('ftp.ibiblio.org')
f.login()f.cwd('/pub/linux/kernel')
fd = open('README', 'wb')
f.retrbinary('RETR README', fd.write)
#retrbinary()向指定的函数输出整块数据
fd.close()f.quit()

4.以高级形式下载文件
ntransfercmd()函数，了解传输文件细节；
代码：

#coding=utf-8from ftplib import FTP
import sysf = FTP('ftp.ibiblio.org')
f.login()f.cwd('/pub/linux/kernel')
#向服务器传输一条指令，检差有没有错
f.voidcmd("TYPE I")#TYPE I表示以二进制模式传输
#retrbinary()会在后台自动执行下载指令，nsransfercmd()不会
datasock, estsize = f.ntransfercmd("RETR README")
transbytes = 0
fd = open('README', 'wb')
while 1:buf = datasock.recv(2048)if not len(buf):breakfd.write(buf)transbytes += len(buf)sys.stdout.write("Received %d " % transbytes)if estsize:sys.stdout.write("of %d bytes (%.1f%%)\r" % \(estsize, 100.0 * float(transbytes) / float(estsize)))else:sys.stdout.write("bytes\r")sys.stdout.flush()
sys.stdout.write("\n")
fd.close()
datasock.close()
f.voidresp()#获得服务器响应，报错f.quit()

运行结果：

D:\python\python.exe E:/code/python/chap4/advbinarydl.py
Received 70 of 70 bytes (100.0%)

Process finished with exit code 0

5.上传数据
storbinary() read(),storlines() readline()

#coding=utf-8from ftplib import FTP
import sys, getpass, os.pathhost, username, localfile, remotepath = sys.argv[1:]
password = getpass.getpass("Enter password for %s on %s: " % \(username, host))
f = FTP(host)
f.login(username, password)f.cwd(remotepath)
f.voidcmd("TYPE I")fd = open(localfile, 'rb')
datasock, esize = f.ntransfercmd('STOR %s' % os.path.basename(localfile))
esize = os.stat(localfile)[6]
transbytes = 0while 1:buf = fd.read(2048)if not len(buf):breakdatasock.sendall(buf)transbytes += len(buf)sys.stdout.write("Sent %d of %d bytes (%.1f%%)\r" % (transbytes, esize,100.0 * float(transbytes) / float(esize)))sys.stdout.flush()
datasock.close()#通知服务器上传结束
sys.stdout.write("\n")
fd.close()
f.voidresp()f.quit()

6.高级二进制模式上传

#cosing=utf-8from ftplib import FTP
import sys, getpass, os.pathhost, username, localfile, remotepath = sys.argv[1:]
password = getpass.getpass("Enter password for %s on %s: " % \(username, host))
f = FTP(host)
f.login(username, password)f.cwd(remotepath)
fd = open(localfile, 'rb')
f.storbinary('STOR %s' % os.path.basename(localfile), fd)
#f.storline('STOR %s' % os.path.basename(localfile), fd)
#以二进制形式上传
fd.close()f.quit()

7.错误处理
8.扫描目录
通过 nlst(),dir()函数
nlst()函数返回给定目录下的一系列条目（信息）。当前位置下所有文件何目录的列表。没有区分文件还是目录。
dir()可以从远方服务器上返回一个目录的列表。与unix ls -l输出一样。
(1)nlst()
代码：

#coding=utf-8from ftplib import FTPf = FTP('ftp.ibiblio.org')
f.login()f.cwd('/pub/linux/kernel')
entries = f.nlst()
entries.sort()print "%d entries:" % len(entries)
for entry in entries:print entry
f.quit()

运行结果：

D:\python\python.exe E:/code/python/chap4/nlst.py
58 entries:
!INDEX
!INDEX.html
!INDEX.short.html
COPYING
LFSBOOK_ED1.iso
LFSBOOK_ED1.lsm
README
changes
config
esep-1.5.lsm
esep-1.5.tgz
getkernel-1.1.1.tar.gz
getkernel.lsm
getpatch-2.21.lsm
getpatch-2.21.tar.gz
images
irq-1.71.tar.gz
irq.lsm
iso9660-compress-2.0.tar.gz
iso9660-compress.lsm
kdebug-1.1.tgz
kernel-2.1.33.dial_on_demand_patch.gz
kernel-2.1.33.dial_on_demand_patch.lsm
kscripts-2.1.40.lsm
kscripts-2.1.40.tar.gz
linux-lite-v1.00.diff.gz
linux-lite-v1.00.lsm
linux-lite-v1.00.relnotes
linux-lite-v1.00.tar.gz
misc-cards
modremove-1.01.lsm
modremove-1.01.tar.gz
modules-2.0.0.lsm
modules-2.0.0.tar.gz
modules-3.1.3-3.1.4.diff.bz2
modules-3.1.3-3.1.4.diff.gz
modules-3.1.4.tar.bz2
modules-3.1.4.tar.gz
modules.lsm
patches
pcmcia
profil.lsm
profil.tgz
readprofile-2.0.lsm
readprofile-2.0.tar.gz
rfs-2.13-4.lsm
rfs-2.13-4.tar.bz2
sound
tapes
udma-generic-0.2.1.lsm
udma-generic-0.2.1.tar.gz
upgrade-in-a-box.2.29.lsm
upgrade-in-a-box.2.29.tar.gz
vuzkern-1.0.lsm
vuzkern.gz
xabt-1.0a.beta.README
xabt-1.0a.beta.bin.tar.gz
xabt-1.0a.beta.lsm

Process finished with exit code 0

(2)dir()
代码：

#coding=utf-8from ftplib import FTPf = FTP('ftp.ibiblio.org')
f.login()f.cwd('/pub/linux/kernel')
entries = []
f.dir(entries.append)print "%d entries:" % len(entries)
for entry in entries:print entry
f.quit()

运行结果：

D:\python\python.exe E:/code/python/chap4/dir.py
58 entries:
drwxrwsr-x 2 1029 704 4096 Feb 20 1997 changes
drwxrwsr-x 2 1029 704 4096 Feb 18 2000 config
-r--rw-r-- 1 1029 704 17982 Jun 26 1994 COPYING
-rw-rw-r-- 1 1029 704 1164 Dec 29 1997 esep-1.5.lsm
-rw-rw-r-- 1 1029 704 20691 Dec 29 1997 esep-1.5.tgz
-rw-rw-r-- 1 1029 704 9014 Feb 2 1998 getkernel-1.1.1.tar.gz
-rw-rw-r-- 1 1029 704 586 Jan 27 1998 getkernel.lsm
-rw-r--r-- 1 1029 704 1204 Apr 24 2004 getpatch-2.21.lsm
-rw-r--r-- 1 1029 704 3841 Apr 24 2004 getpatch-2.21.tar.gz
drwxrwsr-x 2 1029 704 4096 Feb 11 1999 images
-rw-rw-r-- 1 1029 704 2596 Nov 7 2007 !INDEX
-rw-rw-r-- 1 1029 704 9081 Nov 7 2007 !INDEX.html
-rw-rw-r-- 1 1029 704 4114 Nov 7 2007 !INDEX.short.html
-rw-r--r-- 1 1029 704 111147 Jul 14 2003 irq-1.71.tar.gz
-rw-r--r-- 1 1029 704 763 Jul 18 2003 irq.lsm
-rw-rw-r-- 1 1029 704 25314 Mar 13 1998 iso9660-compress-2.0.tar.gz
-rw-rw-r-- 1 1029 704 668 Mar 13 1998 iso9660-compress.lsm
-rw-rw-r-- 1 1029 704 5849 Feb 27 1995 kdebug-1.1.tgz
-rw-rw-r-- 1 1029 704 636 Apr 15 1997 kernel-2.1.33.dial_on_demand_patch.gz
-rw-rw-r-- 1 1029 704 519 Apr 15 1997 kernel-2.1.33.dial_on_demand_patch.lsm
-rw-rw-r-- 1 1029 704 612 May 28 1997 kscripts-2.1.40.lsm
-rw-rw-r-- 1 1029 704 20522 May 28 1997 kscripts-2.1.40.tar.gz
-rw-r--r-- 1 1029 704 707048680 Nov 21 2003 LFSBOOK_ED1.iso
-rw-r--r-- 1 1029 704 956 Nov 20 2003 LFSBOOK_ED1.lsm
-rw-rw-r-- 1 1029 704 31732 Apr 28 1998 linux-lite-v1.00.diff.gz
-rw-rw-r-- 1 1029 704 779 Apr 28 1998 linux-lite-v1.00.lsm
-rw-rw-r-- 1 1029 704 7406 Apr 28 1998 linux-lite-v1.00.relnotes
-rw-rw-r-- 1 1029 704 1259801 Apr 28 1998 linux-lite-v1.00.tar.gz
drwxrwsr-x 2 1029 704 4096 Jan 31 2001 misc-cards
-rw-rw-r-- 1 1029 704 563 Nov 2 1998 modremove-1.01.lsm
-rw-rw-r-- 1 1029 704 10367 Nov 2 1998 modremove-1.01.tar.gz
-rw-rw-r-- 1 1029 704 588 Jun 12 1996 modules-2.0.0.lsm
-rw-rw-r-- 1 1029 704 115459 Jun 12 1996 modules-2.0.0.tar.gz
-rw-rw-r-- 1 1029 704 14780 Aug 3 2001 modules-3.1.3-3.1.4.diff.bz2
-rw-rw-r-- 1 1029 704 14811 Aug 3 2001 modules-3.1.3-3.1.4.diff.gz
-rw-rw-r-- 1 1029 704 293843 Aug 3 2001 modules-3.1.4.tar.bz2
-rw-rw-r-- 1 1029 704 375034 Aug 3 2001 modules-3.1.4.tar.gz
-rw-rw-r-- 1 1029 704 1369 Aug 3 2001 modules.lsm
drwxrwsr-x 10 1029 704 4096 Feb 11 1999 patches
drwxr-xr-x 2 root root 4096 Dec 4 2006 pcmcia
-rw-rw-r-- 1 1029 704 466 Jul 13 1997 profil.lsm
-rw-rw-r-- 1 1029 704 1581 Feb 20 1995 profil.tgz
-rw-r--r-- 1 1029 704 70 Nov 7 2007 README
-rw-rw-r-- 1 1029 704 532 May 16 1996 readprofile-2.0.lsm
-rw-rw-r-- 1 1029 704 4068 May 16 1996 readprofile-2.0.tar.gz
-rw-r--r-- 1 1029 704 629 Oct 29 2007 rfs-2.13-4.lsm
-rw-r--r-- 1 1029 704 19735 Oct 29 2007 rfs-2.13-4.tar.bz2
drwxrwsr-x 2 1029 704 4096 Apr 23 2001 sound
drwxrwsr-x 2 1029 704 4096 Jul 26 2000 tapes
-rw-rw-r-- 1 1029 704 875 May 10 1998 udma-generic-0.2.1.lsm
-rw-rw-r-- 1 1029 704 14536 May 10 1998 udma-generic-0.2.1.tar.gz
-rw-rw-r-- 1 1029 704 1124 Feb 9 1997 upgrade-in-a-box.2.29.lsm
-rw-rw-r-- 1 1029 704 18479392 Feb 9 1997 upgrade-in-a-box.2.29.tar.gz
-rw-rw-r-- 1 1029 704 747 Sep 18 1995 vuzkern-1.0.lsm
-rw-rw-r-- 1 1029 704 1497 Sep 18 1995 vuzkern.gz
-rw-rw-r-- 1 1029 704 173279 May 25 1998 xabt-1.0a.beta.bin.tar.gz

-rw-rw-r-- 1 1029 704 422 May 25 1998 xabt-1.0a.beta.lsm
-rw-rw-r-- 1 1029 704 735 May 25 1998 xabt-1.0a.beta.README

Process finished with exit code 0

9.解析unix目录表
代码：

#coding=utf-8
from ftplib import FTP#在一个目录中的单独条目
class DirEntry:def __init__(self, line):self.parts = line.split(None, 8)def isvalid(self):return len(self.parts) >= 6def gettype(self):"""Returns - for regular file; d for directory; l for symlink."""return self.parts[0][0]def getfilename(self):if self.gettype() != 'l':return self.parts[-1]else:return self.parts[-1].split(' -> ', 1)[0]def getlinkdest(self):if self.gettype() == 'l':return self.parts[-1].split(' -> ', 1)[1]else:raise RuntimeError, "getlinkdest() called on non-link item"class DirScanner(dict):#把从dir()得到的一行数据作为参数，有效加到dictdef addline(self, line):obj = DirEntry(line)if obj.isvalid():self[obj.getfilename()] = objf = FTP('ftp.ibiblio.org')
f.login()f.cwd('/pub/linux/kernel')
d = DirScanner()
f.dir(d.addline)print "%d entries:" % len(d.keys())
for key, value in d.items():print "%s: type %s" % (key, value.gettype())f.quit()

运行结果：

D:\python\python.exe E:/code/python/chap4/dirparse.py
58 entries:
getkernel.lsm: type -
modules-3.1.4.tar.bz2: type -
modules.lsm: type -
linux-lite-v1.00.relnotes: type -
modremove-1.01.lsm: type -
getkernel-1.1.1.tar.gz: type -
upgrade-in-a-box.2.29.tar.gz: type -
COPYING: type -
images: type d
vuzkern-1.0.lsm: type -
pcmcia: type d
profil.tgz: type -
linux-lite-v1.00.diff.gz: type -
misc-cards: type d
kscripts-2.1.40.tar.gz: type -
modules-3.1.4.tar.gz: type -
profil.lsm: type -
modules-3.1.3-3.1.4.diff.bz2: type -
xabt-1.0a.beta.bin.tar.gz: type -
getpatch-2.21.tar.gz: type -
rfs-2.13-4.tar.bz2: type -
readprofile-2.0.lsm: type -
README: type -
linux-lite-v1.00.tar.gz: type -
config: type d
udma-generic-0.2.1.tar.gz: type -
modules-2.0.0.tar.gz: type -
!INDEX: type -
sound: type d
LFSBOOK_ED1.lsm: type -
patches: type d
esep-1.5.tgz: type -
modules-2.0.0.lsm: type -
rfs-2.13-4.lsm: type -
xabt-1.0a.beta.lsm: type -
kdebug-1.1.tgz: type -
udma-generic-0.2.1.lsm: type -
modremove-1.01.tar.gz: type -
!INDEX.html: type -
upgrade-in-a-box.2.29.lsm: type -
!INDEX.short.html: type -
vuzkern.gz: type -
irq.lsm: type -
kernel-2.1.33.dial_on_demand_patch.lsm: type -
kscripts-2.1.40.lsm: type -
tapes: type d
getpatch-2.21.lsm: type -
esep-1.5.lsm: type -
LFSBOOK_ED1.iso: type -
linux-lite-v1.00.lsm: type -
readprofile-2.0.tar.gz: type -
kernel-2.1.33.dial_on_demand_patch.gz: type -
xabt-1.0a.beta.README: type -
iso9660-compress-2.0.tar.gz: type -
modules-3.1.3-3.1.4.diff.gz: type -
changes: type d
irq-1.71.tar.gz: type -
iso9660-compress.lsm: type -

Process finished with exit code 0

10.不用解析表而得到目录信息
代码：

#coding=utf-8import ftplibclass DirEntry:def __init__(self, filename, ftpobj, startingdir = None):self.filename = filenameif startingdir == None:startingdir = ftpobj.pwd()try:ftpobj.cwd(filename)self.filetype = 'd'ftpobj.cwd(startingdir)except ftplib.error_perm:self.filetype = '-'def gettype(self):"""Returns - for regular file; d for directory."""return self.filetypedef getfilename(self):return self.filenamef = ftplib.FTP('ftp.ibiblio.org')
f.login()f.cwd('/pub/linux/kernel')
nitems = f.nlst()
items = [DirEntry(item, f, f.pwd()) for item in nitems]print "%d entries:" % len(items)
for item in items:print "%s: type %s" % (item.getfilename(), item.gettype())
f.quit()

运行结果：

D:\python\python.exe E:/code/python/chap4/nlstscan.py
58 entries:
changes: type d
config: type d
images: type d
misc-cards: type d
patches: type d
pcmcia: type d
sound: type d
tapes: type d
!INDEX.html: type -
!INDEX: type -
iso9660-compress-2.0.tar.gz: type -
!INDEX.short.html: type -
COPYING: type -
LFSBOOK_ED1.iso: type -
LFSBOOK_ED1.lsm: type -
README: type -
esep-1.5.lsm: type -
esep-1.5.tgz: type -
getkernel-1.1.1.tar.gz: type -
getkernel.lsm: type -
getpatch-2.21.lsm: type -
getpatch-2.21.tar.gz: type -
irq-1.71.tar.gz: type -
irq.lsm: type -
linux-lite-v1.00.relnotes: type -
iso9660-compress.lsm: type -
kdebug-1.1.tgz: type -
kscripts-2.1.40.lsm: type -
kernel-2.1.33.dial_on_demand_patch.gz: type -
kernel-2.1.33.dial_on_demand_patch.lsm: type -
kscripts-2.1.40.tar.gz: type -
linux-lite-v1.00.diff.gz: type -
linux-lite-v1.00.lsm: type -
modules-3.1.3-3.1.4.diff.bz2: type -
linux-lite-v1.00.tar.gz: type -
modremove-1.01.lsm: type -
modremove-1.01.tar.gz: type -
modules-2.0.0.lsm: type -
modules-2.0.0.tar.gz: type -
rfs-2.13-4.lsm: type -
modules-3.1.3-3.1.4.diff.gz: type -
modules-3.1.4.tar.bz2: type -
modules-3.1.4.tar.gz: type -
modules.lsm: type -
profil.lsm: type -
profil.tgz: type -
readprofile-2.0.lsm: type -
readprofile-2.0.tar.gz: type -
udma-generic-0.2.1.lsm: type -
udma-generic-0.2.1.tar.gz: type -
upgrade-in-a-box.2.29.lsm: type -
upgrade-in-a-box.2.29.tar.gz: type -
vuzkern-1.0.lsm: type -
vuzkern.gz: type -
xabt-1.0a.beta.README: type -
xabt-1.0a.beta.bin.tar.gz: type -
xabt-1.0a.beta.lsm: type -
rfs-2.13-4.tar.bz2: type -

Process finished with exit code 0

11.递归下载
代码：

#coding=utf-8
from ftplib import FTP
import os, sysclass DirEntry:def __init__(self, line):self.parts = line.split(None, 8)def isvalid(self):return len(self.parts) >= 6def gettype(self):return self.parts[0][0]def getfilename(self):if self.gettype() != 'l':return self.parts[-1]else:return self.parts[-1].split(' -> ', 1)[0]def getlinkdest(self):if self.gettype() == 'l':return self.parts[-1].split(' -> ', 1)[1]else:raise RuntimeError, "getlinkdest() called on non-link item"class DirScanner(dict):def addline(self, line):obj = DirEntry(line)if obj.isvalid():self[obj.getfilename()] = objdef downloadfile(ftpobj, filename):ftpobj.voidcmd("TYPE I")datasock, estsize = ftpobj.ntransfercmd("RETR %s" % filename)transbytes = 0fd = open(filename, 'wb')while 1:buf = datasock.recv(2048)if not len(buf):breakfd.write(buf)transbytes += len(buf)sys.stdout.write("%s: Received %d " % (filename, transbytes))if estsize:sys.stdout.write("of %d bytes (%.1f%%)\r" % (estsize,100.0 * float(transbytes) / float(estsize)))else:sys.stdout.write("bytes\r")fd.close()datasock.close()ftpobj.voidresp()sys.stdout.write("\n")def downloaddir(ftpobj, localpath, remotepath):print "*** Processing directory", remotepathlocalpath = os.path.abspath(localpath)oldlocaldir = os.getcwd()if not os.path.isdir(localpath):os.mkdir(localpath)olddir = ftpobj.pwd()try:os.chdir(localpath)ftpobj.cwd(remotepath)d = DirScanner()f.dir(d.addline)for filename, entryobj in d.items():if entryobj.gettype() == '-':downloadfile(ftpobj, filename)elif entryobj.gettype() == 'd':downloaddir(ftpobj, localpath + '/' + filename,remotepath + '/' + filename)# Re-display directory infoprint "*** Processing directory", remotepathfinally:os.chdir(oldlocaldir)ftpobj.cwd(olddir)f = FTP('ftp.ibiblio.org')
f.login()downloaddir(f, 'kernel', '/pub/linux/kernel')f.quit()

12.操作服务器上的文件和目录
delete()删除一个文件
rmd()删除一个目录
mkdir()建立目录
rename()移动重命名文件夹