天天看點

python socket程式設計詳細介紹

Python 提供了兩個基本的 socket 子產品。

   第一個是 Socket,它提供了标準的 BSD Sockets API。

   第二個是 SocketServer, 它提供了伺服器中心類,可以簡化網絡伺服器的開發。

下面講的是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)

注意點:

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

建立一個與該套接字相關連的檔案

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

服務端執行效果:

python socket程式設計詳細介紹

用戶端執行效果:

python socket程式設計詳細介紹

這是一個簡單的socket通信,裡面存在一些bug

1.在用戶端輸入回車,會挂死。

2.服務端傳回的資料大于1024,用戶端顯示不全。

3.單程序,如果多個用戶端連接配接,要排隊,前一個斷開,後一個用戶端才能通信。

不想把代碼寫的太複雜,簡單的說下解決方案:

問題1.在用戶端上判斷輸入為空,要求重新輸入。

問題2.在用戶端上循環接收,直到接收完。但有沒有完用戶端是不知道的,需要服務端發一個結束符。

問題3.在服務端導入SocketServer子產品,使得每建立一個連接配接,就新建立一個線程。實作多個用戶端與服務端通信。多線程通信原理如下圖:

python socket程式設計詳細介紹

python socket參考位址:

<a href="http://blog.163.com/yi_yixinyiyi/blog/static/136286889201152814341144/">http://blog.163.com/yi_yixinyiyi/blog/static/136286889201152814341144/</a>

<a href="http://blog.sina.com.cn/s/blog_4b5039210100ep72.html">http://blog.sina.com.cn/s/blog_4b5039210100ep72.html</a>

<a href="http://blog.sina.com.cn/s/blog_523491650100hikg.html">http://blog.sina.com.cn/s/blog_523491650100hikg.html</a>