2. 程式人生 > >TCP UDP粘包和程序部分

TCP UDP粘包和程序部分

阿新 • • 發佈：2018-12-20

TCP 半連線池原理

#客戶端
import socket

client = socket.socket(socket.AF_INET,socket.SOCK_STREAM)

client.connect(("127.0.0.1",9999))

while True:
        data = input(">>>:")
        if not data:continue
        client.send(data.encode("utf-8"))
        msg = client.recv(1024).decode("utf-8")
        print(msg)

client.close()

#伺服器
import socket

server = socket.socket(socket.AF_INET,socket.SOCK_STREAM)

server.bind(("127.0.0.1",9999))
#  不是最大連線數  !!
server.listen(5)

while True:
    c,addr = server.accept()
    while True:
        try:
            msg = c.recv(1024).decode("utf-8")
            if not msg:
                c.close()
                break
            c.send(msg.upper().encode("utf-8"))
        except BaseException:
            print("客戶端異常斷開")
            c.close()
            break
server.close()

UDP通訊

#客戶端
import socket

client = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)  # datagram資料報的意思

while True:
    msg = input(">>>:")
    client.sendto(msg.encode("utf-8"),("127.0.0.1",8888))
    data,addr = client.recvfrom(1024)
    print(data.decode("utf-8"))

#伺服器
import socket

# 建立socket物件  指定type引數為socket.SOCK_DGRAM 表示使用UDP協議
server = socket.socket(socket.AF_INET,socket.SOCK_DGRAM) # datagram資料報的意思
# 繫結ip和埠
server.bind(("127.0.0.1",8888))

while True:
    # 接收資料 返回一個元祖  資料和 傳送方的地址
    msg,c_addr = server.recvfrom(1024)
    print("收到來自%s: 說:%s" % (c_addr[0] ,msg.decode("utf-8")))
    # 傳送資料到指定ip和埠
    server.sendto(msg.upper(),c_addr)

UDP聊天

#客戶端
import socket

c = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

while True:
    msg = input(">>>:")
    c.sendto(msg.encode("utf-8"),("127.0.0.1",8848))
    msg, addr = c.recvfrom(1024)
    print(msg.decode("utf-8"))

#伺服器
"""
    群聊思路
        1.客戶端先把資料交給伺服器
        2.伺服器先儲存對方的地址
        3.把收到的資料給所有人都發一遍

"""


import socket

server = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)

server.bind(("127.0.0.1",8848))


# 如果客戶端與伺服器在同一臺計算機  並且有多個客戶端  這些客戶端ip都是相同的127.0.01

clients = {}

while True:
    msg,addr = server.recvfrom(1024)

    # 儲存對方的地址:
    clients[addr[1]] = addr

    print(msg.decode("utf-8"))
    # 迴圈發給所有人
    for c in clients:
        # 這個訊息不用給傳送方發回去
        # if c == addr[1]:
        #     continue
        server.sendto(msg,clients[c])

UDP聊天2

#傳送機
import socket

c = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

while True:
    msg = input(">>>:")
    c.sendto(msg.encode("utf-8"),("127.0.0.1",8848))

#接收機
import socket

c = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

# 先隨便發一條訊息給伺服器  讓服務知道自己的地址
c.sendto("register".encode("utf-8"),("127.0.0.1",8848))

while True:
    msg, addr = c.recvfrom(1024)
    print(msg.decode("utf-8"))

#伺服器
"""
    群聊思路
        1.客戶端先把資料交給伺服器
        2.伺服器先儲存對方的地址
        3.把收到的資料給所有人都發一遍

"""


import socket

server = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)

server.bind(("127.0.0.1",8848))


# 如果客戶端與伺服器在同一臺計算機  並且有多個客戶端  這些客戶端ip都是相同的127.0.01

clients = {}

while True:
    msg,addr = server.recvfrom(1024)

    # 儲存對方的地址:
    clients[addr[1]] = addr

    print(msg.decode("utf-8"))
    # 迴圈發給所有人
    for c in clients:
        # 這個訊息不用給傳送方發回去
        # if c == addr[1]:
        #     continue
        server.sendto(msg,clients[c])

UDP會粘包嗎？

1.UDP 不會粘包 2.緩衝區大小要足夠裝資料包大小 建議不要超過512

UDP的使用場景: 視訊電話 語音電話 直播

DNS 域名解析伺服器

#客戶端
import socket

client = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)  # datagram資料報的意思
client.sendto("10".encode("utf-8"),("127.0.0.1",8888))
client.sendto("22".encode("utf-8"),("127.0.0.1",8888))
client.sendto("32".encode("utf-8"),("127.0.0.1",8888))
client.sendto("43".encode("utf-8"),("127.0.0.1",8888))


