python:socket传输大文件示例

发布时间 - 2026-01-10 22:36:56    点击率:

文件可以传输,但是对比传输前后的文件:socket_test.txt,末尾有一些不一致服务端代码:

#!/usr/bin/python
# -*- coding: utf-8 -*-
import sys
reload(sys)
sys.setdefaultencoding("utf-8")
import time
'''
等待连接
等待发送文件
读取数据
写入文件并且保存
等待连接
'''
import socket
import threading
import time
import struct


def function(newsock, address):
  FILEINFO_SIZE = struct.calcsize('128sI')
  '''定义文件信息(包含文件名和文件大小)大小。128s代表128个char[](文件名),I代表一个integer or long(文件大小)'''
  while 1:
    try:
      fhead = newsock.recv(FILEINFO_SIZE)
      filename, filesize = struct.unpack('128sI', fhead)
      '''把接收到的数据库进行解包,按照打包规则128sI'''
      print "address is: ", address
      print filename, len(filename), type(filename)
      print filesize
      #filename = 'new_'+filename.strip('\00') # 命名新文件new_传送的文件
      filename = filename.strip('\00')
      fp = open(filename, 'wb') # 新建文件,并且准备写入
      restsize = filesize
      print "recving..."
      while 1:
        if restsize > 102400: # 如果剩余数据包大于1024,就去1024的数据包
          filedata = newsock.recv(10240)
        else:
          filedata = newsock.recv(restsize)
          fp.write(filedata)
          #break
        if not filedata:
          break
        fp.write(filedata)
        restsize = restsize - len(filedata) # 计算剩余数据包大小
        if restsize <= 0:
          break
      fp.close()
      print "recv succeeded !!File named:", filename
    except Exception, e:
      print unicode(e).encode('gbk')
      print "the socket partner maybe closed"
      newsock.close()
      break
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 创建tcp连接
sock.bind(('10.240.146.82', 8887)) # 定于端口和ip
sock.listen(5) # 监听
while True:
  newsock, address = sock.accept()
  print "accept another connection"
  tmpThread = threading.Thread(target=function, args=(newsock, address)) # 如果接收到文件,创建线程
  tmpThread.start() # 执行线程
print 'end'

客户端代码:

#!/usr/bin/python
# -*- coding: utf-8 -*-
import sys
reload(sys)
sys.setdefaultencoding("utf-8")
'''
输入文件名,并且上传
'''
import socket
import time
import struct
import os
f = open('socket_test.txt', 'wb')

for i in range(1000000):
  f.write('for socket test, the line number is : ' + str(i) + '\n')

f.close()

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.settimeout(50)
e = 0
try:
  sock.connect(('10.240.146.82', 8887))
  print 'connect...'
except socket.timeout, e:
  print 'timeout', e
except socket.error, e:
  print 'error', e
except e:
  print 'any', e
if not e:
  #while (1):
    #filename = raw_input('input your filename------->') # 输入文件名
  filename = 'socket_test.txt'
  FILEINFO_SIZE = struct.calcsize('128sI') # 编码格式大小
  fhead = struct.pack('128sI', filename, os.stat(filename).st_size) # 按照规则进行打包
  sock.send(fhead) # 发送文件基本信息数据
  fp = open(filename, 'rb')
  fp2 = open('local_test.txt','wb')
  i = 0
  while 1: # 发送文件
    filedata = fp.read(10240)
    if not filedata:
      break
    sock.sendall(filedata)
    fp2.write(filedata)
    print i
    i = i + 1
  print "sending over..."
  fp.close()
  fp2.close()

 以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。


# Python  # Socket传输文件 


相关栏目: 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571


相关推荐: js实现获取鼠标当前的位置  Laravel怎么解决跨域问题_Laravel配置CORS跨域访问  uc浏览器二维码扫描入口_uc浏览器扫码功能使用地址  UC浏览器如何设置启动页 UC浏览器启动页设置方法  javascript中数组(Array)对象和字符串(String)对象的常用方法总结  如何批量查询域名的建站时间记录?  如何选择可靠的免备案建站服务器?  如何快速生成高效建站系统源代码?  中山网站制作网页,中山新生登记系统登记流程?  潮流网站制作头像软件下载,适合母子的网名有哪些?  Laravel如何实现邮件验证激活账户_Laravel内置MustVerifyEmail接口配置【步骤】  三星、SK海力士获美批准:可向中国出口芯片制造设备  Python文件流缓冲机制_IO性能解析【教程】  如何在Tomcat中配置并部署网站项目?  Laravel如何实现全文搜索_Laravel Scout集成Algolia或Meilisearch教程  js实现点击每个li节点,都弹出其文本值及修改  Laravel如何创建自定义Artisan命令?(代码示例)  Laravel如何实现全文搜索功能?(Scout和Algolia示例)  北京网站制作费用多少,建立一个公司网站的费用.有哪些部分,分别要多少钱?  个人摄影网站制作流程,摄影爱好者都去什么网站?  如何实现javascript表单验证_正则表达式有哪些实用技巧  如何在IIS服务器上快速部署高效网站?  ChatGPT怎么生成Excel公式_ChatGPT公式生成方法【指南】  如何在腾讯云服务器上快速搭建个人网站?  Laravel如何使用集合(Collections)进行数据处理_Laravel Collection常用方法与技巧  nodejs redis 发布订阅机制封装实现方法及实例代码  WordPress 子目录安装中正确处理脚本路径的完整指南  SQL查询语句优化的实用方法总结  HTML 中如何正确使用模板变量为元素的 name 属性赋值  Laravel怎么设置路由分组Prefix_Laravel多级路由嵌套与命名空间隔离【步骤】  WEB开发之注册页面验证码倒计时代码的实现  Bootstrap CSS布局之列表  用yum安装MySQLdb模块的步骤方法  深圳网站制作平台,深圳市做网站好的公司有哪些?  深圳网站制作公司好吗,在深圳找工作哪个网站最好啊?  如何自定义safari浏览器工具栏?个性化设置safari浏览器界面教程【技巧】  EditPlus中的正则表达式实战(6)  Python正则表达式进阶教程_复杂匹配与分组替换解析  Win11怎么更改系统语言为中文_Windows11安装语言包并设为显示语言  如何在七牛云存储上搭建网站并设置自定义域名?  网站广告牌制作方法,街上的广告牌,横幅,用PS还是其他软件做的?  Laravel请求验证怎么写_Laravel Validator自定义表单验证规则教程  如何在阿里云虚拟服务器快速搭建网站?  Laravel怎么实现验证码功能_Laravel集成验证码库防止机器人注册  美食网站链接制作教程视频,哪个教做美食的网站比较专业点?  JavaScript如何实现音频处理_Web Audio API如何工作?  北京网站制作公司哪家好一点,北京租房网站有哪些?  如何快速生成橙子建站落地页链接?  Laravel策略(Policy)如何控制权限_Laravel Gates与Policies实现用户授权  长沙企业网站制作哪家好,长沙水业集团官方网站?