PYTHON SOCKET程式設計詳細介紹
Python提供了兩個基本的 socket 模組。
第一個是 Socket,它提供了標準的 BSD Sockets API。
第二個是 SocketServer, 它提供了伺服器中心類,可以簡化網路伺服器的開發。
下面講的是Socket模組功能
1、Socket型別
套接字格式:
socket(family,type[,protocal])使用給定的地址族、套接字型別、協議編號(預設為0)來建立套接字。
socket型別 |
描述 |
socket.AF_UNIX |
只能夠用於單一的Unix系統程序間通訊 |
socket.AF_INET |
伺服器之間網路通訊 |
socket.AF_INET6 |
IPv6 |
socket.SOCK_STREAM |
流式socket , for TCP |
socket.SOCK_DGRAM |
資料報式socket , for UDP |
socket.SOCK_RAW |
原始套接字,普通的套接字無法處理ICMP、IGMP等網路報文,而SOCK_RAW可以;其次,SOCK_RAW也可以處理特殊的IPv4報文;此外,利用原始套接字,可以通過IP_HDRINCL套接字選項由使用者構造IP頭。 |
socket.SOCK_SEQPACKET |
可靠的連續資料包服務 |
建立TCP Socket: |
|
建立UDP Socket: |
s=socket.socket(socket.AF_INET,socket.SOCK_DGRAM) |
2、Socket函式
注意點:
1)TCP傳送資料時,已建立好TCP連線,所以不需要指定地址。UDP是面向無連線的,每次傳送要指定是發給誰。
2)服務端與客戶端不能直接傳送列表,元組,字典。需要字串化repr(data)。
socket函式 |
描述 |
|
服務端socket函式 |
||
s.bind(address) |
將套接字繫結到地址,在AF_INET下,以元組(host,port)的形式表示地址. |
|
s.listen(backlog) |
開始監聽TCP傳入連線。backlog指定在拒絕連線之前,作業系統可以掛起的最大連線數量。該值至少為1,大部分應用程式設為5就可以了。 |
|
s.accept() |
接受TCP連線並返回(conn,address),其中conn是新的套接字物件,可以用來接收和傳送資料。address是連線客戶端的地址。 |
|
客戶端socket函式 |
||
s.connect(address) |
連線到address處的套接字。一般address的格式為元組(hostname,port),如果連接出錯,返回socket.error錯誤。 |
|
s.connect_ex(adddress) |
功能與connect(address)相同,但是成功返回0,失敗返回errno的值。 |
|
公共socket函式 |
||
s.recv(bufsize[,flag]) |
接受TCP套接字的資料。資料以字串形式返回,bufsize指定要接收的最大資料量。flag提供有關訊息的其他資訊,通常可以忽略。 |
|
s.send(string[,flag]) |
傳送TCP資料。將string中的資料傳送到連線的套接字。返回值是要傳送的位元組數量,該數量可能小於string的位元組大小。 |
|
s.sendall(string[,flag]) |
完整發送TCP資料。將string中的資料傳送到連線的套接字,但在返回之前會嘗試傳送所有資料。成功返回None,失敗則丟擲異常。 |
|
s.recvfrom(bufsize[.flag]) |
接受UDP套接字的資料。與recv()類似,但返回值是(data,address)。其中data是包含接收資料的字串,address是傳送資料的套接字地址。 |
|
s.sendto(string[,flag],address) |
傳送UDP資料。將資料傳送到套接字,address是形式為(ipaddr,port)的元組,指定遠端地址。返回值是傳送的位元組數。 |
|
s.close() |
關閉套接字。 |
|
s.getpeername() |
返回連線套接字的遠端地址。返回值通常是元組(ipaddr,port)。 |
|
s.getsockname() |
返回套接字自己的地址。通常是一個元組(ipaddr,port) |
|
s.setsockopt(level,optname,value) |
設定給定套接字選項的值。 |
|
s.getsockopt(level,optname[.buflen]) |
返回套接字選項的值。 |
|
s.settimeout(timeout) |
設定套接字操作的超時期,timeout是一個浮點數,單位是秒。值為None表示沒有超時期。一般,超時期應該在剛建立套接字時設定,因為它們可能用於連線的操作(如connect()) |
|
s.gettimeout() |
返回當前超時期的值,單位是秒,如果沒有設定超時期,則返回None。 |
|
s.fileno() |
返回套接字的檔案描述符。 |
|
s.setblocking(flag) |
如果flag為0,則將套接字設為非阻塞模式,否則將套接字設為阻塞模式(預設值)。非阻塞模式下,如果呼叫recv()沒有發現任何資料,或send()呼叫無法立即傳送資料,那麼將引起socket.error異常。 |
|
s.makefile() |
建立一個與該套接字相關連的檔案 |
3、socket程式設計思路
TCP服務端:
1建立套接字,繫結套接字到本地IP與埠
#socket.socket(socket.AF_INET,socket.SOCK_STREAM), s.bind()
2開始監聽連線 #s.listen()
3進入迴圈,不斷接受客戶端的連線請求 #s.accept()
4然後接收傳來的資料,併發送給對方資料 #s.recv() , s.sendall()
5傳輸完畢後,關閉套接字 #s.close()
TCP客戶端:
1建立套接字,連線遠端地址
#socket.socket(socket.AF_INET,socket.SOCK_STREAM), s.connect()
2連線後傳送資料和接收資料 # s.sendall(), s.recv()
3傳輸完畢後,關閉套接字 #s.close()
4、Socket程式設計之服務端程式碼:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 |
root@yangrong: / python # catday5-socket-server.py
#!/usr/bin/python
import socket #socket模組
import commands #執行系統命令模組
HOST = '10.0.0.245'
PORT = 50007
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM) #定義socket型別,網路通訊,TCP
s.bind((HOST,PORT)) #套接字繫結的IP與埠
s.listen( 1 ) #開始TCP監聽,監聽1個請求
while 1 :
conn,addr = s.accept() #接受TCP連線,並返回新的套接字與IP地址
print 'Connected by' ,addr #輸出客戶端的IP地址
while 1 :
data = conn.recv( 1024 ) #把接收的資料例項化
cmd_status,cmd_result = commands.getstatusoutput(data) #commands.getstatusoutput執行系統命令(即shell命令),返回兩個結果,第一個是狀態,成功則為0,第二個是執行成功或失敗的輸出資訊
if len (cmd_result.strip()) = = 0 : #如果輸出結果長度為0,則告訴客戶端完成。此用法針對於建立檔案或目錄,建立成功不會有輸出資訊
conn.sendall( 'Done.' )
else :
conn.sendall(cmd_result) #否則就把結果發給對端(即客戶端)
conn.close() #關閉連線
|
5、Socket程式設計之客戶端程式碼:
1 2 3 4 5 6 7 8 9 10 11 12 13 |
root@yangrong: / python # catday5-socket-client.py
#!/usr/bin/python
import socket
HOST = '10.0.0.245'
PORT = 50007
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM) #定義socket型別,網路通訊,TCP
s.connect((HOST,PORT)) #要連線的IP與埠
while 1 :
cmd = raw_input ( "Please input cmd:" ) #與人互動,輸入命令
s.sendall(cmd) #把命令傳送給對端
data = s.recv( 1024 ) #把接收的資料定義為變數
print data #輸出變數
s.close() #關閉連線
來源:http://blog.csdn.net/rebelqsp/article/details/22109925 |