快捷導(dǎo)航

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

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

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

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

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

服務(wù)器端：

復(fù)制代碼代碼如下:

#!/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

客戶端：

復(fù)制代碼代碼如下:

#!/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服務(wù)器

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

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

使用socketserver框架的服務(wù)器：

復(fù)制代碼代碼如下:

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服務(wù)器只能處理一個(gè)請(qǐng)求，如果要處理多個(gè)請(qǐng)求，可以用forking或者threading實(shí)現(xiàn)，實(shí)現(xiàn)多進(jìn)程或者多線程服務(wù)器。下面是使用forking和threading的服務(wù)器代碼：

使用forking的服務(wù)器：

復(fù)制代碼代碼如下:

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()

使用多線程的服務(wù)器：

復(fù)制代碼代碼如下:

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()

您可能感興趣的文章: