python網(wǎng)絡編程之TCP通信實例和socketserver框架使用例子

更新時間：2014年04月25日 10:47:46 作者：

這篇文章主要介紹了python網(wǎng)絡編程之TCP通信實例和socketserver框架使用例子,需要的朋友可以參考下

1.TCP是一種面向連接的可靠地協(xié)議，在一方發(fā)送數(shù)據(jù)之前，必須在雙方之間建立一個連接，建立的過程需要經(jīng)過三次握手，通信完成后要拆除連接，需要經(jīng)過四次握手，這是由TCP的半關閉造成的，一方在完成數(shù)據(jù)發(fā)送后要發(fā)送一個FIN來終止這個方向的連接，一個TCP連接在收到一個FIN后仍能發(fā)送數(shù)據(jù)，但應用程序很少這么做，下面是TCP連接建立和拆除的過程：

2.python可以實現(xiàn)TCP服務器和客戶端的編程，下面是代碼：

服務器端：

復制代碼代碼如下:

#!/usr/bin/env python
import socket
host="localhost"
port=10000
s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
s.bind((host,port))
s.listen(5)
while 1:
sock,addr=s.accept()
print "got connection form ",sock.getpeername()
data=sock.recv(1024)
if not data:
break
else:
print data

客戶端：

復制代碼代碼如下:

#!/usr/bin/env python
import socket
host="localhost"
port=10000
s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
s.connect((host,port))
s.send("hello from client")
s.close()

3.使用socketserver框架編寫TCP服務器

Socketserver模塊可以簡化網(wǎng)絡服務器的編寫，它包含了四種服務器類，TCPServer使用TCP協(xié)議，UDPServer使用UDP協(xié)議，還有兩個不常使用的，即UnixStreamServer和UnixDatagramServer,這兩個類僅僅在unix環(huán)境下有用。

使用服務器編程，需要進行一下步驟，先建立一個請求句柄類，這個類繼承自BaseRequestHandler類，建立這個類后重寫它的handle方法，然后實例化服務器類，把主機名，端口號和句柄類傳給它，然后調(diào)用server_forever()方法來處理請求。

使用socketserver框架的服務器：

復制代碼代碼如下:

import SocketServer
host=''
port=10000
class Handler(SocketServer.StreamRequestHandler):

def handler(self):
  addr=self.request.getpeername()
  print "got connection from",addr
  self.wfile.write("connected")

server=SocketServer.TCPServer((host,port),Handler)
server.serve_forever()

上面的socketserver服務器只能處理一個請求，如果要處理多個請求，可以用forking或者threading實現(xiàn)，實現(xiàn)多進程或者多線程服務器。下面是使用forking和threading的服務器代碼：

使用forking的服務器：

復制代碼代碼如下:

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

def handle(self):
  addr=self.request.getpeername()
  print "got connection from",addr
  self.wfile.write('connected')

server=Server((''.10000),Handler)
server.serve_forever()

使用多線程的服務器：

復制代碼代碼如下:

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

class Handler(StreamRequestHandler):
def handle(self):
  addr=self.request.getpeername()
  print "got connection from",addr
  self.wfile.write("connected")

server=Server(('',10000),Handler)
server.serve_forever()

您可能感興趣的文章: