1. 程式人生 > >Python實戰之socket初版 Linux粘包問題

Python實戰之socket初版 Linux粘包問題

網路:

1.理想的:應用 表示 會話 傳輸 網路 資料鏈路 物理層

2.現實: 應用 傳輸 網路 資料物理鏈路

應用層的所有協議最終:發send 和 收recieve 所以要封裝,這種封裝總體叫socket

所有的網路協議就是基於socket  如:http  smtp  dns  ftp  ssh  snmp  icmp  dhcp等等很多..

socket最後總結2種方式:發send  收receive   所有的協議本質都是這樣

port:65535個埠

socket示例:

接收端:import socket---定義封裝協議----監聽IP埠---等待----接收資料---傳送資料                                                

傳送端:import socket---定義封裝協議—發起連線---傳送資料---接收返回資訊—關閉

 

引數一:Socket Families(地址蔟):網路層

socket.AF_UNIX                  #本機程序間的通訊

socke.AF_INET 支援IPV4    #建立socket預設IPV4

socke.AF_INET6 支援IPV6

引數二:Socket Types:傳輸層

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_RDM #是一種可靠的UDP形式,即保證交付資料報但不保證順序。SOCK_RAM用來提供對原始協議的低階訪問,在需要執行某些特殊操作時使用,如傳送ICMP報文。SOCK_RAM通常僅限於高階使用者或管理員執行的程式

socket引數

1、源IP地址和目的IP地址以及源埠號和目的埠號的組合稱為套接字。其用於標識客戶端請求的伺服器和服務。

2、套接字,是支援TCP/IP的網路通訊的基本操作單元,可以看做是不同主機之間的程序進行雙向通訊的端點,簡單的說就是通訊的兩方的一種約定,用套接字中的相關函式來完成通訊過程。

sk.bind(address) 

將套接字繫結到地址。address地址的格式取決於地址族。在AF_INET下,以元組(host,port)的形式表示地址。

sk.listen(backlog) 

開始監聽傳入連線。backlog指定在拒絕連線之前,可以掛起的最大連線數量。backlog等於5,表示核心已經接到了連線請求,但伺服器還沒有呼叫accept進行處理的連線個數最大為5,這個值不能無限大,因為要在核心中維護連線佇列

sk.setblocking(bool) 

是否阻塞(預設True),如果設定False,那麼accept和recv時一旦無資料,則報錯。

sk.accept() 

接受連線並返回(conn,address),其中conn是新的套接字物件,可以用來接收和傳送資料。address是連線客戶端的地址。接收TCP 客戶的連線(阻塞式)等待連線的到來

sk.connect(address) 

連線到address處的套接字。一般,address的格式為元組(hostname,port),如果連接出錯,返回socket.error錯誤。

sk.connect_ex(address)

同上,只不過會有返回值,連線成功時返回 0 ,連線失敗時候返回編碼,例如:10061

sk.close() 

關閉套接字

sk.recv(bufsize[,flag]) 

接受套接字的資料。資料以字串形式返回,bufsize指定最多可以接收的數量。flag提供有關訊息的其他資訊,通常可以忽略。

sk.recvfrom(bufsize[.flag])

與recv()類似,但返回值是(data,address)。其中data是包含接收資料的字串,address是傳送資料的套接字地址。

sk.send(string[,flag]) 

將string中的資料傳送到連線的套接字。返回值是要傳送的位元組數量,該數量可能小於string的位元組大小。即:可能未將指定內容全部發送。

sk.sendall(string[,flag]) 

將string中的資料傳送到連線的套接字,但在返回之前會嘗試傳送所有資料。成功返回None,失敗則丟擲異常。內部通過遞迴呼叫send,將所有內容傳送出去。

sk.sendto(string[,flag],address)

將資料傳送到套接字,address是形式為(ipaddr,port)的元組,指定遠端地址。返回值是傳送的位元組數。該函式主要用於UDP協議。

sk.settimeout(timeout) 

