91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Python tcp傳輸代碼實例解析

發布時間:2020-10-04 17:50:38 來源:腳本之家 閱讀:111 作者:flag_HW 欄目:開發技術

socket是編程語言對tcp/ip協議的封裝,使用其可以在兩個主機之間傳輸文件,下面直接進入主題,下面示例是最簡單的tcp傳輸代碼示例,先啟動server再啟動client。需要注意python3socket只能傳輸byte類型,具體如何轉換可以復習字符編碼章節相關知識

sever端代碼

# -*- coding:utf-8 -*-
import socket
server = socket.socket()
server.bind(("0.0.0.0", 8888))
server.listen(10)
while True: #循環監聽連接過來的客戶端
  conn,addr = server.accept()
  while True: #每個客戶端連接過來以后持續交互,當客戶端端斷開后在和下一個客戶端交互
    try:
      rec_data = conn.recv(4096) #4096接收緩沖區大小
      if len(rec_data) == 0:
        break
      print("rec_data:", rec_data.decode(encoding="utf-8"))
      conn.send(rec_data.upper())
    except ConnectionResetError as e:
      print("一個客戶端關閉了連接")
      break
server.close()

client端代碼

import socket
client = socket.socket()
client.connect(("127.0.0.1", 8888))
while True:
  msg = input()
  if len(msg) == 0:
    continue
  client.send(msg.encode(encoding="utf-8")) #如果發送中文需要對其進行encode,接收也需要decode;英文前面直接加b指定類型
  client_rec = client.recv(4096)
  print("client_rec:", client_rec)
client.close()

粘包解決方法:對于兩條緊挨的send語句,會存在上一條send的內容與下一條send的內容混在一起的情況,這個是因為send只是將數據發送給os,具體os如何發送數據無法控制,使用下面方法能夠解決兩條send語句之間發送報文粘包問題

server端代碼

import socket, os
server = socket.socket()
server.bind(("0.0.0.0", 8888))
server.listen(10)
while True: #循環監聽連接過來的客戶端
  conn,addr = server.accept()
  while True: #收到客戶端發過來的get filename如果filename存在就將文件發出否則返回文件不存在
    try:
      rec_data = conn.recv(1024) #4096接收緩沖區大小
      if len(rec_data) == 0:
        break
      rec_str_list = rec_data.decode(encoding="utf-8").split(" ")
      filename = rec_str_list[-1]
      if os.path.isfile(filename):#判斷文件在當前路徑下存在句將文件傳給客戶端
        file_data = open(filename,encoding="utf-8").read()
        conn.send(str(len(file_data)).encode(encoding="utf-8")) #將文件長度傳給客戶端
        print(conn.recv(1024).decode(encoding="utf-8")) #客戶端收到文件長度返回確認信息,server收到確認信息后再開始傳送數據
        conn.sendall(file_data.encode(encoding="utf-8"))#將數據全部發個客戶端,客戶端判斷數據接收完成后發送接收完成的信息
        print(conn.recv(1024).decode(encoding="utf-8")) #接收客戶端接收完成的確認指令,避免兩個send直接連在一起產生粘包
      else:#如果文件名不存在則返回文件不存在
        conn.send(b"file is not exit")
    except ConnectionResetError as e:
      print("一個客戶端關閉了連接")
      break
server.close()

client端代碼

import socket, os
#輸入get 文件名,當文件存在server家目錄下則返回文件,客戶端將接收文件內容并打印,
client = socket.socket()
client.connect(("127.0.0.1", 8888))
while True:
  msg = input()
  if len(msg) == 0:
    continue
  client.send(msg.encode(encoding="utf-8")) #如果發送中文需要對其進行encode,接收也需要decode;英文前面直接加b指定類型
  client_rec = client.recv(1024).decode(encoding="utf-8")
  print("client_rec", client_rec)
  if client_rec == "file is not exit": #如果文件不存在則用戶打印文件不存在,用戶繼續輸入
    print(client_rec)
    continue
  client.send(client_rec.encode(encoding="utf-8"))#文件存在則將文件大小發回去
  rec_len = int(client_rec)
  print("rec_len", rec_len)
  file_len = 0
  new_file = open("new_file","a",encoding="utf-8")
  while file_len < rec_len:#開始循環接收文件直到接收的文件大小與server端發過來的大小一樣,將接收到的數據寫入新文件
    rec_data_tmp = client.recv(1024)
    file_len += len(rec_data_tmp)
    print("receive date len", file_len)
    new_file.write(rec_data_tmp.decode(encoding="utf-8"))
  client.send("receive all".encode(encoding="utf-8"))

client.close()

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持億速云。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

太仆寺旗| 岳阳县| 嘉义市| 南康市| 青阳县| 奎屯市| 陆良县| 长垣县| 科技| 宝山区| 山丹县| 建德市| 攀枝花市| 伊通| 故城县| 万安县| 莱州市| 汉源县| 乌鲁木齐市| 昌乐县| 永兴县| 宣恩县| 灵璧县| 沂水县| 宝丰县| 大兴区| 环江| 信宜市| 锡林浩特市| 怀宁县| 鄂伦春自治旗| 龙海市| 榆林市| 定陶县| 香港| 且末县| 遂川县| 莎车县| 安庆市| 龙里县| 新平|