国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > Python > 正文

python網絡編程之TCP通信實例和socketserver框架使用例子

2019-11-25 18:26:25
字體:
來源:轉載
供稿:網友

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



2.python可以實現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模塊可以簡化網絡服務器的編寫,它包含了四種服務器類,TCPServer使用TCP協(xié)議,UDPServer使用UDP協(xié)議,還有兩個不常使用的,即UnixStreamServer和UnixDatagramServer,這兩個類僅僅在unix環(huán)境下有用。

    使用服務器編程,需要進行一下步驟,先建立一個請求句柄類,這個類繼承自BaseRequestHandler類,建立這個類后重寫它的handle方法,然后實例化服務器類,把主機名,端口號和句柄類傳給它,然后調用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實現,實現多進程或者多線程服務器。下面是使用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()

發(fā)表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發(fā)表
主站蜘蛛池模板: 兴安县| 东丰县| 小金县| 临沭县| 甘谷县| 平乐县| 松江区| 平凉市| 马山县| 高陵县| 哈巴河县| 腾冲县| 图片| 建平县| 左云县| 舞阳县| 汨罗市| 武宁县| 塔河县| 城步| 涿鹿县| 璧山县| 黄山市| 南皮县| 金堂县| 射洪县| 四平市| 伊春市| 开封市| 恩平市| 改则县| 汉阴县| 华阴市| 湘阴县| 鸡泽县| 海口市| 托克托县| 贵定县| 永嘉县| 当雄县| 报价|