Python socket模組程式設計 SocketServer框架
本文簡要介紹socket模組包含的類及其使用。
1.開始瞭解socket模組前,先熟悉下Python的網路程式設計模組主要支援的兩種Intent協議:TCP和UDP。TCP協議是一種面向連線的可靠協議,用於建立機器之間的雙向通訊流。UDP協議是一種較低級別的、以資料包為基礎的協議(無連線傳輸模式)。與TCP不同,UDP資訊不可靠。
他們的區別如下圖所示:左圖為TCP連線協議,右圖為UDP連線協議
2.socket模組的部分類方法介紹
類方法 |
說明 |
|
socket.socket(family, type[,proto]) |
建立並返回一個新的 socket物件 |
|
socket.getfqdn(name) |
將使用點號分隔的 IP地址字串轉換成一個完整的域名 |
|
socket.gethostbyname(hostname) |
將主機名解析為一個使用點號分隔的 IP地址字串 |
|
socket.gethostbyname_ex(name) |
它返回一個包含三個元素的元組,從左到右分別是給定地址的主要的主機名、同一IP地址的可選的主機名的一個列表、關於同一主機的同一介面的其它IP地址的一個列表(列表可能都是空的)。 |
|
socket.gethostbyaddr(address) |
作用與gethostbyname_ex相同,只是你提供給它的引數是一個IP地址字串 |
|
Socket.getservbyname(service,protocol) |
它要求一個服務名(如'telnet'或'ftp')和一個協議(如'tcp'或'udp'),返回服務所使用的埠號 |
|
socket.fromfd(fd, family, type) |
從現有的檔案描述符建立一個 socket物件 |
3.socket物件的部分方法介紹
例項方法 |
說明 |
sock.bind( (adrs, port) ) |
將 socket繫結到一個地址和埠上 |
sock.accept() |
返回一個客戶機 socket(帶有客戶機端的地址資訊) |
sock.listen(backlog) |
將 socket設定成監聽模式,能夠監聽 backlog 外來的連線請求 |
sock.connect( (adrs, port) ) |
將 socket連線到定義的主機和埠上 |
sock.recv( buflen[, flags] ) |
從 socket中接收資料,最多 buflen 個字元 |
sock.recvfrom( buflen[, flags] ) |
從 socket中接收資料,最多 buflen 個字元,同時返回資料來源的遠端主機和埠號 |
sock.send( data[, flags] ) |
通過 socket傳送資料 |
sock.sendto( data[, flags], addr ) |
通過 socket傳送資料 |
sock.close() |
關閉 socket |
sock.getsockopt( lvl, optname ) |
獲得指定 socket 選項的值 |
sock.setsockopt( lvl, optname, val ) |
設定指定 socket選項的值 |
4.編寫socket測試程式
(a)編寫server的步驟
第一步是建立socket物件。呼叫socket建構函式。如:
socket = socket.socket( family, type )
family引數代表地址家族,可為AF_INET或AF_UNIX。AF_INET家族包括Internet地址,AF_UNIX家族用於同一臺機器上的程序間通訊。
type引數代表套接字型別,可為SOCK_STREAM(流套接字)和SOCK_DGRAM(資料報套接字)。
第二步是將socket繫結到指定地址。這是通過socket物件的bind方法來實現的:
socket.bind( address )
由AF_INET所建立的套接字,address地址必須是一個雙元素元組,格式是(host,port)。host代表主機,port代表埠號。如果埠號正在使用、主機名不正確或埠已被保留,bind方法將引發socket.error異常。
第三步是使用socket套接字的listen方法接收連線請求。
socket.listen( backlog )
backlog指定最多允許多少個客戶連線到伺服器。它的值至少為1。收到連線請求後,這些請求需要排隊,如果佇列滿,就拒絕請求。
第四步是伺服器套接字通過socket的accept方法等待客戶請求一個連線。
connection, address = socket.accept()
調 用accept方法時,socket會時入“waiting”狀態。客戶請求連線時,方法建立連線並返回伺服器。accept方法返回一個含有兩個元素的元組(connection,address)。第一個元素connection是新的socket物件,伺服器必須通過它與客戶通訊;第二個元素 address是客戶的Internet地址。
第 五步是處理階段,伺服器和客戶端通過send和recv方法通訊(傳輸 資料)。伺服器呼叫send,並採用字串形式向客戶傳送資訊。send方法返回已傳送的字元個數。伺服器使用recv方法從客戶接收資訊。呼叫recv 時,伺服器必須指定一個整數,它對應於可通過本次方法呼叫來接收的最大資料量。recv方法在接收資料時會進入“blocked”狀態,最後返回一個字元 串,用它表示收到的資料。如果傳送的資料量超過了recv所允許的,資料會被截短。多餘的資料將緩衝於接收端。以後呼叫recv時,多餘的資料會從緩衝區 刪除(以及自上次呼叫recv以來,客戶可能傳送的其它任何資料)。
傳輸結束,伺服器呼叫socket的close方法關閉連線。(b)編寫client的步驟
首先建立一個socket以連線伺服器:socket =socket.socket( family, type )
使用socket的connect方法連線伺服器。對於AF_INET家族,連線格式如下:
socket.connect( (host,port) )
host代表伺服器主機名或IP,port代表伺服器程序所繫結的埠號。如連線成功,客戶就可通過套接字與伺服器通訊,如果連線失敗,會引發socket.error異常。
處理階段,客戶和伺服器將通過send方法和recv方法通訊。
傳輸結束,客戶通過呼叫socket的close方法關閉連線。5.例項原始碼:Python socket半雙工聊天
(a)tcpserver.py
- # -*- coding: cp936 -*-
- #file:tcpserver.py
- import socket
- from time import ctime
- import sys
- bufsize = 1024
- host = '127.0.0.1'
- port = 8100
- address = (host,port)
- server_sock = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
- server_sock.bind(address)
- server_sock.listen(1)
- whileTrue:
- print'waiting for connection...'
- clientsock,addr = server_sock.accept()
- print'received from :',addr
- whileTrue:
- data = clientsock.recv(bufsize)
- print' 收到---->%s\n%s' %(ctime(),data)
- data = raw_input("傳送----->")
- clientsock.send(data)
- clientsock.close()
- server_sock.close()
- ## -*- coding: cp936 -*-
- ##file:tcpclient.py
- from socket import *
- from time import ctime
- bufsize = 1024
- host = '127.0.0.1'
- port = 8100
- addr = (host,port)
- client_sock = socket(AF_INET,SOCK_STREAM)
- client_sock.connect(addr)
- whileTrue:
- data = raw_input("傳送---->")
- ifnot data:
- break
- else:
- client_sock.send(data)
- data = client_sock.recv(bufsize)
- print'收到---->%s\n%s' %(ctime(),data)
- client_sock.close()
(c)執行結果:左邊截圖為server,右邊截圖為client
ref: http://blog.csdn.net/vicken520/article/details/8292835
1.前言:
雖說用Python編寫簡單的網路程式很方便,但複雜一點的網路程式還是用現成的框架比較好。這樣就可以專心事務邏輯,而不是套接字的各種細節。SocketServer模組簡化了編寫網路服務程式的任務。同時SocketServer模組也是Python標準庫中很多伺服器框架的基礎。
2.網路服務類:
SocketServer提供了4個基本的服務類:
TCPServer針對TCP套接字流
UDPServer針對UDP資料報套接字
UnixStreamServer和UnixDatagramServer針對UNIX域套接字,不常用。
它們的繼承關係如下:
+------------+
| BaseServer |
+------------+
|
v
+-----------+ +------------------+
| TCPServer |------->| UnixStreamServer |
+-----------+ +------------------+
|
v
+-----------+ +--------------------+
| UDPServer |------->| UnixDatagramServer |
+-----------+ +--------------------+
2.1非同步處理:
這個四個服務類都是同步處理請求的。一個請求沒處理完不能處理下一個請求。要想支援非同步模型,可以利用多繼承讓server類繼承ForkingMixIn 或 ThreadingMixIn mix-in classes。
ForkingMixIn利用多程序(分叉)實現非同步。
ThreadingMixIn利用多執行緒實現非同步。
3.請求處理類:
要實現一項服務,還必須派生一個handler class請求處理類,並重寫父類的handle()方法。handle方法就是用來專門是處理請求的。該模組是通過服務類和請求處理類組合來處理請求的。
SocketServer模組提供的請求處理類有BaseRequestHandler,以及它的派生類StreamRequestHandler和DatagramRequestHandler。從名字看出可以一個處理流式套接字,一個處理資料報套接字。
4.總結用SocketServer建立一個服務的步驟:
1.建立一個request handler class(請求處理類),繼承自BaseRequestHandler class並重寫它的handle()方法,該方法將處理到的請求。
2.例項化一個server class物件,並將服務的地址和之前建立的request handler class傳遞給它。
3.呼叫server class物件的handle_request() 或 serve_forever()方法來開始處理請求。
一個基於SocketServer的伺服器示例:
from
SocketServer import
TCPServer,StreamRequestHandler
#定義請求處理類
class
Handler(StreamRequestHandler):
def
handle( self ):
addr
= self .request.getpeername()
print
'Got connection from ' ,addr
self .wfile.write( 'Thank you for connecting' )
= TCPServer(('', 1234 ), handler) #例項化服務類物件
server.server_forever() #開啟服務
|
5.實現非同步,支援多連線
前面介紹服務類時提到過,四個基本的服務類預設是同步模型的。要想支援非同步可以利用多繼承從ForkingMixIn 或ThreadingMixInmix-in classes和一個基本的服務類繼承來定義一個支援非同步的服務類。比如:
class Server(ThreadingMixIn, TCPServer): pass
ForkingMixIn 要考慮程序間的通訊。ThreadingMixIn要考慮執行緒訪問同一變數時的同步和互斥。
一個使用了多執行緒處理的伺服器示例:
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(
'Thank you for connection'
)
server
=
Server(('',
1234
), Handler)
#例項化服務類
.serve_forever()
#開啟服務
ref: http://www.pythontab.com/html/2013/pythonjichu_0705/480.html