python 14章，网络编程

python 14章，网络编程

一，socket 模块

套接字包括两类：服务器，客户机，

创建一个套接字后让它等待连接

服务器：

import socket
s = socket.socket()
port = 1234
host = socket.gethostname()
print host
s.bind((host,port))
s.listen(5)
while True:
    get,addr = s.accept()
    print 'Got connection from',addr
    get.send('Thank you for connecting')
    get.close()

客户机：

import socket
s = socket.socket()
host = socket.gethostname()
port = 1234
s.connect((host,port))
print s.recv(1024)

>>>
Z5WRYRLDY59AL03
Got connection from ('222.27.174.175', 53389)
Got connection from ('222.27.174.175', 53398)
Got connection from ('222.27.174.175', 53405)
Got connection from ('222.27.174.175', 53407)

>>> ================================ RESTART ================================
>>>
Thank you for connecting
>>> ================================ RESTART ================================
>>>
Thank you for connecting
>>> ================================ RESTART ================================
>>>
Thank you for connecting
>>> ================================ RESTART ================================
>>>
Thank you for connecting

二，urllib,urllib2

可以通过 网络访问文件，借用URL简单下载用urllib 如果要用http验证或用cookie 用urllib2

1.打开远程文件

from urllib import urlopen

webpage = urlopen("http://www.baidu.com")

urlopen 方法：close,read,readline,readlines

2.获取远程文件

urlretrieve('http://www.python.org','c:\\python.html')

默认放在临时位置，用urlcleanup清理

三，SocketServer

SocketServer是许多服务器框架的基础如：BaseHTTPServer,SimpleHTTPServer,CGIHTTPServer

SocketSever包含4个基本类：1针对TCP套接字流的TCPServer，２.针对UDP数据报UDPServer 3.UnixStreamServer 4.UnixDatagramServer

服务器：

from SocketServer import TCPServer,StreamRequestHandler
import socket
class Handler(StreamRequestHandler):

    def handle(self):
        addr = self.request.getpeername()
        print 'Got connection from',addr
        self.wfile.write('Thank you for connecting!!!')
host = socket.gethostname()
server = TCPServer((host,1234),Handler)
server.serve_forever()

>>>
Thank you for connecting!!!
>>>

Got connection from ('222.27.174.175', 55479)

四，多连接

3种方法： 分叉（forking），线程(threading)，异步IO(asynchronous I/O)

使用SocketServer进行分叉和线程处理

from SocketServer import TCPServer,ForkingMixIn,StreamRequestHandler
import socket
class Server(ForkingMixIn,TCPServer):pass

class Handler(StreamRequestHandler):

    def handle(self):
        addr = self.request.getpeername()
        print 'Got connection from',addr
        self.wfile.write('Thank you for connecting ...')
host = socket.gethostname()
server = Server(('',1234),Handler)
server.serve_forever()

使用select

import socket,select
s = socket.socket()
host = socket.gethostname()
port = 3306
print host
s.bind((host,port))

s.listen(5)
inputs = [s]
while True:
    rs,ws,es = select.select(inputs,[],[])
    for r in rs:
        if r is s:
            c,addr = s.accept()
            print 'Got connection form',addr
            inputs.append(c)
        else:
            try:
                data = r.recv(1024)
                disconnected = not data
                if data:
                    r.send('yes!I can hear you!')
            except socket.error:
                disconnected = True

            if disconnected:
                print r.getpeername(),'disconnected'
                inputs.remove(r)
            else:
                print data