python 网络编程详解及简单实例
python网络编程详解
网络编程的专利权应该属于Unix,各个平台(如windows、Linux等)、各门语言(C、C++、Python、Java等)所实现的符合自身特性的语法都大同小异。在我看来,懂得了Unix的socket网络编程,其他的形式的网络编程方法也就知道了。这句话说得还不太严谨。准确的应该说成懂得了socket编程的原理,网络编程也就知道了,不同之处就在于每个平台,每个语言都有自己专享的语法,我们直接灵活套用就行了。
下面是用python实现的最基本的网络编程的例子,即依托于客户端-服务器的架构,实现客户端与服务器之间的单向“数据流通”。我们分别用两个方法来实现,一个方法是最原始的socket编程,另一个方法是利用python的面向对象对第一种方法进行封装实现,目的是减少实现透明性,便于快速开发。
要求:客户端输入数据,发送到服务端,服务器端生成(时间戳+数据)的封装数据回应客户端。由于socket编程包括两种:面向连接的和无连接的,这两种分别对应TCP数据流和UDP数据报文。所以,我们两种方法都进行实现。
一、Pythonsocket编程
面向连接的TCPsocket编程:
#-*-coding:utf-8-*-
3fromsocketimport*
fromtimeimportctime
#AddressandPort
HOST=''
PORT=21567
ADDR=(HOST,PORT)
#BuffSize
BUFSIZ=1024
#buildsocket
tcpSerSock=socket(AF_INET,SOCK_STREAM)
#bindsocket
tcpSerSock.bind(ADDR)
#listen5client
tcpSerSock.listen(5)
try:
whileTrue:
print'waitingforconnection...'
#buildclientsocket
tcpCliSock,addr=tcpSerSock.accept()
print'...connectfrom:',addr
#acceptdataandprocess
whileTrue:
data=tcpCliSock.recv(BUFSIZ)
ifnotdata:
break
tcpCliSock.send('[%s]%s'%(ctime(),data))
#closeclientsocket
tcpCliSock.close()
exceptEOFError,KeyboardInterrupt:
tcpSerSock.close()
#-*-coding:utf-8-*-
fromsocketimport*
#AddressandPort
HOST='127.0.0.1'
PORT=21567
ADDR=(HOST,PORT)
#BufferSize
BUFSIZ=1024
#buildsocket
tcpCliSocket=socket(AF_INET,SOCK_STREAM)
tcpCliSocket.connect(ADDR)
whileTrue:
data=raw_input('>')
ifnotdata:
break
#senddata
tcpCliSocket.send(data)
#recvdata
data=tcpCliSocket.recv(BUFSIZ)
ifnotdata:
break
#showdata
printdata
tcpCliSocket.close()
无连接的UDPsocket编程
#-*-coding:utf-8-*-
fromsocketimport*
fromtimeimportctime
#AddressandPort
HOST=''
PORT=8000
ADDR=(HOST,PORT)
#BufferSize
BUFFSIZE=1024
#buildsocket
udpSerSock=socket(AF_INET,SOCK_DGRAM)
#bindsocket
udpSerSock.bind(ADDR)
try:
whileTrue:
print'waitingthemessage...'
data,addr=udpSerSock.recvfrom(BUFFSIZE)
print'receivedthemessage:'+data+'from:',addr
udpSerSock.sendto('[%s]%s'%(ctime(),data),addr)
exceptEOFError,KeyboardInterrupt:
udpSerSock.close()
#-*-coding:utf-8-*-
fromsocketimport*
#AddressandPort
HOST='localhost'
PORT=8000
ADDR=(HOST,PORT)
#BufferSize
BUFSIZ=1024
#buildsocket
udpCliSock=socket(AF_INET,SOCK_DGRAM)
whileTrue:
data=raw_input('>')
udpCliSock.sendto(data,ADDR)
data=udpCliSock.recvfrom(BUFSIZ)
ifnotdata:
break
printdata
udpCliSock.close()
二、基于封装类SocketServer的网络编程
#-*-coding:utf-8-*-
fromSocketServerimportTCPServerasTCP,StreamRequestHandlerasSRH
fromtimeimportctime
#AddressandPort
HOST=''
PORT=21567
ADDR=(HOST,PORT)
#BuffSize
BUFSIZ=1024
#buildRequestHandler
classMyRequestHandler(SRH):
defhandle(self):
print'...connectedfrom:',self.client_address
self.wfile.write('[%s]%s'%(ctime(),self.rfile.readline()))
#buildTCPServer
TCPServ=TCP(ADDR,MyRequestHandler)
print'waitingforconnection...'
#looptoprocess
TCPServ.serve_forever()
#-*-coding:utf-8-*-
fromsocketimport*
#AddressandPort
HOST='127.0.0.1'
PORT=21567
ADDR=(HOST,PORT)
#BufferSize
BUFSIZ=1024
whileTrue:
#note:SocketServer的请求处理器的默认行为是接受连接,
#得到请求,然后就关闭连接,所以需要多次连接
tcpCliSock=socket(AF_INET,SOCK_STREAM)
tcpCliSock.connect(ADDR)
#processdata
data=raw_input('>')
ifnotdata:
break
tcpCliSock.send('%s\r\n'%data)
data=tcpCliSock.recv(BUFSIZ)
ifnotdata:
break
printdata.strip()
tcpCliSock.close()
感谢阅读,希望能帮助大家,谢谢大家对本站的支持!