
文章目錄
- 打開一個網路介面:套接字
- 系結IP與埠:bind
- 監聽網路來信:監聽套接字
- 接收網路來訪者:允許連接
- 客戶端方面:申請連接
- 關閉通信套接字:close()
- 公共用途的套接字函式
- 服務端/客戶端,放碼過來
- 服務端
- 客戶端
- 結果輸出
抱歉,我一直堅定選擇的是后端,嘿嘿嘿,
就算是Python,我也要繞回后端來,
上圖是socket網路編程的流程圖
至于資料在網路中是怎么走的,咱先不說,那個太底層了,咱今天見就說如何將資料從咱的螢屏上放到網路流中去,
這可不是鍵盤敲敲,回車一按的事情,在這背后,那也是百轉千回,
打開一個網路介面:套接字
Socket又稱"套接字",應用程式通常通過"套接字"向網路發出請求或者應答網路請求,使主機間或者一臺計算機上的行程間可以通訊,
Python 中,我們用 socket()函式來創建套接字,語法格式如下:
import socket # 居然是個內置模塊
socket.socket([family[, type[, proto]]])
引數釋義:
family: 套接字家族可以使 AF_UNIX(本地協議) 或者 AF_INET(產生IPV4),
type: 套接字型別可以根據是面向連接的還是非連接分為
SOCK_STREAM(這個協議是按照順序的、可靠的、資料完整的基于位元組流的連接,這是一個使用最多的socket型別,是用TCP協議來傳輸的,)
或 SOCK_DGRAM(這個協議是無連接的,固定長度的連接呼叫,該協議是不可靠的,使用UDP來進行它的連接,),
protocol: 一般不填默認為 0,
回傳值:回傳一個通信套接字,為本機向網路通信的介面,
系結IP與埠:bind
bind() 用來關聯 socket 到指定的網路介面(IP 地址)和埠號:
bind(hostname,port)
引數釋義:
hostname:主機IP
port:進行網路通信的埠
127.0.0.1 是標準的 IPv4 回環地址,只有主機上的行程可以連接到服務器,如果你傳了空字串,服務器將接受本機所有可用的 IPv4 地址,
埠號應該是 1-65535 之間的整數(0是保留的),這個整數就是用來接受客戶端鏈接的 TCP 埠號,如果埠號小于 1024,有的作業系統會要求管理員權限,
監聽網路來信:監聽套接字
listen(backlog) #開始 TCP 監聽,
引數釋義:
backlog 指定在拒絕連接之前,作業系統可以掛起的最大連接數量,該值至少為 1,大部分應用程式設為 5 就可以,做并發的話可以設大一些,比方說20,
函式listen用來初始化服務器可連接佇列,
服務器處理客戶端連接時是順序處理的,同一時間只能處理一個客戶端連接,
當多個客戶端的連接請求同時到來的時候,服務器將不能處理的客戶端連接請求放入到等待佇列中,這個佇列的長度由listen()函式來指定,
(這里面包括了還沒握手的、一次握手的、兩次握手的,只要還沒握完,通通進去待著)
大多數系統的設定為20,其實真的沒必要太多,真的,
根據系統的可承受負載和程式的需求來確定,
系統有一個最大偵聽佇列數,一般是128(somaxconn),可以調優,
接收網路來訪者:允許連接
accept() #被動接受TCP客戶端連接,(阻塞式)等待連接的到來
accept() 方法阻塞并等待傳入連接,當一個客戶端連接時,它將回傳一個新的 socket 物件,物件中有表示當前連接的 conn 和一個由主機、埠號組成的 IPv4/v6 連接的元組,
我們將用這個 socket 物件和客戶端進行通信,
客戶端方面:申請連接
connect((HOST, PORT))
引數不用我再釋義了吧,回傳一個通信套接字,
主動初始化TCP服務器連接,,一般address的格式為元組(hostname,port),如果連接出錯,回傳socket.error錯誤,
connect_ex() connect()函式的擴展版本,出錯時回傳出錯碼,而不是拋出例外,
關閉通信套接字:close()
用于關閉對某一個套接字的函式,
公共用途的套接字函式
s.recv() # 接收 TCP 資料,資料以字串形式回傳,bufsize 指定要接收的最大資料量,flag 提供有關訊息的其他資訊,通常可以忽略,
s.send() # 發送 TCP 資料,將 string 中的資料發送到連接的套接字,回傳值是要發送的位元組數量,該數量可能小于 string 的位元組大小,
s.recvfrom() # 接收 UDP 資料,與 recv() 類似,但回傳值是(data,address),其中 data 是包含接收資料的字串,address 是發送資料的套接字地址,
s.sendto() # 發送 UDP 資料,將資料發送到套接字,address 是形式為(ipaddr,port)的元組,指定遠程地址,回傳值是發送的位元組數,
這里面函式要拿出來單講都能寫一篇,
服務端/客戶端,放碼過來
我先打個樣兒,后來人可以直接拿去修改了自己用:
服務端
import socket
# create a socket object
serversocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# get local machine name
host = socket.gethostname()
port = 8088
# bind to the port
serversocket.bind((host, port))
print("Server start at port: 8088")
# queue up to 5 requests
serversocket.listen(5)
while True:
# establish a connection
clientsocket,addr = serversocket.accept()
print("Got a connection from %s" % str(addr))
msg='Thank you for connecting'+ "\r\n"
clientsocket.send(msg.encode('utf-8'))
clientsocket.close()
客戶端
import socket
# create a socket object
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# get local machine name
host = socket.gethostname()
port = 8088
# connection to hostname on the port.
s.connect((host, port))
# Receive no more than 1024 bytes
msg = s.recv(1024)
s.close()
print (msg.decode('ascii'))
結果輸出
Server start at port: 8088
Got a connection from ('172.28.47.243', 9599)
Thank you for connecting
本文是處理單連接的,這是一種場景,不過更過的場景是處理多連接,大并發的,
后面會出啦,我先去調查一下Python是否支持epoll,
因為這篇主要是為我六月份的那個專案服務的,所以連接足夠用啦,

轉載請註明出處,本文鏈接:https://www.uj5u.com/houduan/278091.html
標籤:python