# while True:
    # msg = input(">>>:")
    # client.sendto(msg.encode("utf-8"),("127.0.0.1",8888))
    # data,addr = client.recvfrom(1024)
    # print(data.decode("utf-8"))

#伺服器
import socket

# 建立socket物件  指定type引數為socket.SOCK_DGRAM 表示使用UDP協議
server = socket.socket(socket.AF_INET,socket.SOCK_DGRAM) # datagram資料報的意思
# 繫結ip和埠
server.bind(("127.0.0.1",8888))

while True:
    # 接收資料 返回一個元祖  資料和 傳送方的地址
    msg,c_addr = server.recvfrom(512)
    print("收到來自%s: 說:%s" % (c_addr[0] ,msg.decode("utf-8")))
    # 傳送資料到指定ip和埠
    server.sendto(msg.upper(),c_addr)

UDP總結

1.TCP模板程式碼 半連線池的工作原理 目前我們的程式是單執行緒 伺服器要麼處理通訊要麼處理連線請求 無法同時進行

2.TCP 和 UDP 傳送資料時的流程 ***** 解釋 為何TCP是可靠的 是因為傳送資料後必須收到確認包

  1. UDP的模板程式碼 ***** 與TCP程式碼的區別 不需要監聽 不需要接收 type引數為 SOCK_DGRAM UDP 可以同時處理多個客戶端 是因為CPU處理速度快 給人感覺像是同時處理

什麼是程序

什麼是程序 正在進行(執行)的程式 在只有一個CPU的情況下 是因為有多道技術 記憶體被分為多個區域 存放不同的應用程式 當一個應用程式遇到了I/O操作時 作業系統會將CPU分配給其他的應用程式使用 切換的時間非常短 使用者是感覺不到的 特點: 一個作業系統中可以同時存在多個程序 內部使用了多道技術 可以快速在不同程序間切換 給使用者的感覺像是同時執行 程序是一個包含程式執行所需的所有資源的單位

相關推薦

TCP UDP粘包和程序部分

TCP 半連線池原理 #客戶端 import socket client = socket.socket(socket.AF_INET,socket.SOCK_STREAM) client.connect(("127.0.0.1",9999)) while

golang中tcp socket粘包問題和處理

enc pack 獲取 人工 過程 reader 主動 exit ase 轉自：http://www.01happy.com/golang-tcp-socket-adhere/ 在用golang開發人工客服系統的時候碰到了粘包問題，那麽什麽是粘包呢？例如我們和客戶端約定數據

TCP通訊粘包問題分析和解決（全）

在socket網路程式中，TCP和UDP分別是面向連線和非面向連線的。因此TCP的socket程式設計，收發兩端（客戶端和伺服器端）都要有成對的socket，因此，傳送端為了將多個發往接收端的包，更有效的發到對方，使用了優化方法（Nagle演算法），將多次間隔較小、資料量小的

Tcp粘包和拆包的原因

最近研究Netty網路程式設計，以前專案中也遇到過資料接收過程中資料質量太差問題，很可能是TCP傳輸過程中問題，特此記錄。 問題產生 一個完整的業務可能會被TCP拆分成多個包進行傳送，也有可能把多個小的包封裝成一個大的資料包傳送，這個就是TCP的拆包和封包問

