Python中常用网络编程模块

bind('127.0.0.1',1051)    绑定ip地址和端口，如果地址为空则表示本机；
    listen(backlog)      　　  监听所有socket对象创建的连接，backlog指定连接队列数，最小为1，最大一般为5；
    connect(address)
    connect_ex(address)   　　 两个都可以连接到服务端，不同的是第一个返回一个错误，第二个返回一个异常；
    accept()       　　　　　　 接收来自客户端的数据，返回一个新的socket对象和客户端地址；
    recv(bufsize,flags)   　　 仅返回所接收的字符串；bufsize指定接收缓冲区的大小，flags为可选参数，表示接收标志；
    recvfrom(bufsize,flags)    返回所接收的字符串和地址；
    send(string,flags)   　　  向已经连接的socket发送数据；
    sendall(string,flags)      与send不同的是将会一直发送完全部数据；
    sendto(string,flags,address)可以向一个未连接的socket发送数据；
    makefile(mode,bufsize)     将socket关联到文件对象上，两个参数都是可选的，mode文件模式，bufsize缓冲区大小；
    close()            　　　　 完成通信后，应使用close方法关闭网络连接；

import socket
sock = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
sock.bind('127.0.0.1',20178)
sock.listen(5)
conn,address = sock.accept()
print('connect by ',address)
while True:
    data = conn.recv(100)
    if not data:break
    print(data)
    conn.send("anydata")
sock.close()

import socket
sock = socket.socket(socket.AF_INET,socket.SOCK_STREAM)  #与服务端相同
sock.connect('127.0.0.1',20178)
sock.send("data")
data = sock.recv(98)
print('recieved ',data)
sock.close()

# 服务端实例
import socket
import select
import queue

sock = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
sock.setblocking(False)   #设置为非阻塞服务
sock.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
sock.bind('127.0.0.1',20178)
sock.listen(10)
rlists = [sock]
wlists = []
msg_que = {}
timeout = 20

while rlists:
    rs,ws,es = select.select(rlists,wlists,rlists,timeout)
    if not (rs or ws or es):
        print('timeout...')
        break
    for s in rs:
        if s is sock:
            conn,address = s.accept()
            conn.setblocking(False)
            rlists.append(conn)
            msg_que[conn] = queue.Queue()
        else:
            data = s.recv(1024)
            if data:
                print(data)
                msg_que[s].put(data)
                if s not in wlists:
                    wlists.append(s)
            else:
                if s in wlists:
                    wlists.remove(s)
                rlists.remove(s)
                s.close()
                del msg_que[s]
    for s in ws:
        try:
            msg = msg_que[s].get_nowait()
        except queue.Empty:
            wlists.remove(s)
    for s in es:
        print('except ',s.getpeername())
        if s in rlists:
            rlists.remove(s)
        if s in wlists:
            wlists.remove(s)
        s.close()
        del msg_que[s]

FTP(host,user,passwd,acct)    创建一个FTP连接对象
    getwelcome()          　　 获得FTP服务器的欢迎信息
    abort()                   中断文件传输
    sendcmd(command)          发送命令，command为一个字符串
    voidcmd(command)          发送命令，但没有返回值
    retrbinary(command,callback,maxblocksize,rest) 下载文件（二进制）
        command        　　　　由"RETR 文件名  组成"
        callback    　　　　　　回调函数
        maxblocksize　　　　　　每次传输最大字节数
        rest        　　　　　　文件续传位置
    retrlines(command,callback)下载文件（ASCII）
    storbinary(command,file,blocksize)    以二进制上传文件；
    storlines(command,file)    以ASCII形式上传文件；
    dir()            　　　　   获取当前目录的内容列表；
    rename(fromname,toname)    重命名
    delete(filename)    　　　　删除文件
    cwd(pathname)        　　　 改变当前目录
    mkd(pathname)        　　　 创建目录
    rmd(dirname)        　　　　删除服务器上的目录
    size(filename)        　　　获取文件大小
    set_pasv(boolean)    　　　 设置传输模式
    quit()                
    close()                　　关闭服务器的连接
set_debuglevel(level)         设置调试级别
connect(host,port)            配置host
login(user,passwd,acct)       登录