Python中,socket用來實(shí)現(xiàn)網(wǎng)絡(luò)通信,它默認(rèn)的recv是一個(gè)阻塞的函數(shù),也就是說,當(dāng)運(yùn)行到recv時(shí),會(huì)在這個(gè)位置一直等待直到有數(shù)據(jù)傳輸過來,我在網(wǎng)上一篇文章看到:
Sunmmary
Python的socket.recv()方法可以通過傳入flags=0x40參數(shù)配合try-except方法實(shí)現(xiàn)非阻塞。
于是便欣喜的放到了代碼中,結(jié)果:
結(jié)果.png
然后又看到傳入socket.MSG_DONTWAIT解決,結(jié)果:
結(jié)果.png
最后,終于找到一種可用的方法,使用setblocking設(shè)置.
s.setblocking(0) #非阻塞模式
s.setblocking(1) #阻塞模式
然后需要使用try/except語句捕捉BlockingIOError進(jìn)行判斷是否還有輸入,這里分享一個(gè)小技巧,為了等待數(shù)據(jù),我們可以用一個(gè)阻塞的recv等待,在這之后使用while循環(huán)進(jìn)行非阻塞接收以接收不定長(zhǎng)的數(shù)據(jù).
接收函數(shù)代碼:
def recv(s):
buffer=[s.recv(1024)] #一開始的部分,用于等待傳輸開始,避免接收不到的情況.
if buffer[0] in (0,-1): #返回0,-1代表出錯(cuò)
return False
s.setblocking(0) #非阻塞模式
while True: #循環(huán)接收
try:
data=s.recv(1024) #接收1024字節(jié)
buffer.append(data) #拼接到結(jié)果中
except BlockingIOError as e: #如果沒有數(shù)據(jù)了
break #退出循環(huán)
s.setblocking(1) #恢復(fù)阻塞模式
return b"".join(buffer).decode("utf-8") #編碼并返回
以上是這篇文章的全部,錯(cuò)誤的地方懇請(qǐng)指正.
QQ:8955859,希望能和大家一起學(xué)習(xí).
最后,都看到這了,贊賞一下唄!(^ ~ ^||).
