socket解釋

socekt又稱為‘套接字’，用於描述IP和地址端口，是一個通信鏈路的句柄，應用程序通常通過套接字向網絡發出請求或者應答網絡請求。

socket起源於Unix，所以也遵從“一切皆文件”的基本哲學，對於文件，進行打開/讀取/關閉的操作模式。socket就是該模式的一個實現，socket即是一種特殊的文件，一些socket函數就是對其進行的操作（讀/寫IO、打開、關閉）。

socket和file文件的區別：

• file模塊是針對指定文件進行打開、讀寫、關閉操作。

• socket模塊是針對服務器和客戶端socket進行打開、讀寫、關閉操作。

Socket對象

sk = socket.socket(socket.AF_INET,socket.SOCK_STREAM,0)

參數一：地址簇

參數二：類型

Socket類方法

socket編程思路

• TCP服務端

1. 創建套接字，綁定套接字到本地IP與端口

2. 開始監聽連接

3. 進入循環，不斷接受客戶端的連接請求

4. 然後接收傳來的數據，並發送給對方數據

5. 傳輸完畢後，關閉套接字

• TCP客戶端

1. 創建套接字，連接遠端地址

2. 連接後發送數據和接收數據

3. 傳輸完畢後，關閉套接字

server端:

import socket
ip_port = (‘127.0.0.1‘,9999)
sk = socket.socket(socket.AF_INET,socket.SOCK_DGRAM,0)
sk.bind(ip_port)
?
while True:
    data = sk.recv(1024)
    print(data.decode())

client端:

import socket
ip_port = (‘127.0.0.1‘,9999)
?
sk = socket.socket(socket.AF_INET,socket.SOCK_DGRAM,0)
while True:
    inp = input(‘數據：‘).strip()
    if inp == ‘exit‘:
        break
    sk.sendto(bytes(inp,encoding=‘utf8‘),ip_port)
?
sk.close()

?

socket粘包問題

sk.recv(1024)中,bufsize值為1024,最多只能接受1024個字節,那麽如果client端發送的數據包特別大時,超過了指定的bufsize的值,超過的不分會留在內核緩沖區中，下次調用recv的時候會繼續讀剩余的字節。這就是所謂的粘包問題,那麽怎麽解決呢?

類似於http協議,我們可以:

1. 在發送之前先告訴接受數據端我要發送數據的字節大小

2. 接收數據端收到數據後回復給數據發送端一個確認消息

3. 數據發送端收到確認信息後,發送數據

4. 數據接收端循環接受數據,直到數據接受完成,收到完整數據包

client端:

import socket
ip_port=(‘127.0.0.1‘,9999)
?
s=socket.socket()
?
s.connect(ip_port)
?
while True:
    send_data=input(‘>>:‘).strip()
?
?
    if send_data==‘exit‘:break
    if len(send_data)==0:continue
    s.send(bytes(send_data,encoding=‘utf8‘))
?
    ready_tag=s.recv(1024)
    ready_tag=str(ready_tag,encoding=‘utf8‘)
    if ready_tag.startswith(‘Ready‘):
        msg_size=int(ready_tag.split(‘|‘)[-1])
        print(msg_size)
    start_tag=‘Start‘
    s.send(bytes(start_tag,encoding=‘utf8‘))
?
    recv_size=0
    recv_msg=b‘‘
?
    while recv_size < msg_size:
        recv_data=s.recv(1024)
        recv_msg+=recv_data
        recv_size+=len(recv_data)
?
    print(str(recv_msg,encoding=‘utf8‘))
?
?
s.close()

server端:

import socket,subprocess
ip_port=(‘127.0.0.1‘,9999)
?
s=socket.socket()
?
s.bind(ip_port)
?
s.listen(5)
?
?
while True:
    conn,addr=s.accept()
    while True:
        try:
            recv_data=conn.recv(1024)
            if recv_data==0:break
            p=subprocess.Popen(str(recv_data,encoding=‘utf8‘),shell=True,stdout=subprocess.PIPE)
            res=p.stdout.read()
            if len(res)==0:
                send_data=‘cmd ERROR‘
                send_data=bytes(send_data,encoding=‘utf8‘)
            else:
                send_data=res
            ready_tag=‘Ready|%s‘%len(send_data)
            conn.send(bytes(ready_tag,encoding=‘utf8‘))
?
            feedback=conn.recv(1024)
            feedback=str(feedback,encoding=‘utf8‘)
?
            if feedback.startswith(‘Start‘):
                conn.send(send_data)
?
        except Exception as ex:
            break
?
    conn.close()

python之socket網絡編程