設定套接字操作的超時期,timeout是一個浮點數,單位是秒。值為None表示沒有超時期。一般,超時期應該在剛建立套接字時設定,因為它們可能用於連線的操作(如 client 連線最多等待5s )

sk.getpeername()  

返回連線套接字的遠端地址。返回值通常是元組(ipaddr,port)。

sk.getsockname()

返回套接字自己的地址。通常是一個元組(ipaddr,port)

sk.fileno()

套接字的檔案描述符

socket.sendfile(file, offset=0, count=None)

 傳送檔案 ,但目前多數情況下並無什麼卵用。

socket實戰初版

服務端

import socket
server = socket.socket()
#預設是socke.AF_INET:IPV4 和 socket.SOCK_STREAMTCP
#等於宣告socket型別,同時生成socket連線物件
server.bind(('0.0.0.0',6969))#繫結要監聽埠
server.listen()#監聽埠
conn,addr = server.accept()
#客戶訪問進來了後,accept會返回2個值:連結標記位和對方的地址
# 賦予兩個值的變數:conn:連結標記位,addr:對方的地址
#conn:就是客戶端連線過來而在伺服器端為其生成的一個連線例項
   #如:<socket.socket fd=264, family=AddressFamily.AF_INET,
        # type=SocketKind.SOCK_STREAM,
        #  proto=0, laddr=('127.0.0.1', 6969),
        # raddr=('127.0.0.1', 61401)> ('127.0.0.1', 61401)
     #客戶端的IP是127.0.0.1 埠:61401(發起端是隨機埠)
data = conn.recv(1024)#通過連結標記位conn接收客戶端的資料
                     #(1024位元組=1k):每次最多接收1024位元組、官方建議8192
print("recv:",data.decode())
#由於有中文如果不進行decode解碼的話列印顯示byts型別xe6\x88\x91\xe...
conn.send(data.upper())#通過連結標記位conn返回資料給客戶端
#data=收到了客戶端的資料 假如客戶端傳送過來的是“b'Hello World'”
# data.upper ==b'Hello World.upper(變大寫) == b'HELLO WORLD'
#傳送返回b'HELLO WORLD'給客戶端
server.close()

客戶端

import socket
client = socket.socket()
#預設是socke.AF_INET:IPV4 和 socket.SOCK_STREAM:TCP
#等於宣告socket型別,同時生成socket連線物件
client.connect(('localhost',6969))
#連線到本地(如果不是本地就輸入IP)的6969埠
client.send(b"Hello World   ")# b相當於把字串型別轉成byts型別
client.send("我要下載xx資源".encode("utf-8"))
# 但是記住b是處理ASCII轉換的對於中文是無效的
# 中文就需要加上"xxx".encode("utf-8")
#傳送byts:Hello World
#在python3只可以發byts型別(位元流),不可以發字串,需要轉換
#python2既可以發byts 也可以發字串無需轉換
#總之記住傳資料需要把資料型別轉換byts型別
data = client.recv(1024) #接收服務端的資料
#(1024位元組=1k):每次最多接收1024位元組、官方建議8192
print("recv:",data.decode())
#由於有中文如果不進行decode解碼的話列印顯示byts型別xe6\x88\x91\xe...
client.close()

 

Linux上的socket粘包問題

兩個conn.send 語句緊挨著,系統我自動合併當成一次傳送如上面服務端:

解決方案:2種

在緊挨傳送的中間插入

1.#time.sleep(0.5)#兩個傳送緊連著會出現粘包問題出錯,所以需要間隔時間#但是不可以用sleep,如果實時且資料大...就搞死了

2. 服務端:

client_ack = conn.recv(1024)#wait client to confirm(我們在客戶端設定接收了資料大小後,給我一個恢復,當收到回覆了以後就可以繼續往下執行

客戶端

client.send("準備好接收了,loser可以發了".encode("utf-8"))#在接收第服務端第一個傳送的資料後進行對服務端的回覆,