tcp粘包和拆包、斷包

    while (1) {       var packLen = _.unpack('packLen', tcpBuffer.slice(0, 2));       len = packLen.len;       // console.log('pack len------:' + len);    

tcp粘包和拆包的處理方案

隨著智慧硬體越來越流行，很多後端開發人員都有可能接觸到socket程式設計。而很多情況下，伺服器與端上需要保證資料的有序，穩定到達，自然而然就會選擇基於tcp/ip協議的socekt開發。開發過程中，經常會遇到tcp粘包，拆包的問題，本文將從產生原因，和解決方案以及work

TCP通訊粘包問題分析和解決

什麼時候需要考慮粘包問題?1.如果利用tcp每次傳送資料，就與對方建立連線，然後雙方傳送完一段資料後，就關閉連線，這樣就不會出現粘包問題（因為只有一種包結構,類似於http協議）。關閉連線主要是要雙方都發送close連線（參考tcp關閉協議）。如：A需要傳送一段字串給B，那麼

關於TCP粘包和半包的處理

今日，在程式設計過程中需要在區域網內不同的電腦間傳輸檔案，遇到了TCP協議的粘包和半包現象。經過思考和借鑑，找到了一個比較好的解決方法。因為在傳輸檔案時要先傳輸檔名和檔案大小，然後再傳輸檔案，所以電腦間的應用程式實現了一個小的協議。這個協議需要解碼TCP傳輸的內容。在有粘包

Linux下的socket程式設計實踐（四）TCP的粘包問題和常用解決方案

TCP粘包問題的產生 由於TCP協議是基於位元組流並且無邊界的傳輸協議, 因此很有可能產生粘包問題。此外，傳送方引起的粘包是由TCP協議本身造成的，TCP為提高傳輸效率，傳送方往往要收集到足夠多的資料

【Python】TCP Socket的粘包和分包的處理

概述 在進行TCP Socket開發時，都需要處理資料包粘包和分包的情況。本文詳細講解解決該問題的步驟。使用的語言是Python。實際上解決該問題很簡單，在應用層下，定義一個協議：訊息頭部+訊息長度+訊息正文即可。 那什麼是粘包和分包呢？ 關於分包和粘

Netty中處理TCP粘包和拆包

什麼是粘包和拆包 TCP是個”流”協議，流其實就是沒有界限的一串資料。 TCP底層中並不瞭解上層業務資料的具體含義，它會根據TCP緩衝區的實際情況進行包劃分，所以在TCP中就有可能一個完整地包會被TCP拆分成多個包，也有可能吧多個小的包封裝成一個大的資料包傳

Unity Socket傳輸 TCP粘包和拆包原因以及解決策略

3. 乙太網的payload大於MTU進行IP分片。MTU指：一種通訊協議的某一層上面所能通過的最大資料包大小。如果IP層有一個數據包要傳，而且資料的長度比鏈路層的MTU大，那麼IP層就會進行分片，把資料包分成若干片，讓每一片都不超過MTU。注意，IP分片可以發生在原始傳送端主機上，也可以發生在中間路由器上

詳說tcp粘包和半包

`tcp`服務端和客戶端建立連線後會長時間維持這個連線，用於互相傳遞資料，`tcp`是以流的方式傳輸資料的，就像一個水管裡的水一樣，從一頭不斷的流向另一頭。 理想情況下，傳送的資料包都是獨立的， ![](https://img2020.cnblogs.com/blog/342595/202006/3

tcp的粘包問題

rom 協議 現象 sock soc 傳輸 port blank clas 前情提要： 　　只有TCP有粘包現象，UDP永遠不會粘包 　 　知識儲備： 　　　　　　　　socket收發消息的原理 　　 發送端可以是一K一K地發送數據，而接收端的應用程序可以兩K兩K地提走數

socket編程 粘包和半包 問題的及處理

當前 多少 分包 轉義 保存 長連接 完整 過去 高效 一般在socket處理大數據量傳輸的時候會產生粘包和半包問題，有的時候tcp為了提高效率會緩沖N個包後再一起發出去，這個與緩存和網絡有關系。 粘包 為x.5個包 半包 為0.5個包 由於網絡原因 一次可能會來 0.5/

網絡通信 粘包和 緩沖器

就會 客戶 tcp 大小 .so 輸出緩沖區 發送消息 並且 緩沖器 tcp: 　　屬於長連接,與一個客戶端進行連接了以後,其他的客戶端要等待,要連接另外一個,必須優雅的斷開前面這個客戶端的連接. 允許地址重用:在bind IP地址和端口之前加上,# server.set

粘包和半包問題總結

什麼是TCP粘包半包？ 假設客戶端分別傳送了兩個資料包D1和D2給服務端，由於服務端一次讀取到的位元組數是不確定的，故可能存在以下4種情況。 （1）服務端分兩次讀取到了兩個獨立的資料包，分別是D1和D2，沒有粘包和拆包； （2）服務端一次接收到了兩個資料包，D1和D2粘合在一起，被稱為

TCP/UDP 校驗和、偽首部

tcp和udp兩個協議相對應的首部，都有一項是校驗和。 校驗和是幹什麼的？ 在接收端收到資料時，判斷協議首部和資料是否被破壞。是在資料包中真實存在的一段資料。 偽首部是幹什麼的？ 偽首部用來生成校驗和，偽首部只是一種根據真實的首部的部分資料抽象出來的一種資料結構。並沒有在資料包中

TCP 的粘包與拆包問題

之前在做專案時，使用 Java NIO 來搭建伺服器端及客戶端程式，發現待發送的資料大於傳送緩衝區 ByteBuffer 大小時，將發生拆包情況，會把待發送的資料包分多次傳送到客戶端。當時是分配了更大的位元組緩衝區來解決這個問題，後來瞭解到這是 TCP 協議中的粘包與拆包問題。首先我們瞭解一下

tcp的粘包現象與解決方案

粘包現象: 粘包1:連續的小包,會被優化機制給合併 粘包2:服務端一次性無法完全就收完客戶端傳送的資料,第二再次接收的時候,會接收到第一次遺留的內容   模擬一個粘包現象 服務端   import socket server = socket.socket(type=